libp2p/protocols/kademlia/provider

Search:
Group by:
Source   Edit  

Procs

proc `<`(a, b: ProviderRecord): bool {.inline, ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc `<`(a: ProviderRecord; b: chronos.Moment): bool {.inline, ...raises: [],
    tags: [], forbids: [].}
Source   Edit  
proc `==`(a, b: ProviderRecord): bool {.inline, ...raises: [], tags: [],
                                        forbids: [].}
Source   Edit  
proc `[]`(pr: ProviderRecords; i: int): ProviderRecord {.inline, ...raises: [],
    tags: [], forbids: [].}
Source   Edit  
proc addProvider(kad: KadDHT; cid: Cid): InternalRaisesFuture[void,
    (CancelledError,)] {....gcsafe, stackTrace: false, raises: [], gcsafe,
                         tags: [RootEffect], forbids: [].}
Find the closest nodes to the key via FIND_NODE and send ADD_PROVIDER with self's peerInfo to each of them Source   Edit  
proc del(pk: ProvidedKeys; c: Cid) {.inline, ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc del(pr: ProviderRecords; index: Natural) {.inline, ...raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc dispatchGetProviders(switch: Switch; peer: PeerId; key: Key): InternalRaisesFuture[
    (HashSet[Provider], seq[Peer]),
    (CancelledError, DialFailedError, LPStreamError)] {....stackTrace: false,
    raises: [], gcsafe, tags: [RootEffect], forbids: [].}
Source   Edit  
proc find(pr: ProviderRecords; record: ProviderRecord): int {.inline,
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc getProviders(kad: KadDHT; key: Key): InternalRaisesFuture[
    HashSet[Provider], (LPStreamError, DialFailedError, CancelledError)] {.
    ...gcsafe, stackTrace: false, raises: [], gcsafe, tags: [RootEffect],
    forbids: [].}
Get providers for a given key from the nodes closest to that key. Source   Edit  
proc handleAddProvider(kad: KadDHT; conn: Connection; msg: Message): InternalRaisesFuture[
    void, (CancelledError,)] {....stackTrace: false, raises: [], gcsafe,
                               tags: [RootEffect], forbids: [].}
Source   Edit  
proc handleGetProviders(kad: KadDHT; conn: Connection; msg: Message): InternalRaisesFuture[
    void, (CancelledError,)] {....stackTrace: false, raises: [], gcsafe,
                               tags: [RootEffect], forbids: [].}
Source   Edit  
proc hasKey(pk: ProvidedKeys; c: Cid): bool {.inline, ...raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc isFull(pk: ProvidedKeys): bool {.inline, ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc isFull(pr: ProviderRecords): bool {.inline, ...raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc len(pk: ProvidedKeys): int {.inline, ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc len(pr: ProviderRecords): int {.inline, ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc manageExpiredProviders(kad: KadDHT): InternalRaisesFuture[void,
    (CancelledError,)] {....stackTrace: false, raises: [], gcsafe,
                         tags: [RootEffect], forbids: [].}
Source   Edit  
proc manageRepublishProvidedKeys(kad: KadDHT): InternalRaisesFuture[void,
    (CancelledError,)] {....stackTrace: false, raises: [], gcsafe,
                         tags: [RootEffect], forbids: [].}
Source   Edit  
proc pop(pr: ProviderRecords): ProviderRecord {.inline, ...raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc push(pr: ProviderRecords; record: ProviderRecord) {.inline, ...raises: [],
    tags: [], forbids: [].}
Source   Edit  
proc startProviding(kad: KadDHT; c: Cid): InternalRaisesFuture[void,
    (CancelledError,)] {....stackTrace: false, raises: [], gcsafe,
                         tags: [RootEffect], forbids: [].}
Source   Edit  
proc stopProviding(kad: KadDHT; c: Cid) {....raises: [], tags: [], forbids: [].}
Source   Edit