Imports

Types

PartialMessageExtension = ref object of Extension: Source Edit
PartialMessageExtensionConfig = object sendRPC*: proc (peerID: PeerId; rpc: PartialMessageExtensionRPC) {....gcsafe, raises: [].} publishToPeers*: proc (topic: string): seq[PeerId] {....gcsafe, raises: [].} nodeTopicOpts*: proc (topic: string): TopicOpts {....gcsafe, raises: [].} isSupported*: proc (peer: PeerId): bool {....gcsafe, raises: [].} updatePeerBehaviorPenalty*: UpdatePeerBehaviorPenaltyProc unionPartsMetadata*: proc (a, b: PartsMetadata): Result[PartsMetadata, string] {. ...gcsafe, raises: [].} validateRPC*: proc (rpc: PartialMessageExtensionRPC): Result[void, string] {. ...gcsafe, raises: [].} onIncomingRPC*: proc (peer: PeerId; rpc: PartialMessageExtensionRPC) {....gcsafe, raises: [].} heartbeatsTillEviction*: int maxPartialGroups*: int = 1000 maxPartialGroupsPerPeer*: int = 100: Source Edit
TopicOpts = object requestsPartial*: bool supportsSendingPartial*: bool: Source Edit

proc gossipPartsMetadata(ext: PartialMessageExtension) {....raises: [], tags: [RootEffect, WriteIOEffect], forbids: [].}: Source Edit
proc new(T: typedesc[PartialMessageExtension]; config: PartialMessageExtensionConfig): PartialMessageExtension: Source Edit
proc peerRequestsPartial(ext: PartialMessageExtension; peerId: PeerId; topic: string): bool {....raises: [], tags: [], forbids: [].}: Source Edit
proc publishPartial(ext: PartialMessageExtension; topic: string; pm: PartialMessage; peers: seq[PeerId] = @[]): int {. ...raises: [], tags: [RootEffect, WriteIOEffect], forbids: [].}: Source Edit

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