Procs
proc bootstrapNode(kad: KadDHT; peerId: PeerId; addrs: seq[MultiAddress]): InternalRaisesFuture[ void, (CancelledError,)] {....stackTrace: false, raises: [], gcsafe, tags: [RootEffect], forbids: [].}
- Uses node with peerId and addrs as a bootstrap node Source Edit
proc new(T: typedesc[KadDHT]; switch: Switch; bootstrapNodes: seq[(PeerId, seq[MultiAddress])] = @[]; config: KadDHTConfig = KadDHTConfig.new(); rng: ref HmacDrbgContext = newRng(); client: bool = false; codec: string = KadCodec): T:type {....raises: [].}
- Source Edit
Exports
-
$, bucketIndex, insert, isStale, oldestPeer, findClosest, new, randomKeyInBucketRange, new, findClosestPeerIds, insert, decode, encode, write, Record, ConnectionType, MessageType, encode, Message, decode, writeOpt, decode, encode, decode, Peer, formatItIMPL, ProviderRecords, Bucket, DefaultQuorum, DefaultBucketRefreshTime, Key, isValid, xorDistance, RoutingTable, DefaultRetries, KadDHT, XorDistance, DefaultMaxBuckets, new, isValid, toPeer, get, KadDHTConfig, toPeer, Provider, init, TimeStamp, EntrySelector, MaxMsgSize, xorDistance, DefaultCleanupProvidersInterval, LocalTable, EntryValidator, shortLog, IdLength, KadCodec, select, ProviderRecord, DefaultAlpha, toKey, DefaultProviderExpirationInterval, toKey, countLeadingZeroBits, RoutingTableConfig, toCid, XorDHasher, toPeerIds, <, DefaultTimeout, <=, DefaultEntrySelector, DefaultProvidedKeyCapacity, DefaultRepublishInterval, select, toKey, EntryRecord, toPeerId, ReceivedTable, NodeEntry, insert, xorDistance, DefaultProviderRecordCapacity, xorDistance, ProviderManager, CandidatePeers, leadingZeros, DefaultEntryValidator, DefaultReplication, new, cmp, noOpHasher, ProvidedKeys, findClosestPeers, sendFindNode, handleFindNode, findNode, findPeer, handleGetValue, getValue, putValue, handlePutValue, dispatchPutVal, isFull, <, startProviding, handleAddProvider, isFull, ==, stopProviding, pop, addProvider, hasKey, getProviders, dispatchGetProviders, len, len, <, find, del, manageExpiredProviders, manageRepublishProvidedKeys, del, handleGetProviders, push, [], ping, handlePing