libp2p/protocols/pubsub/gossipsub/preamblestore

Search:
Group by:
Source   Edit  

Procs

proc `[]`(ps: var PreambleStore; msgId: MessageId): PreambleInfo {.
    ...raises: [KeyError], tags: [], forbids: [].}
Source   Edit  
proc `[]=`(ps: var PreambleStore; msgId: MessageId; entry: PreambleInfo) {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc addPossiblePeerToQuery(ps: var PreambleStore; msgId: MessageId;
                            peer: PubSubPeer) {....raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc del(ps: var PreambleStore; msgId: MessageId) {....raises: [], tags: [],
    forbids: [].}
Source   Edit  
proc hasKey(ps: var PreambleStore; msgId: MessageId): bool {....raises: [],
    tags: [], forbids: [].}
Source   Edit  
proc init(T: typedesc[PeerSet]): T:type
Source   Edit  
proc init(T: typedesc[PreambleInfo]; preamble: ControlPreamble;
          sender: PubSubPeer; startsAt: Moment; expiresAt: Moment): T:type
Source   Edit  
proc init(T: typedesc[PreambleStore]): T:type
Source   Edit  
proc insert(ps: var PreambleStore; msgId: MessageId; info: PreambleInfo) {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc len(ps: var PreambleStore): int {....raises: [], tags: [], forbids: [].}
Source   Edit  
proc popExpired(ps: var PreambleStore; now: Moment): Option[PreambleInfo] {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc possiblePeersToQuery(preamble: PreambleInfo): seq[PeerId] {....raises: [],
    tags: [], forbids: [].}
Source   Edit  

Templates

template withValue(ps: var PreambleStore; key: MessageId; value, body: untyped)
Source   Edit