libp2p/protocols/pubsub/rpc/messages

Search:
Group by:
Source   Edit  

Types

ControlExtensions {.proto2.} = object
  partialMessageExtension* {.fieldNumber: 10.}: Opt[bool]
  testExtension* {.fieldNumber: 6492434.}: Opt[bool]
  pingpongExtension* {.fieldNumber: 3145728.}: Opt[bool]
  preambleExtension* {.fieldNumber: 4194304.}: Opt[bool]
Source   Edit   
ControlGraft {.proto2.} = object
  topicID* {.fieldNumber: 1.}: Opt[string]
Source   Edit   
ControlIHave {.proto2.} = object
  topicID* {.fieldNumber: 1.}: Opt[string]
  messageIDs* {.fieldNumber: 2.}: seq[MessageId]
Source   Edit   
ControlIWant {.proto2.} = object
  messageIDs* {.fieldNumber: 1.}: seq[MessageId]
Source   Edit   
ControlMessage {.proto2.} = object
  ihave* {.fieldNumber: 1.}: seq[ControlIHave]
  iwant* {.fieldNumber: 2.}: seq[ControlIWant]
  graft* {.fieldNumber: 3.}: seq[ControlGraft]
  prune* {.fieldNumber: 4.}: seq[ControlPrune]
  idontwant* {.fieldNumber: 5.}: seq[ControlIWant]
  extensions* {.fieldNumber: 6.}: Opt[ControlExtensions]
Source   Edit   
ControlPrune {.proto2.} = object
  topicID* {.fieldNumber: 1.}: Opt[string]
  peers* {.fieldNumber: 2.}: seq[PeerInfoMsg]
  backoff* {.fieldNumber: 3, pint.}: Opt[uint64]
Source   Edit   
IMReceiving {.proto2.} = object
  messageID* {.fieldNumber: 1.}: Opt[MessageId]
  messageLength* {.fieldNumber: 2, pint.}: Opt[uint32]
Source   Edit   
Message {.proto2.} = object
  fromPeer* {.fieldNumber: 1, ext.}: Opt[PeerId]
  data* {.fieldNumber: 2.}: Opt[seq[byte]]
  seqno* {.fieldNumber: 3.}: Opt[seq[byte]]
  topic* {.fieldNumber: 4, required.}: string
  signature* {.fieldNumber: 5.}: Opt[seq[byte]]
  key* {.fieldNumber: 6.}: Opt[seq[byte]]
Source   Edit   
MessageId = seq[byte]
Source   Edit   
PartialMessageExtensionRPC {.proto2.} = object
  topicID* {.fieldNumber: 1.}: Opt[string]
  groupID* {.fieldNumber: 2.}: Opt[seq[byte]]
  partialMessage* {.fieldNumber: 3.}: Opt[seq[byte]]
  partsMetadata* {.fieldNumber: 4.}: Opt[seq[byte]]
Source   Edit   
PeerInfoMsg {.proto2.} = object
  peerId* {.fieldNumber: 1, ext.}: Opt[PeerId]
  signedPeerRecord* {.fieldNumber: 2.}: Opt[seq[byte]]
Source   Edit   
PingPongExtensionRPC {.proto2.} = object
  ping* {.fieldNumber: 1.}: Opt[seq[byte]]
  pong* {.fieldNumber: 2.}: Opt[seq[byte]]
Source   Edit   
Preamble {.proto2.} = object
  topicID* {.fieldNumber: 1.}: Opt[string]
  messageID* {.fieldNumber: 2.}: Opt[MessageId]
  messageLength* {.fieldNumber: 3, pint.}: Opt[uint32]
Source   Edit   
PreambleExtensionRPC {.proto2.} = object
  preamble* {.fieldNumber: 1.}: seq[Preamble]
  imreceiving* {.fieldNumber: 2.}: seq[IMReceiving]
Source   Edit   
RPCMsg {.proto2.} = object
  subscriptions* {.fieldNumber: 1.}: seq[SubOpts]
  messages* {.fieldNumber: 2.}: seq[Message]
  control* {.fieldNumber: 3.}: Opt[ControlMessage]
  partialMessageExtension* {.fieldNumber: 10.}: Opt[PartialMessageExtensionRPC]
  testExtension* {.fieldNumber: 6492434.}: Opt[TestExtensionRPC]
  pingpongExtension* {.fieldNumber: 3145728.}: Opt[PingPongExtensionRPC]
  preambleExtension* {.fieldNumber: 4194304.}: Opt[PreambleExtensionRPC]
Source   Edit   
SaltedId = object
  data*: MDigest[256]
Source   Edit   
SubOpts {.proto2.} = object
  subscribe* {.fieldNumber: 1.}: Opt[bool]
  topic* {.fieldNumber: 2.}: Opt[string]
  requestsPartial* {.fieldNumber: 3.}: Opt[bool]
  supportsSendingPartial* {.fieldNumber: 4.}: Opt[bool]
