Types
PreambleInfo = ref object messageId*: MessageId messageLength*: uint32 topicId*: string sender*: PeerId startsAt*: Moment expiresAt*: Moment deleted*: bool peerSet*: PeerSet
- Source Edit
PreambleStore = object byId*: Table[MessageId, PreambleInfo] heap*: HeapQueue[PreambleInfo]
- Source Edit
Procs
proc `[]`(ps: PreambleStore; msgId: MessageId): PreambleInfo {. ...raises: [KeyError], tags: [], forbids: [].}
- Source Edit
proc addPossiblePeerToQuery(ps: var PreambleStore; msgId: MessageId; peerId: PeerId) {....raises: [], tags: [], forbids: [].}
- Source Edit
proc del(ps: var PreambleStore; msgId: MessageId) {....raises: [], tags: [], forbids: [].}
- Source Edit
proc hasKey(ps: PreambleStore; msgId: MessageId): bool {....raises: [], tags: [], forbids: [].}
- Source Edit
proc init(T: typedesc[PreambleInfo]; preamble: Preamble; sender: PeerId; startsAt: Moment; expiresAt: Moment): T:type
- Source Edit
proc init(T: typedesc[PreambleStore]): T:type
- Source Edit
proc insert(ps: var PreambleStore; info: PreambleInfo) {....raises: [], tags: [], forbids: [].}
- Source Edit
proc len(ps: PreambleStore): int {....raises: [], tags: [], forbids: [].}
- Source Edit
proc popExpired(ps: var PreambleStore; now: Moment): Opt[PreambleInfo] {. ...raises: [], tags: [], forbids: [].}
- Source Edit
proc possiblePeersToQuery(preamble: PreambleInfo): seq[PeerId] {....raises: [], tags: [], forbids: [].}
- Source Edit