Imports

../../../peerid, ../../../routing_record, ../../../utility

Types

ControlGraft = object topicID*: string: Source Edit
ControlIHave = object topicID*: string messageIDs*: seq[MessageId]: Source Edit
ControlIMReceiving = object messageID*: MessageId messageLength*: uint32: Source Edit
ControlIWant = object messageIDs*: seq[MessageId]: Source Edit
ControlMessage = object ihave*: seq[ControlIHave] iwant*: seq[ControlIWant] graft*: seq[ControlGraft] prune*: seq[ControlPrune] idontwant*: seq[ControlIWant] when defined(libp2p_gossipsub_1_4): preamble*: seq[ControlPreamble] imreceiving*: seq[ControlIMReceiving]: Source Edit
ControlPreamble = object topicID*: string messageID*: MessageId messageLength*: uint32: Source Edit
ControlPrune = object topicID*: string peers*: seq[PeerInfoMsg] backoff*: uint64: Source Edit
Message = object fromPeer*: PeerId data*: seq[byte] seqno*: seq[byte] topic*: string signature*: seq[byte] key*: seq[byte]: Source Edit
MessageId = seq[byte]: Source Edit
PeerInfoMsg = object peerId*: PeerId signedPeerRecord*: seq[byte]: Source Edit
RPCMsg = object subscriptions*: seq[SubOpts] messages*: seq[Message] control*: Option[ControlMessage] ping*: seq[byte] pong*: seq[byte]: Source Edit
SaltedId = object data*: MDigest[256]: Source Edit
SubOpts = object subscribe*: bool topic*: string: Source Edit

Procs

proc byteSize(ihaves: seq[ControlIHave]): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc byteSize(imreceivings: seq[ControlIMReceiving]): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc byteSize(iwants: seq[ControlIWant]): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc byteSize(msg: Message): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc byteSize(msgs: seq[Message]): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc byteSize(preambles: seq[ControlPreamble]): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc byteSize(rpc: RPCMsg): int {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(c: ControlMessage): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(m: RPCMsg): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(msg: Message): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(s: ControlGraft): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(s: ControlIHave): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(s: ControlIMReceiving): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(s: ControlIWant): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(s: ControlPreamble): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func shortLog(s: ControlPrune): auto {....raises: [], tags: [], forbids: [].}: Source Edit
func withSubs(T: type RPCMsg; topics: openArray[string]; subscribe: bool): T:type {. ...raises: [].}: Source Edit

libp2p/protocols/pubsub/rpc/messages

Imports

Types

Procs