Source   Edit   
TestExtensionRPC {.proto2.} = object
Source   Edit  

Procs

func anonymize(msg: Message; anonymize: bool): Message {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
func anonymize(msg: RPCMsg; anonymize: bool): RPCMsg {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
proc byteSize(ihaves: seq[ControlIHave]): int {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
proc byteSize(imreceivings: seq[IMReceiving]): 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[Preamble]): 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(pme: PartialMessageExtensionRPC): auto {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
func shortLog(rpc: PingPongExtensionRPC): auto {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
func shortLog(rpc: PreambleExtensionRPC): 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: ControlIWant): auto {....raises: [], tags: [], forbids: [].}
Source   Edit   
func shortLog(s: ControlPrune): auto {....raises: [], tags: [], forbids: [].}
Source   Edit   
func shortLog(s: IMReceiving): auto {....raises: [], tags: [], forbids: [].}
Source   Edit   
func shortLog(s: Preamble): auto {....raises: [], tags: [], forbids: [].}
Source   Edit   
func shortLog(so: Opt[ControlExtensions]): auto {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
func validate(msg: RPCMsg): Result[void, string] {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
func validate(sub: SubOpts): Result[void, string] {....raises: [], tags: [],
    forbids: [].}
Source   Edit   
proc withControl(_: typedesc[RPCMsg]; control: sink ControlMessage): RPCMsg {.
    ...raises: [].}
Source   Edit   
proc withExtensions(_: typedesc[ControlMessage]; ext: sink ControlExtensions): ControlMessage {.
    ...raises: [].}
Source   Edit   
proc withGraft(_: typedesc[ControlMessage]; topicID: string): ControlMessage {.
    ...raises: [].}
Source   Edit   
proc withIDontWant(_: typedesc[ControlMessage]; msgId: MessageId): ControlMessage {.
    ...raises: [].}
Source   Edit   
proc withIDontWant(_: typedesc[ControlMessage]; msgIds: sink seq[MessageId]): ControlMessage {.
    ...raises: [].}
Source   Edit   
proc withIHave(_: typedesc[ControlMessage]; topicID: string;
               messageIDs: sink seq[MessageId]): ControlMessage {....raises: [].}
Source   Edit   
proc withIMReceiving(_: typedesc[RPCMsg]; imreceiving: sink seq[IMReceiving]): RPCMsg {.
    ...raises: [].}
Source   Edit   
proc withIMReceiving(_: typedesc[RPCMsg]; preamble: sink Preamble): RPCMsg {.
    ...raises: [].}
Source   Edit   
proc withIWant(_: typedesc[ControlMessage]; msgId: MessageId): ControlMessage {.
    ...raises: [].}
Source   Edit   
proc withIWant(_: typedesc[ControlMessage]; msgIds: sink seq[MessageId]): ControlMessage {.
    ...raises: [].}
Source   Edit   
proc withMessages(_: typedesc[RPCMsg]; messages: sink seq[Message]): RPCMsg {.
    ...raises: [].}
Source   Edit   
proc withMessages(_: typedesc[RPCMsg]; msg: sink Message): RPCMsg {....raises: [].}
Source   Edit   
proc withPing(_: typedesc[RPCMsg]; ping: sink Opt[seq[byte]]): RPCMsg {.
    ...raises: [].}
Source   Edit   
proc withPing(_: typedesc[RPCMsg]; ping: sink seq[byte]): RPCMsg {....raises: [].}
Source   Edit   
proc withPong(_: typedesc[RPCMsg]; pong: sink seq[byte]): RPCMsg {....raises: [].}
Source   Edit   
proc withPreamble(_: typedesc[RPCMsg]; msgs: seq[Message];
                  msgIds: seq[MessageId]): RPCMsg {....raises: [].}
Source   Edit   
proc withPreamble(_: typedesc[RPCMsg]; preamble: sink seq[Preamble]): RPCMsg {.
    ...raises: [].}
Source   Edit   
proc withPreamble(_: typedesc[RPCMsg]; topic: string; msgId: MessageId;
                  messageLength: int): RPCMsg {....raises: [].}
Source   Edit   
proc withPrune(_: typedesc[ControlMessage]; topicID: string; backoff: uint64;
               peers: sink seq[PeerInfoMsg]): ControlMessage {....raises: [].}
Source   Edit   
proc withSubscriptions(_: typedesc[RPCMsg]; subscriptions: sink seq[SubOpts]): RPCMsg {.
    ...raises: [].}
Source   Edit  

Templates

template isSubscribe(s: SubOpts): bool {..}
Source   Edit  

Made with Nim. Generated: 2026-07-14 05:50:27 UTC