SecureProtocol {.pure.} = enum - Noise, Secio {....deprecated.}
Set the listening address of the switch
Calling it multiple time will override the value
Set the listening addresses of the switch
Calling it multiple time will override the value
proc createExchange(epubkey, signature: openArray[byte]): seq[byte] {. - ...raises: [], tags: [].}
proc createProposal(nonce, pubkey: openArray[byte]; - exchanges, ciphers, hashes: string): seq[byte] {....raises: [], - tags: [].}
proc decodeExchange(message: seq[byte]; pubkey, signature: var seq[byte]): bool {. - ...raises: [], tags: [].}
Parse incoming exchange message and decode remote ephemeral public key pubkey and signature signature.
-Procedure returns true on success and false on error.
- - Source - Edit - -proc decodeProposal(message: seq[byte]; nonce, pubkey: var seq[byte]; - exchanges, ciphers, hashes: var string): bool {....raises: [], - tags: [].}
Parse incoming proposal message and decode remote random nonce nonce, remote public key pubkey, comma-delimieted list of supported exchange schemes exchanges, comma-delimeted list of supported ciphers ciphers and comma-delimeted list of supported hashes hashes.
-Procedure returns true on success and false on error.
- - Source - Edit -On success deserialized signature will be stored in value.
Source - Edit + EditOn success deserialized key will be stored in value.
Source - Edit + Edit @@ -1553,9 +1471,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -1566,9 +1484,9 @@ class="link-seesrc" target="_blank">Source Write PublicKey value pubkey to buffer vb. Source - Edit + Edit @@ -1579,9 +1497,9 @@ class="link-seesrc" target="_blank">Source Write PrivateKey value seckey to buffer vb. Source - Edit + Edit @@ -1592,9 +1510,9 @@ class="link-seesrc" target="_blank">Source Write Signature value sig to buffer vb. Source - Edit + Edit @@ -1605,9 +1523,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -1703,7 +1621,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/curve25519.html b/ex-handlersupport/libp2p/crypto/curve25519.html index 89cc8c319..9d8c3577e 100644 --- a/ex-handlersupport/libp2p/crypto/curve25519.html +++ b/ex-handlersupport/libp2p/crypto/curve25519.html @@ -398,7 +398,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/ecnist.html b/ex-handlersupport/libp2p/crypto/ecnist.html index 439235155..e8ebd773f 100644 --- a/ex-handlersupport/libp2p/crypto/ecnist.html +++ b/ex-handlersupport/libp2p/crypto/ecnist.html @@ -1450,7 +1450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/ed25519/constants.html b/ex-handlersupport/libp2p/crypto/ed25519/constants.html index 45e13efa4..a85c1c75f 100644 --- a/ex-handlersupport/libp2p/crypto/ed25519/constants.html +++ b/ex-handlersupport/libp2p/crypto/ed25519/constants.html @@ -3040,7 +3040,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/ed25519/ed25519.html b/ex-handlersupport/libp2p/crypto/ed25519/ed25519.html index 682781e79..ec5de1791 100644 --- a/ex-handlersupport/libp2p/crypto/ed25519/ed25519.html +++ b/ex-handlersupport/libp2p/crypto/ed25519/ed25519.html @@ -940,7 +940,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/hkdf.html b/ex-handlersupport/libp2p/crypto/hkdf.html index 1d9f31692..d37a42cbe 100644 --- a/ex-handlersupport/libp2p/crypto/hkdf.html +++ b/ex-handlersupport/libp2p/crypto/hkdf.html @@ -275,7 +275,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/minasn1.html b/ex-handlersupport/libp2p/crypto/minasn1.html index 1250040b7..0ea2fd31d 100644 --- a/ex-handlersupport/libp2p/crypto/minasn1.html +++ b/ex-handlersupport/libp2p/crypto/minasn1.html @@ -1195,7 +1195,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/rsa.html b/ex-handlersupport/libp2p/crypto/rsa.html index 9c8c60529..8f325b803 100644 --- a/ex-handlersupport/libp2p/crypto/rsa.html +++ b/ex-handlersupport/libp2p/crypto/rsa.html @@ -1029,7 +1029,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/crypto/secp.html b/ex-handlersupport/libp2p/crypto/secp.html index b1aba8dd2..f055baaca 100644 --- a/ex-handlersupport/libp2p/crypto/secp.html +++ b/ex-handlersupport/libp2p/crypto/secp.html @@ -908,7 +908,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/dial.html b/ex-handlersupport/libp2p/dial.html index 2217e6e7f..39f394136 100644 --- a/ex-handlersupport/libp2p/dial.html +++ b/ex-handlersupport/libp2p/dial.html @@ -381,7 +381,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/dialer.html b/ex-handlersupport/libp2p/dialer.html index f4bf82537..c3871568a 100644 --- a/ex-handlersupport/libp2p/dialer.html +++ b/ex-handlersupport/libp2p/dialer.html @@ -450,7 +450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/errors.html b/ex-handlersupport/libp2p/errors.html index 1465b9322..6f6b3b13c 100644 --- a/ex-handlersupport/libp2p/errors.html +++ b/ex-handlersupport/libp2p/errors.html @@ -340,7 +340,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/multiaddress.html b/ex-handlersupport/libp2p/multiaddress.html index 330ac7c53..6b2144e54 100644 --- a/ex-handlersupport/libp2p/multiaddress.html +++ b/ex-handlersupport/libp2p/multiaddress.html @@ -2551,7 +2551,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/multibase.html b/ex-handlersupport/libp2p/multibase.html index 439187b75..13b4aa6e3 100644 --- a/ex-handlersupport/libp2p/multibase.html +++ b/ex-handlersupport/libp2p/multibase.html @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/multicodec.html b/ex-handlersupport/libp2p/multicodec.html index 4a75f1c3c..9b27f8792 100644 --- a/ex-handlersupport/libp2p/multicodec.html +++ b/ex-handlersupport/libp2p/multicodec.html @@ -481,7 +481,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/multihash.html b/ex-handlersupport/libp2p/multihash.html index a4125bb69..0fb05302f 100644 --- a/ex-handlersupport/libp2p/multihash.html +++ b/ex-handlersupport/libp2p/multihash.html @@ -689,7 +689,7 @@ class="link-seesrc" target="_blank">Source diff --git a/ex-handlersupport/libp2p/multistream.html b/ex-handlersupport/libp2p/multistream.html index e012cd0da..2e21343b5 100644 --- a/ex-handlersupport/libp2p/multistream.html +++ b/ex-handlersupport/libp2p/multistream.html @@ -226,11 +226,7 @@ window.addEventListener("DOMContentLoaded", main2); Procsproc addHandler(m: MultistreamSelect; codec: string; - handler: LPProtoHandler | LPProtocolHandler; - matcher: Matcher = nil) {....raises: [].}
proc addHandler(m: MultistreamSelect; codec: string; protocol: LPProtocol; matcher: Matcher = nil) {....raises: [], tags: [RootEffect].}
proc addHandler[E](m: MultistreamSelect; codec: string; handler: LPProtoHandler | + proc (conn: Connection; proto: string): InternalRaisesFuture[void, E]; + matcher: Matcher = nil) {....raises: [].}
proc handle(_: type MultistreamSelect; conn: Connection; protos: seq[string]; - matchers = newSeq[Matcher](); active: bool = false): Future[string] {. + matchers = newSeq[Matcher](); active: bool = false): InternalRaisesFuture[ + string, (CancelledError, LPStreamError, MultiStreamError)] {. stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [].}
proc handle(m: MultistreamSelect; conn: Connection; active: bool = false): Future[ - void] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
proc handle(m: MultistreamSelect; conn: Connection; active: bool = false): InternalRaisesFuture[ + void, (CancelledError,)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], tags: [RootEffect].}
proc list(m: MultistreamSelect; conn: Connection): Future[seq[string]] {. +
proc list(m: MultistreamSelect; conn: Connection): InternalRaisesFuture[ + seq[string], (CancelledError, LPStreamError, MultiStreamError)] {. stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc select(_: MultistreamSelect | type MultistreamSelect; conn: Connection; - proto: seq[string]): Future[string] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [].}
proc select(_: MultistreamSelect | type MultistreamSelect; conn: Connection; - proto: string): Future[bool] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [].}
proc select(m: MultistreamSelect; conn: Connection): Future[bool] {....raises: [], +- +
proc select(m: MultistreamSelect; conn: Connection): InternalRaisesFuture[bool, + (CancelledError, LPStreamError, MultiStreamError)] {.stackTrace: false, + ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}- + + + Source + Edit + +
+
proc start(m: MultistreamSelect): InternalRaisesFuture[void, (CancelledError,)] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc start(m: MultistreamSelect): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc stop(m: MultistreamSelect): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc stop(m: MultistreamSelect): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method start(r: Relay): Future[void] {.stackTrace: false, ...raises: [], gcsafe, - raises: [], raises: [], - tags: [RootEffect].}
method start(r: Relay): InternalRaisesFuture[void, (CancelledError,)] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [WriteIOEffect, TimeEffect, RootEffect].}
method stop(r: Relay): Future[void] {.stackTrace: false, ...raises: [], gcsafe, - raises: [], raises: [], tags: [RootEffect].}
method stop(r: Relay): InternalRaisesFuture[void, void] {.stackTrace: false, + ...raises: [], gcsafe, raises: [], raises: [], + tags: [WriteIOEffect, TimeEffect, RootEffect].}
LPProtocolHandler[E] = proc (conn: Connection; proto: string): InternalRaisesFuture[ - void, E]
func handler=(p: LPProtocol; handler: LPProtocolHandler) {....raises: [].}
func handler=[E](p: LPProtocol; handler: proc (conn: Connection; proto: string): InternalRaisesFuture[ + void, E]) {....raises: [].}
proc new(T: type LPProtocol; codecs: seq[string]; handler: LPProtocolHandler; - maxIncomingStreams: Opt[int] | int = Opt.none(int)): T:type {. - ...raises: [].}
proc new[E](T: type LPProtocol; codecs: seq[string]; handler: proc ( + conn: Connection; proto: string): InternalRaisesFuture[void, E]; + maxIncomingStreams: Opt[int] | int = Opt.none(int)): T:type {. + ...raises: [].}
method start(p: LPProtocol): Future[void] {.base, stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
method start(p: LPProtocol): InternalRaisesFuture[void, (CancelledError,)] {. + base, stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [].}
method stop(p: LPProtocol): Future[void] {.base, stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
method stop(p: LPProtocol): InternalRaisesFuture[void, void] {.base, + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [].}
proc rateLimit(g: GossipSub; peer: PubSubPeer; rpcMsgOpt: Opt[RPCMsg]; - msgSize: int): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc rateLimit(g: GossipSub; peer: PubSubPeer; overhead: int): Future[void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method start(g: GossipSub): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
method start(g: GossipSub): InternalRaisesFuture[void, (CancelledError,)] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [WriteIOEffect, TimeEffect, RootEffect].}
method stop(g: GossipSub): Future[void] {.stackTrace: false, ...raises: [], gcsafe, - raises: [], raises: [], tags: [RootEffect].}
method stop(g: GossipSub): InternalRaisesFuture[void, void] {.stackTrace: false, + ...raises: [], gcsafe, raises: [], raises: [], + tags: [WriteIOEffect, TimeEffect, RootEffect].}
proc rewardDelivered(g: GossipSub; peer: PubSubPeer; topics: openArray[string]; - first: bool; delay = ZeroDuration) {....raises: [], - tags: [RootEffect].}
proc rewardDelivered(g: GossipSub; peer: PubSubPeer; topic: string; first: bool; + delay = ZeroDuration) {....raises: [], tags: [RootEffect].}
CacheEntry = object mid*: MessageId - topicIds*: seq[string] + topic*: string
The return value is the number of neighbours that we attempted to send the message to, excluding self. Note that this is an optimistic number of attempts - the number of peers that actually receive the message might be lower.
Source - Edit + Edit @@ -1101,9 +1101,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -1115,9 +1115,9 @@ class="link-seesrc" target="_blank">Source Handler that must be overridden by concrete implementation Source - Edit + Edit @@ -1128,9 +1128,9 @@ class="link-seesrc" target="_blank">Source subscribe to remote peer to receive/send pubsub messages Source - Edit + Edit @@ -1155,9 +1155,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -1166,7 +1166,7 @@ class="link-seesrc" target="_blank">SourceHigh priority messages are sent immediately, while low priority messages are queued and sent only after all high priority messages have been sent.
Source - Edit + Edit @@ -723,9 +723,9 @@ class="link-seesrc" target="_blank">SourceHigh priority messages are sent immediately, while low priority messages are queued and sent only after all high priority messages have been sent.
Source - Edit + Edit @@ -748,9 +748,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -776,7 +776,7 @@ class="link-seesrc" target="_blank">SourceControlGraft = object - topicId*: string + topicID*: string
ControlIHave = object - topicId*: string - messageIds*: seq[MessageId] + topicID*: string + messageIDs*: seq[MessageId]
ControlIWant = object - messageIds*: seq[MessageId] + messageIDs*: seq[MessageId]
ControlPrune = object - topicId*: string + topicID*: string peers*: seq[PeerInfoMsg] backoff*: uint64
method start(rdv: RendezVous): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
method start(rdv: RendezVous): InternalRaisesFuture[void, (CancelledError,)] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [WriteIOEffect, TimeEffect, RootEffect].}
method stop(rdv: RendezVous): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
method stop(rdv: RendezVous): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [WriteIOEffect, TimeEffect, RootEffect].}
method upgrade(self: Transport; conn: Connection; peerId: Opt[PeerId]): Future[ - Muxer] {.base, ...gcsafe, raises: [], tags: [].}
method upgrade(self: Transport; conn: Connection; peerId: Opt[PeerId]): InternalRaisesFuture[ + Muxer, (CancelledError, LPError)] {.base, stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [].}
proc mux(self: MuxedUpgrade; conn: Connection): Future[Muxer] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
proc new(T: type MuxedUpgrade; muxers: seq[MuxerProvider]; secureManagers: openArray[Secure] = []; ms: MultistreamSelect): T:type {. @@ -310,9 +293,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit
method upgrade(self: MuxedUpgrade; conn: Connection; peerId: Opt[PeerId]): Future[ - Muxer] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method upgrade(self: MuxedUpgrade; conn: Connection; peerId: Opt[PeerId]): InternalRaisesFuture[ + Muxer, (CancelledError, LPError)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], + tags: [RootEffect].}
proc secure(self: Upgrade; conn: Connection; peerId: Opt[PeerId]): Future[ - Connection] {.stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], - gcsafe, raises: [], tags: [RootEffect].}
proc secure(self: Upgrade; conn: Connection; peerId: Opt[PeerId]): InternalRaisesFuture[ + Connection, (CancelledError, LPError)] {.stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, raises: [], tags: [RootEffect].}
method upgrade(self: Upgrade; conn: Connection; peerId: Opt[PeerId]): Future[ - Muxer] {.base, ...gcsafe, raises: [], tags: [].}
method upgrade(self: Upgrade; conn: Connection; peerId: Opt[PeerId]): InternalRaisesFuture[ + Muxer, (CancelledError, LPError)] {.base, stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}