diff --git a/test-nim16/libp2p.html b/test-nim16/libp2p.html index b6055e3bf..1c0cfbe8e 100644 --- a/test-nim16/libp2p.html +++ b/test-nim16/libp2p.html @@ -260,7 +260,7 @@ class="link-seesrc" target="_blank">Source
diff --git a/test-nim16/libp2p/builders.html b/test-nim16/libp2p/builders.html index d81e4252a..b3db46370 100644 --- a/test-nim16/libp2p/builders.html +++ b/test-nim16/libp2p/builders.html @@ -722,7 +722,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/connmanager.html b/test-nim16/libp2p/connmanager.html index e529a50a2..46c057075 100644 --- a/test-nim16/libp2p/connmanager.html +++ b/test-nim16/libp2p/connmanager.html @@ -888,7 +888,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/chacha20poly1305.html b/test-nim16/libp2p/crypto/chacha20poly1305.html index 18ab96200..bb34ec1a1 100644 --- a/test-nim16/libp2p/crypto/chacha20poly1305.html +++ b/test-nim16/libp2p/crypto/chacha20poly1305.html @@ -393,7 +393,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/crypto.html b/test-nim16/libp2p/crypto/crypto.html index bf7a66574..4533a20ba 100644 --- a/test-nim16/libp2p/crypto/crypto.html +++ b/test-nim16/libp2p/crypto/crypto.html @@ -1751,7 +1751,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/curve25519.html b/test-nim16/libp2p/crypto/curve25519.html index aea8fad89..f7bef87ec 100644 --- a/test-nim16/libp2p/crypto/curve25519.html +++ b/test-nim16/libp2p/crypto/curve25519.html @@ -399,7 +399,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/ecnist.html b/test-nim16/libp2p/crypto/ecnist.html index 17f494f4f..f6d2e3b9d 100644 --- a/test-nim16/libp2p/crypto/ecnist.html +++ b/test-nim16/libp2p/crypto/ecnist.html @@ -1410,7 +1410,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/ed25519/constants.html b/test-nim16/libp2p/crypto/ed25519/constants.html index d0734c3cb..565038bf1 100644 --- a/test-nim16/libp2p/crypto/ed25519/constants.html +++ b/test-nim16/libp2p/crypto/ed25519/constants.html @@ -3040,7 +3040,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/ed25519/ed25519.html b/test-nim16/libp2p/crypto/ed25519/ed25519.html index c2c1d7c1a..28fcc04d6 100644 --- a/test-nim16/libp2p/crypto/ed25519/ed25519.html +++ b/test-nim16/libp2p/crypto/ed25519/ed25519.html @@ -940,7 +940,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/hkdf.html b/test-nim16/libp2p/crypto/hkdf.html index c0d55fa67..a4427cb32 100644 --- a/test-nim16/libp2p/crypto/hkdf.html +++ b/test-nim16/libp2p/crypto/hkdf.html @@ -275,7 +275,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/minasn1.html b/test-nim16/libp2p/crypto/minasn1.html index 3a9449a01..3d7e9a27d 100644 --- a/test-nim16/libp2p/crypto/minasn1.html +++ b/test-nim16/libp2p/crypto/minasn1.html @@ -1209,7 +1209,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/rsa.html b/test-nim16/libp2p/crypto/rsa.html index ce992be32..7931bdd92 100644 --- a/test-nim16/libp2p/crypto/rsa.html +++ b/test-nim16/libp2p/crypto/rsa.html @@ -1024,7 +1024,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/crypto/secp.html b/test-nim16/libp2p/crypto/secp.html index 9b4c97268..6ff950573 100644 --- a/test-nim16/libp2p/crypto/secp.html +++ b/test-nim16/libp2p/crypto/secp.html @@ -936,7 +936,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/dial.html b/test-nim16/libp2p/dial.html index f4bd8d47b..015f8410f 100644 --- a/test-nim16/libp2p/dial.html +++ b/test-nim16/libp2p/dial.html @@ -341,7 +341,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/dialer.html b/test-nim16/libp2p/dialer.html index 2759f4a33..e42ca68db 100644 --- a/test-nim16/libp2p/dialer.html +++ b/test-nim16/libp2p/dialer.html @@ -410,7 +410,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/errors.html b/test-nim16/libp2p/errors.html index 2afe7d89e..5d5b205fb 100644 --- a/test-nim16/libp2p/errors.html +++ b/test-nim16/libp2p/errors.html @@ -357,7 +357,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/multiaddress.html b/test-nim16/libp2p/multiaddress.html index f113ac2b2..b88311662 100644 --- a/test-nim16/libp2p/multiaddress.html +++ b/test-nim16/libp2p/multiaddress.html @@ -2115,7 +2115,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/multibase.html b/test-nim16/libp2p/multibase.html index 0471e1bdf..3073359d7 100644 --- a/test-nim16/libp2p/multibase.html +++ b/test-nim16/libp2p/multibase.html @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/multicodec.html b/test-nim16/libp2p/multicodec.html index cec5bf1fd..29230052e 100644 --- a/test-nim16/libp2p/multicodec.html +++ b/test-nim16/libp2p/multicodec.html @@ -484,7 +484,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/multihash.html b/test-nim16/libp2p/multihash.html index 082d9be15..1ad164f9e 100644 --- a/test-nim16/libp2p/multihash.html +++ b/test-nim16/libp2p/multihash.html @@ -693,7 +693,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/multistream.html b/test-nim16/libp2p/multistream.html index e5b0489a8..00dc76c32 100644 --- a/test-nim16/libp2p/multistream.html +++ b/test-nim16/libp2p/multistream.html @@ -598,7 +598,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/muxers/mplex/coder.html b/test-nim16/libp2p/muxers/mplex/coder.html index 24b872bcf..b31b8d2e7 100644 --- a/test-nim16/libp2p/muxers/mplex/coder.html +++ b/test-nim16/libp2p/muxers/mplex/coder.html @@ -392,7 +392,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/muxers/mplex/mplex.html b/test-nim16/libp2p/muxers/mplex/mplex.html index 70417483d..8a64687c4 100644 --- a/test-nim16/libp2p/muxers/mplex/mplex.html +++ b/test-nim16/libp2p/muxers/mplex/mplex.html @@ -400,7 +400,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/muxers/muxer.html b/test-nim16/libp2p/muxers/muxer.html index 6fd5188a0..479cdfbcb 100644 --- a/test-nim16/libp2p/muxers/muxer.html +++ b/test-nim16/libp2p/muxers/muxer.html @@ -504,7 +504,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/muxers/yamux/yamux.html b/test-nim16/libp2p/muxers/yamux/yamux.html index c9906686c..4addddd44 100644 --- a/test-nim16/libp2p/muxers/yamux/yamux.html +++ b/test-nim16/libp2p/muxers/yamux/yamux.html @@ -545,7 +545,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/nameresolving/nameresolver.html b/test-nim16/libp2p/nameresolving/nameresolver.html index b6ef890c1..95fc26a12 100644 --- a/test-nim16/libp2p/nameresolving/nameresolver.html +++ b/test-nim16/libp2p/nameresolving/nameresolver.html @@ -355,7 +355,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/peerid.html b/test-nim16/libp2p/peerid.html index 451c7f556..cfc13ced0 100644 --- a/test-nim16/libp2p/peerid.html +++ b/test-nim16/libp2p/peerid.html @@ -789,7 +789,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/peerinfo.html b/test-nim16/libp2p/peerinfo.html index 0464d6443..0d8f05f99 100644 --- a/test-nim16/libp2p/peerinfo.html +++ b/test-nim16/libp2p/peerinfo.html @@ -393,7 +393,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/protobuf/minprotobuf.html b/test-nim16/libp2p/protobuf/minprotobuf.html index 88a509081..cbb899219 100644 --- a/test-nim16/libp2p/protobuf/minprotobuf.html +++ b/test-nim16/libp2p/protobuf/minprotobuf.html @@ -939,7 +939,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/protocols/identify.html b/test-nim16/libp2p/protocols/identify.html index 962b015b0..41ad435a6 100644 --- a/test-nim16/libp2p/protocols/identify.html +++ b/test-nim16/libp2p/protocols/identify.html @@ -620,7 +620,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/protocols/ping.html b/test-nim16/libp2p/protocols/ping.html index 3bb7a7fac..b375a7d43 100644 --- a/test-nim16/libp2p/protocols/ping.html +++ b/test-nim16/libp2p/protocols/ping.html @@ -416,7 +416,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/protocols/protocol.html b/test-nim16/libp2p/protocols/protocol.html index 585fa7a03..265612c51 100644 --- a/test-nim16/libp2p/protocols/protocol.html +++ b/test-nim16/libp2p/protocols/protocol.html @@ -385,7 +385,7 @@ class="link-seesrc" target="_blank">Source diff --git a/test-nim16/libp2p/protocols/pubsub.html b/test-nim16/libp2p/protocols/pubsub.html index c7741930f..f97f03b15 100644 --- a/test-nim16/libp2p/protocols/pubsub.html +++ b/test-nim16/libp2p/protocols/pubsub.html @@ -229,7 +229,7 @@ class="link-seesrc" target="_blank">SourceFloodSub {.public.} = ref object of PubSub floodsub*: PeerTable - seen*: TimedCache[MessageID] + seen*: TimedCache[MessageId] seenSalt*: seq[byte]
proc addSeen(f: FloodSub; msgId: MessageID): bool {....raises: [Defect], tags: [].}
proc addSeen(f: FloodSub; msgId: MessageId): bool {....raises: [Defect], tags: [].}
proc firstSeen(f: FloodSub; msgId: MessageID): Moment {....raises: [Defect], ++- diff --git a/test-nim16/libp2p/protocols/pubsub/gossipsub.html b/test-nim16/libp2p/protocols/pubsub/gossipsub.html index a3b554381..68454abfa 100644 --- a/test-nim16/libp2p/protocols/pubsub/gossipsub.html +++ b/test-nim16/libp2p/protocols/pubsub/gossipsub.html @@ -244,8 +244,8 @@ window.addEventListener("DOMContentLoaded", main2); proc firstSeen(f: FloodSub; msgId: MessageId): Moment {....raises: [Defect], tags: [].}- @@ -376,8 +376,8 @@ class="link-seesrc" target="_blank">Source
onPubSubPeerEvent -
- onPubSubPeerEvent(p: GossipSub; peer: PubSubPeer; event: PubsubPeerEvent)
+- onPubSubPeerEvent(p: GossipSub; peer: PubSubPeer; event: PubSubPeerEvent)
onTopicSubscription @@ -403,8 +403,8 @@ class="link-seesrc" target="_blank">Source
method onPubSubPeerEvent(p: GossipSub; peer: PubSubPeer; event: PubsubPeerEvent) {. ++@@ -511,7 +511,7 @@ class="link-seesrc" target="_blank">Source method onPubSubPeerEvent(p: GossipSub; peer: PubSubPeer; event: PubSubPeerEvent) {. ...gcsafe, raises: [Defect], tags: [RootEffect, WriteIOEffect, TimeEffect].}- @@ -501,7 +501,7 @@ class="link-seesrc" target="_blank">Source
Exports
-GossipBackoffPeriod, BackoffSlackTime, GossipSubCodec_10, GossipSubHistoryGossip, GossipSubDlo, IHaveMaxLength, TopicInfo, ValidationSeenTable, IHavePeerBudget, IWantPeerBudget, RoutingRecordsHandler, GossipSubCodec, GossipSubD, GossipSubDhi, RoutingRecordsPair, GossipSubHeartbeatInterval, PeerStats, GossipSubHistoryLength, GossipSubFanoutTTL, BackoffTable, TopicParams, GossipSub, MeshMetrics, GossipSubParams, updateScores, init, addCapped, withPeerStats, byScore, punishInvalidMessage, rewardDelivered, scoringHeartbeat, getGossipPeers, replenishFanout, rebalanceMesh, dropFanoutPeers, handleIWant, pruned, handleBackingOff, peerExchangeList, handleGraft, grafted, handleIHave, handlePrune, heartbeat, sendSubs, MsgIdProvider, onTopicSubscription, init, unsubscribe, PubSubObserver, TopicHandler, codec=, removeObserver, send, libp2p_pubsub_received_subscriptions, initPubSub, subscribe, libp2p_pubsub_broadcast_prune, PubSubPeer, libp2p_pubsub_broadcast_ihave, libp2p_pubsub_received_iwant, codec, unsubscribe, getOrCreatePeer, libp2p_pubsub_messages_rebroadcasted, SubscriptionValidator, removeValidator, PubSub, libp2p_pubsub_received_unsubscriptions, start, broadcast, rpcHandler, libp2p_pubsub_received_prune, KnownLibP2PTopicsSeq, libp2p_pubsub_messages_published, LPProtoHandler, ValidationResult, ValidatorHandler, handleConn, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_received_graft, libp2p_pubsub_broadcast_iwant, init, updateMetrics, libp2p_pubsub_broadcast_subscriptions, InitializationError, libp2p_pubsub_received_messages, unsubscribePeer, addObserver, addValidator, libp2p_pubsub_received_ihave, handleData, validate, unsubscribeAll, libp2p_pubsub_broadcast_messages, KnownLibP2PTopics, TopicPair, onPubSubPeerEvent, libp2p_pubsub_broadcast_graft, publish, LPProtocol, stop, subscribePeer +GossipBackoffPeriod, BackoffSlackTime, GossipSubCodec_10, GossipSubHistoryGossip, GossipSubDlo, IHaveMaxLength, TopicInfo, ValidationSeenTable, IHavePeerBudget, IWantPeerBudget, RoutingRecordsHandler, GossipSubCodec, GossipSubD, GossipSubDhi, RoutingRecordsPair, GossipSubHeartbeatInterval, PeerStats, GossipSubHistoryLength, GossipSubFanoutTTL, BackoffTable, TopicParams, GossipSub, MeshMetrics, GossipSubParams, updateScores, init, addCapped, withPeerStats, byScore, punishInvalidMessage, rewardDelivered, scoringHeartbeat, getGossipPeers, replenishFanout, rebalanceMesh, dropFanoutPeers, handleIWant, pruned, handleBackingOff, peerExchangeList, handleGraft, grafted, handleIHave, handlePrune, heartbeat, sendSubs, MsgIdProvider, onTopicSubscription, init, unsubscribe, PubSubObserver, TopicHandler, codec=, removeObserver, send, libp2p_pubsub_received_subscriptions, initPubSub, subscribe, libp2p_pubsub_broadcast_prune, PubSubPeer, libp2p_pubsub_broadcast_ihave, libp2p_pubsub_received_iwant, codec, unsubscribe, getOrCreatePeer, libp2p_pubsub_messages_rebroadcasted, SubscriptionValidator, removeValidator, PubSub, libp2p_pubsub_received_unsubscriptions, start, broadcast, rpcHandler, libp2p_pubsub_received_prune, KnownLibP2PTopicsSeq, libp2p_pubsub_messages_published, LPProtoHandler, ValidationResult, ValidatorHandler, handleConn, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_received_graft, libp2p_pubsub_broadcast_iwant, init, updateMetrics, libp2p_pubsub_broadcast_subscriptions, InitializationError, libp2p_pubsub_received_messages, unsubscribePeer, addObserver, addValidator, libp2p_pubsub_received_ihave, handleData, validate, unsubscribeAll, libp2p_pubsub_broadcast_messages, KnownLibP2PTopics, TopicPair, onPubSubPeerEvent, libp2p_pubsub_broadcast_graft, publish, LPProtocol, stop, subscribePeer
ValidationSeenTable = Table[MessageID, HashSet[PubSubPeer]]
ValidationSeenTable = Table[MessageId, HashSet[PubSubPeer]]
CacheEntry = object - mid*: MessageID - topicIDs*: seq[string] + mid*: MessageId + topicIds*: seq[string]
MCache = object of RootObj - msgs*: Table[MessageID, Message] + msgs*: Table[MessageId, Message] history*: seq[seq[CacheEntry]] windowSize*: Natural
func contains(c: MCache; mid: MessageID): bool {....raises: [Defect], tags: [].}
func contains(c: MCache; mid: MessageId): bool {....raises: [Defect], tags: [].}
func get(c: MCache; mid: MessageID): Option[Message] {....raises: [Defect], ++- func get(c: MCache; mid: MessageId): Option[Message] {....raises: [Defect], tags: [].}- @@ -353,8 +353,8 @@ class="link-seesrc" target="_blank">Source
- func put(c: var MCache; msgId: MessageID; msg: Message) {....raises: [Defect], ++ func put(c: var MCache; msgId: MessageId; msg: Message) {....raises: [Defect], tags: [].}- @@ -379,7 +379,7 @@ class="link-seesrc" target="_blank">Source
-@@ -406,7 +406,7 @@ class="link-seesrc" target="_blank">Source func window(c: MCache; topic: string): HashSet[MessageID] {....raises: [Defect], + func window(c: MCache; topic: string): HashSet[MessageId] {....raises: [Defect], tags: [].}- @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source
Exports
-withSubs, PeerInfoMsg, ControlIHave, ControlMessage, ControlGraft, shortLog, SubOpts, shortLog, shortLog, RPCMsg, MessageID, ControlPrune, ControlIWant, shortLog, shortLog, shortLog, Message, shortLog +withSubs, PeerInfoMsg, ControlIHave, ControlMessage, ControlGraft, shortLog, SubOpts, shortLog, shortLog, RPCMsg, MessageId, ControlPrune, ControlIWant, shortLog, shortLog, shortLog, Message, shortLog
MsgIdProvider {.public.} = proc (m: Message): Result[MessageID, ValidationResult] {. +
MsgIdProvider {.public.} = proc (m: Message): Result[MessageId, ValidationResult] {. noSideEffect, ...raises: [Defect], gcsafe.}
method onPubSubPeerEvent(p: PubSub; peer: PubSubPeer; event: PubsubPeerEvent) {. ++ method onPubSubPeerEvent(p: PubSub; peer: PubSubPeer; event: PubSubPeerEvent) {. base, ...gcsafe, raises: [Defect], tags: [RootEffect, WriteIOEffect, TimeEffect].}- @@ -1160,7 +1160,7 @@ class="link-seesrc" target="_blank">Source
OnEvent = proc (peer: PubSubPeer; event: PubsubPeerEvent) {....gcsafe, + OnEvent = proc (peer: PubSubPeer; event: PubSubPeerEvent) {....gcsafe, raises: [Defect].}- @@ -431,8 +431,8 @@ class="link-seesrc" target="_blank">Source
PubsubPeerEvent = object ++ PubSubPeerEvent = object kind*: PubSubPeerEventKind- @@ -645,7 +645,7 @@ class="link-seesrc" target="_blank">Source
func defaultMsgIdProvider(m: Message): Result[MessageID, ValidationResult] {. +
func defaultMsgIdProvider(m: Message): Result[MessageId, ValidationResult] {. ...raises: [Defect], tags: [].}
ControlGraft = 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