libp2p/protocols/pubsub/gossipsub/behavior

Search:
Group by:
Source   Edit  

Procs

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