Procs
proc dropFanoutPeers(g: GossipSub) {....raises: [], tags: [].}
- Source Edit
proc getGossipPeers(g: GossipSub): Table[PubSubPeer, ControlMessage] {. ...raises: [], tags: [].}
- gossip iHave messages to peers Source Edit
proc grafted(g: GossipSub; p: PubSubPeer; topic: string) {....raises: [], tags: [RootEffect].}
- Source Edit
proc handleBackingOff(t: var BackoffTable; topic: string) {....raises: [], tags: [].}
- Source Edit
proc handleGraft(g: GossipSub; peer: PubSubPeer; grafts: seq[ControlGraft]): seq[ ControlPrune] {....raises: [], tags: [WriteIOEffect, TimeEffect, RootEffect].}
- Source Edit
proc handleIDontWant(g: GossipSub; peer: PubSubPeer; iDontWants: seq[ControlIWant]) {....raises: [], tags: [].}
- Source Edit
proc handleIHave(g: GossipSub; peer: PubSubPeer; ihaves: seq[ControlIHave]): ControlIWant {. ...raises: [], tags: [].}
- Source Edit
proc handleIWant(g: GossipSub; peer: PubSubPeer; iwants: seq[ControlIWant]): seq[ Message] {....raises: [], tags: [].}
- Source Edit
proc handlePrune(g: GossipSub; peer: PubSubPeer; prunes: seq[ControlPrune]) {. ...raises: [], tags: [RootEffect].}
- Source Edit
proc heartbeat(g: GossipSub): Future[void] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
- Source Edit
proc peerExchangeList(g: GossipSub; topic: string): seq[PeerInfoMsg] {. ...raises: [], tags: [RootEffect].}
- Source Edit
proc pruned(g: GossipSub; p: PubSubPeer; topic: string; setBackoff: bool = true; backoff = none(Duration)) {....raises: [], tags: [].}
- Source Edit
proc rebalanceMesh(g: GossipSub; topic: string; metrics: ptr MeshMetrics = nil) {. ...raises: [], tags: [RootEffect, WriteIOEffect, TimeEffect].}
- Source Edit
proc replenishFanout(g: GossipSub; topic: string) {....raises: [], tags: [].}
- get fanout peers for a topic Source Edit