libp2p/protocols/pubsub/gossipsub/extensions

Search:
Group by:
Source   Edit  

Types

ExtensionsState = ref object
Source   Edit  

Procs

proc addPeer(state: ExtensionsState; peerId: PeerId) {....raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc handleRPC(state: ExtensionsState; peerId: PeerId; rpc: RPCMsg) {.
    ...raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
proc heartbeat(state: ExtensionsState) {....raises: [], tags: [], forbids: [].}
Source   Edit  
proc isControlSent(state: ExtensionsState; peerId: PeerId): bool {....raises: [],
    tags: [], forbids: [].}
Source   Edit  
proc makeControlExtensions(state: ExtensionsState): ControlExtensions {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc new(T: typedesc[ExtensionsState]; rng: Rng; updatePeerBehaviorPenalty: UpdatePeerBehaviorPenaltyProc = noopBehaviorPenaltyProc;
    testExtensionConfig: Opt[TestExtensionConfig] = Opt.none(TestExtensionConfig);
    partialMessageExtensionConfig: Opt[PartialMessageExtensionConfig] = Opt.none(
    PartialMessageExtensionConfig); pingpongExtensionConfig: Opt[
    PingPongExtensionConfig] = Opt.none(PingPongExtensionConfig);
    preambleExtensionConfig: Opt[PreambleExtensionConfig] = Opt.none(
    PreambleExtensionConfig); externalExtensions: seq[Extension] = @[]): T:type
Source   Edit  
proc noopBehaviorPenaltyProc(_: PeerId; _: float64) {....gcsafe, raises: [],
    tags: [], forbids: [].}
Source   Edit  
proc peerRequestsPartial(state: ExtensionsState; peerId: PeerId; topic: string): bool {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc preambleBroadcast(state: ExtensionsState; msg: RPCMsg; peers: seq[PeerId]) {.
    ...raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
proc preambleBroadcastIfNotReceiving(state: ExtensionsState; msg: RPCMsg;
                                     peers: seq[PeerId]) {....raises: [],
    tags: [RootEffect], forbids: [].}
Source   Edit  
proc preambleHandleIHave(state: ExtensionsState; peerId: PeerId;
                         msgId: MessageId): bool {....raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc preambleMsgReceived(state: ExtensionsState; peerId: PeerId;
                         msgId: MessageId; msgLen: int) {....raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc publishPartial(state: ExtensionsState; topic: string; pm: PartialMessage;
                    peers: seq[PeerId] = @[]): int {....raises: [],
    tags: [RootEffect, WriteIOEffect], forbids: [].}
Source   Edit  
proc removePeer(state: ExtensionsState; peerId: PeerId) {....raises: [], tags: [],
    forbids: [].}
Source   Edit