Imports

Types

ConnectionType = enum notConnected = 0, connected = 1, canConnect = 2, cannotConnect = 3: Source Edit
Message {.public.} = object msgType*: MessageType key*: seq[byte] record*: Opt[Record] closerPeers*: seq[Peer] providerPeers*: seq[Peer]: Source Edit
MessageType = enum putValue = 0, getValue = 1, addProvider = 2, getProviders = 3, findNode = 4, ping = 5: Source Edit
Peer {.public.} = object id*: seq[byte] addrs*: seq[MultiAddress] connection*: ConnectionType: Source Edit
Record {.public.} = object key*: seq[byte] value*: Opt[seq[byte]] timeReceived*: Opt[string]: Source Edit

proc decode(T: type Message; buf: seq[byte]): ProtoResult[T]: Source Edit
proc decode(T: type Message; pb: ProtoBuffer): ProtoResult[T]: Source Edit
proc decode(T: type Peer; pb: ProtoBuffer): ProtoResult[T]: Source Edit
proc decode(T: type Record; pb: ProtoBuffer): ProtoResult[T]: Source Edit
proc encode(msg: Message): ProtoBuffer {....raises: [], gcsafe, tags: [RootEffect], forbids: [].}: Source Edit
proc encode(peer: Peer): ProtoBuffer {....raises: [], tags: [], forbids: [].}: Source Edit
proc encode(record: Record): ProtoBuffer {....raises: [], tags: [RootEffect], forbids: [].}: Source Edit
proc write(pb: var ProtoBuffer; field: int; value: Record) {....raises: [], gcsafe, tags: [RootEffect], forbids: [].}: Source Edit
proc writeOpt[T](pb: var ProtoBuffer; field: int; opt: Opt[T]) {....raises: [], gcsafe.}: Source Edit