Imports

Types

PreambleExtension = ref object of Extension ongoingReceives*: PreambleStore ongoingIWantReceives*: PreambleStore: Source Edit
PreambleExtensionConfig = object maxPreamblePeerBudget*: int = 10 maxHeIsReceiving*: int = 50 broadcastRPC*: proc (msg: RPCMsg; peers: seq[PeerId]) {....gcsafe, raises: [].} hasSeen*: proc (mid: MessageId): bool {....gcsafe, raises: [].} meshAndDirectPeersForTopic*: proc (topic: string): seq[PeerId] {....gcsafe, raises: [].}: Source Edit

proc handleIHave(ext: PreambleExtension; peerId: PeerId; messageId: MessageId): bool {. ...raises: [], tags: [], forbids: [].}: Source Edit
proc handleIMReceiving(ext: PreambleExtension; peerId: PeerId; imreceivings: seq[IMReceiving]) {....raises: [], tags: [], forbids: [].}: Source Edit
proc handlePreamble(ext: PreambleExtension; peerId: PeerId; preambles: seq[Preamble]) {....raises: [], tags: [RootEffect], forbids: [].}: Source Edit
proc new(T: typedesc[PreambleExtension]; config: PreambleExtensionConfig; rng: Rng): PreambleExtension: Source Edit
proc preambleBroadcast(ext: PreambleExtension; msg: RPCMsg; peers: seq[PeerId]) {. ...raises: [], tags: [RootEffect], forbids: [].}: Source Edit
proc preambleBroadcastIfNotReceiving(ext: PreambleExtension; msg: RPCMsg; peers: seq[PeerId]) {....raises: [], tags: [RootEffect], forbids: [].}: Source Edit
proc preambleExpirationTick(ext: PreambleExtension) {....raises: [], tags: [RootEffect], forbids: [].}: Source Edit
proc preambleMsgReceived(ext: PreambleExtension; peerId: PeerId; msgId: MessageId; msgLen: int) {....raises: [], tags: [], forbids: [].}: Source Edit

method isSupported(ext: PreambleExtension; pe: PeerExtensions): bool {....gcsafe, raises: [], tags: [], forbids: [].}: Source Edit
method onHandleRPC(ext: PreambleExtension; peerId: PeerId; rpc: RPCMsg) {. ...gcsafe, raises: [], tags: [RootEffect], forbids: [].}: Source Edit
method onHeartbeat(ext: PreambleExtension) {....gcsafe, raises: [], tags: [RootEffect], forbids: [].}: Source Edit
method onNegotiated(ext: PreambleExtension; peerId: PeerId) {....gcsafe, raises: [], tags: [], forbids: [].}: Source Edit
method onRemovePeer(ext: PreambleExtension; peerId: PeerId) {....gcsafe, raises: [], tags: [], forbids: [].}: Source Edit