From 96fbb00cd87fb9632226973f74635d9c44590e0b Mon Sep 17 00:00:00 2001 From: = Date: Thu, 7 Mar 2024 14:41:43 +0000 Subject: [PATCH] update docs for 1052-single-topic-message --- 1052-single-topic-message/libp2p.html | 2 +- .../libp2p/builders.html | 2 +- .../libp2p/connmanager.html | 2 +- .../libp2p/crypto/chacha20poly1305.html | 2 +- .../libp2p/crypto/crypto.html | 2 +- .../libp2p/crypto/curve25519.html | 2 +- .../libp2p/crypto/ecnist.html | 2 +- .../libp2p/crypto/ed25519/constants.html | 2 +- .../libp2p/crypto/ed25519/ed25519.html | 2 +- .../libp2p/crypto/hkdf.html | 2 +- .../libp2p/crypto/minasn1.html | 2 +- .../libp2p/crypto/rsa.html | 2 +- .../libp2p/crypto/secp.html | 2 +- 1052-single-topic-message/libp2p/dial.html | 2 +- 1052-single-topic-message/libp2p/dialer.html | 2 +- 1052-single-topic-message/libp2p/errors.html | 2 +- .../libp2p/multiaddress.html | 2 +- .../libp2p/multibase.html | 2 +- .../libp2p/multicodec.html | 2 +- .../libp2p/multihash.html | 2 +- .../libp2p/multistream.html | 2 +- .../libp2p/muxers/mplex/coder.html | 2 +- .../libp2p/muxers/mplex/mplex.html | 2 +- .../libp2p/muxers/muxer.html | 2 +- .../libp2p/muxers/yamux/yamux.html | 2 +- .../libp2p/nameresolving/nameresolver.html | 2 +- .../libp2p/observedaddrmanager.html | 2 +- 1052-single-topic-message/libp2p/peerid.html | 2 +- .../libp2p/peerinfo.html | 2 +- .../libp2p/protobuf/minprotobuf.html | 2 +- .../protocols/connectivity/autonat/core.html | 2 +- .../connectivity/autonat/server.html | 2 +- .../protocols/connectivity/relay/client.html | 2 +- .../connectivity/relay/messages.html | 2 +- .../protocols/connectivity/relay/rconn.html | 2 +- .../protocols/connectivity/relay/relay.html | 2 +- .../connectivity/relay/rtransport.html | 2 +- .../protocols/connectivity/relay/utils.html | 2 +- .../libp2p/protocols/identify.html | 2 +- .../libp2p/protocols/ping.html | 2 +- .../libp2p/protocols/protocol.html | 2 +- .../libp2p/protocols/pubsub.html | 4 +- .../libp2p/protocols/pubsub/errors.html | 2 +- .../libp2p/protocols/pubsub/floodsub.html | 21 +- .../libp2p/protocols/pubsub/gossipsub.html | 44 ++- .../protocols/pubsub/gossipsub/behavior.html | 50 ++- .../protocols/pubsub/gossipsub/scoring.html | 4 +- .../protocols/pubsub/gossipsub/types.html | 6 +- .../libp2p/protocols/pubsub/mcache.html | 10 +- .../libp2p/protocols/pubsub/peertable.html | 2 +- .../libp2p/protocols/pubsub/pubsub.html | 42 ++- .../libp2p/protocols/pubsub/pubsubpeer.html | 34 +- .../libp2p/protocols/pubsub/rpc/message.html | 51 ++- .../libp2p/protocols/pubsub/rpc/messages.html | 294 +++++++++++++++++- .../libp2p/protocols/pubsub/rpc/protobuf.html | 148 ++++++++- .../libp2p/protocols/pubsub/timedcache.html | 2 +- .../libp2p/protocols/rendezvous.html | 2 +- .../libp2p/protocols/secure/noise.html | 2 +- .../libp2p/protocols/secure/secure.html | 2 +- .../libp2p/routing_record.html | 2 +- .../libp2p/signed_envelope.html | 2 +- .../libp2p/stream/bufferstream.html | 2 +- .../libp2p/stream/chronosstream.html | 2 +- .../libp2p/stream/connection.html | 2 +- .../libp2p/stream/lpstream.html | 2 +- .../libp2p/stream/streamseq.html | 2 +- 1052-single-topic-message/libp2p/switch.html | 2 +- .../libp2p/transcoder.html | 2 +- .../libp2p/transports/tcptransport.html | 2 +- .../libp2p/transports/transport.html | 2 +- .../libp2p/transports/wstransport.html | 2 +- .../libp2p/upgrademngrs/muxedupgrade.html | 2 +- .../libp2p/upgrademngrs/upgrade.html | 2 +- 1052-single-topic-message/libp2p/utility.html | 2 +- .../libp2p/utils/future.html | 2 +- .../libp2p/utils/heartbeat.html | 2 +- .../libp2p/utils/offsettedseq.html | 2 +- .../libp2p/utils/semaphore.html | 2 +- 1052-single-topic-message/libp2p/varint.html | 2 +- 1052-single-topic-message/libp2p/vbuffer.html | 2 +- 1052-single-topic-message/libp2p/wire.html | 2 +- 1052-single-topic-message/theindex.html | 112 ++++++- 82 files changed, 822 insertions(+), 136 deletions(-) diff --git a/1052-single-topic-message/libp2p.html b/1052-single-topic-message/libp2p.html index c9c6e816a..9df6daafe 100644 --- a/1052-single-topic-message/libp2p.html +++ b/1052-single-topic-message/libp2p.html @@ -260,7 +260,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/builders.html b/1052-single-topic-message/libp2p/builders.html index e984c16d9..ae7aff1e0 100644 --- a/1052-single-topic-message/libp2p/builders.html +++ b/1052-single-topic-message/libp2p/builders.html @@ -801,7 +801,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/connmanager.html b/1052-single-topic-message/libp2p/connmanager.html index 42a0334b1..510da3e78 100644 --- a/1052-single-topic-message/libp2p/connmanager.html +++ b/1052-single-topic-message/libp2p/connmanager.html @@ -874,7 +874,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/chacha20poly1305.html b/1052-single-topic-message/libp2p/crypto/chacha20poly1305.html index c26176ba7..7d6da0a5a 100644 --- a/1052-single-topic-message/libp2p/crypto/chacha20poly1305.html +++ b/1052-single-topic-message/libp2p/crypto/chacha20poly1305.html @@ -391,7 +391,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/crypto.html b/1052-single-topic-message/libp2p/crypto/crypto.html index 349c70d38..9922299be 100644 --- a/1052-single-topic-message/libp2p/crypto/crypto.html +++ b/1052-single-topic-message/libp2p/crypto/crypto.html @@ -1703,7 +1703,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/curve25519.html b/1052-single-topic-message/libp2p/crypto/curve25519.html index c89044fde..7d4c8931a 100644 --- a/1052-single-topic-message/libp2p/crypto/curve25519.html +++ b/1052-single-topic-message/libp2p/crypto/curve25519.html @@ -398,7 +398,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/ecnist.html b/1052-single-topic-message/libp2p/crypto/ecnist.html index 2908ead0a..8eaca6c47 100644 --- a/1052-single-topic-message/libp2p/crypto/ecnist.html +++ b/1052-single-topic-message/libp2p/crypto/ecnist.html @@ -1450,7 +1450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/ed25519/constants.html b/1052-single-topic-message/libp2p/crypto/ed25519/constants.html index cdb84f5a4..e8f3f503a 100644 --- a/1052-single-topic-message/libp2p/crypto/ed25519/constants.html +++ b/1052-single-topic-message/libp2p/crypto/ed25519/constants.html @@ -3040,7 +3040,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/ed25519/ed25519.html b/1052-single-topic-message/libp2p/crypto/ed25519/ed25519.html index 6f14c4c4c..7cfb75452 100644 --- a/1052-single-topic-message/libp2p/crypto/ed25519/ed25519.html +++ b/1052-single-topic-message/libp2p/crypto/ed25519/ed25519.html @@ -940,7 +940,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/hkdf.html b/1052-single-topic-message/libp2p/crypto/hkdf.html index 8b92e80e6..1da20073d 100644 --- a/1052-single-topic-message/libp2p/crypto/hkdf.html +++ b/1052-single-topic-message/libp2p/crypto/hkdf.html @@ -275,7 +275,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/minasn1.html b/1052-single-topic-message/libp2p/crypto/minasn1.html index 3bbed8666..f5a733265 100644 --- a/1052-single-topic-message/libp2p/crypto/minasn1.html +++ b/1052-single-topic-message/libp2p/crypto/minasn1.html @@ -1195,7 +1195,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/rsa.html b/1052-single-topic-message/libp2p/crypto/rsa.html index 1b9d75918..0cd4a36d5 100644 --- a/1052-single-topic-message/libp2p/crypto/rsa.html +++ b/1052-single-topic-message/libp2p/crypto/rsa.html @@ -1029,7 +1029,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/crypto/secp.html b/1052-single-topic-message/libp2p/crypto/secp.html index 8e3ec7132..83b16f15a 100644 --- a/1052-single-topic-message/libp2p/crypto/secp.html +++ b/1052-single-topic-message/libp2p/crypto/secp.html @@ -908,7 +908,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/dial.html b/1052-single-topic-message/libp2p/dial.html index 77660e0d2..f4bd3ecd1 100644 --- a/1052-single-topic-message/libp2p/dial.html +++ b/1052-single-topic-message/libp2p/dial.html @@ -381,7 +381,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/dialer.html b/1052-single-topic-message/libp2p/dialer.html index bab0fd285..d2b3dbc60 100644 --- a/1052-single-topic-message/libp2p/dialer.html +++ b/1052-single-topic-message/libp2p/dialer.html @@ -450,7 +450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/errors.html b/1052-single-topic-message/libp2p/errors.html index 186e0c7c2..4455d4f90 100644 --- a/1052-single-topic-message/libp2p/errors.html +++ b/1052-single-topic-message/libp2p/errors.html @@ -340,7 +340,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/multiaddress.html b/1052-single-topic-message/libp2p/multiaddress.html index 1c8c08da1..bb62c9123 100644 --- a/1052-single-topic-message/libp2p/multiaddress.html +++ b/1052-single-topic-message/libp2p/multiaddress.html @@ -2551,7 +2551,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/multibase.html b/1052-single-topic-message/libp2p/multibase.html index 2df85525e..695f6feb1 100644 --- a/1052-single-topic-message/libp2p/multibase.html +++ b/1052-single-topic-message/libp2p/multibase.html @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/multicodec.html b/1052-single-topic-message/libp2p/multicodec.html index e036d948a..0566eb157 100644 --- a/1052-single-topic-message/libp2p/multicodec.html +++ b/1052-single-topic-message/libp2p/multicodec.html @@ -481,7 +481,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/multihash.html b/1052-single-topic-message/libp2p/multihash.html index 5ac79daff..01c5cdebd 100644 --- a/1052-single-topic-message/libp2p/multihash.html +++ b/1052-single-topic-message/libp2p/multihash.html @@ -689,7 +689,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/multistream.html b/1052-single-topic-message/libp2p/multistream.html index 604d5d9cd..0064cadb7 100644 --- a/1052-single-topic-message/libp2p/multistream.html +++ b/1052-single-topic-message/libp2p/multistream.html @@ -539,7 +539,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/muxers/mplex/coder.html b/1052-single-topic-message/libp2p/muxers/mplex/coder.html index 75ba5abea..68c30ec12 100644 --- a/1052-single-topic-message/libp2p/muxers/mplex/coder.html +++ b/1052-single-topic-message/libp2p/muxers/mplex/coder.html @@ -399,7 +399,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/muxers/mplex/mplex.html b/1052-single-topic-message/libp2p/muxers/mplex/mplex.html index 0211e821f..f9528bcea 100644 --- a/1052-single-topic-message/libp2p/muxers/mplex/mplex.html +++ b/1052-single-topic-message/libp2p/muxers/mplex/mplex.html @@ -455,7 +455,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/muxers/muxer.html b/1052-single-topic-message/libp2p/muxers/muxer.html index 4e49a2d9e..8f5d0972b 100644 --- a/1052-single-topic-message/libp2p/muxers/muxer.html +++ b/1052-single-topic-message/libp2p/muxers/muxer.html @@ -535,7 +535,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/muxers/yamux/yamux.html b/1052-single-topic-message/libp2p/muxers/yamux/yamux.html index 312808b87..8dc73ae38 100644 --- a/1052-single-topic-message/libp2p/muxers/yamux/yamux.html +++ b/1052-single-topic-message/libp2p/muxers/yamux/yamux.html @@ -606,7 +606,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/nameresolving/nameresolver.html b/1052-single-topic-message/libp2p/nameresolving/nameresolver.html index f25a68538..9065934a9 100644 --- a/1052-single-topic-message/libp2p/nameresolving/nameresolver.html +++ b/1052-single-topic-message/libp2p/nameresolving/nameresolver.html @@ -375,7 +375,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/observedaddrmanager.html b/1052-single-topic-message/libp2p/observedaddrmanager.html index 1a42b393b..4fc25a0fb 100644 --- a/1052-single-topic-message/libp2p/observedaddrmanager.html +++ b/1052-single-topic-message/libp2p/observedaddrmanager.html @@ -360,7 +360,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/peerid.html b/1052-single-topic-message/libp2p/peerid.html index 477d2b6d6..704b7eb82 100644 --- a/1052-single-topic-message/libp2p/peerid.html +++ b/1052-single-topic-message/libp2p/peerid.html @@ -806,7 +806,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/peerinfo.html b/1052-single-topic-message/libp2p/peerinfo.html index ee8511bed..080619084 100644 --- a/1052-single-topic-message/libp2p/peerinfo.html +++ b/1052-single-topic-message/libp2p/peerinfo.html @@ -484,7 +484,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protobuf/minprotobuf.html b/1052-single-topic-message/libp2p/protobuf/minprotobuf.html index 17783111f..a9a5721f2 100644 --- a/1052-single-topic-message/libp2p/protobuf/minprotobuf.html +++ b/1052-single-topic-message/libp2p/protobuf/minprotobuf.html @@ -931,7 +931,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/autonat/core.html b/1052-single-topic-message/libp2p/protocols/connectivity/autonat/core.html index cf44c66e8..2348b8844 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/autonat/core.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/autonat/core.html @@ -508,7 +508,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/autonat/server.html b/1052-single-topic-message/libp2p/protocols/connectivity/autonat/server.html index 30f5b37ce..0bb6d3898 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/autonat/server.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/autonat/server.html @@ -302,7 +302,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/relay/client.html b/1052-single-topic-message/libp2p/protocols/connectivity/relay/client.html index e6afbafc3..b0a90c60f 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/relay/client.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/relay/client.html @@ -468,7 +468,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/relay/messages.html b/1052-single-topic-message/libp2p/protocols/connectivity/relay/messages.html index bd1518691..c772d6573 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/relay/messages.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/relay/messages.html @@ -722,7 +722,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/relay/rconn.html b/1052-single-topic-message/libp2p/protocols/connectivity/relay/rconn.html index c2a4fc904..6a2562a2a 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/relay/rconn.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/relay/rconn.html @@ -383,7 +383,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/relay/relay.html b/1052-single-topic-message/libp2p/protocols/connectivity/relay/relay.html index 8c84a77e1..924e3e61e 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/relay/relay.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/relay/relay.html @@ -567,7 +567,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/relay/rtransport.html b/1052-single-topic-message/libp2p/protocols/connectivity/relay/rtransport.html index 0987926a3..afd71fbe4 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/relay/rtransport.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/relay/rtransport.html @@ -414,7 +414,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/connectivity/relay/utils.html b/1052-single-topic-message/libp2p/protocols/connectivity/relay/utils.html index 280b8b870..f4b794689 100644 --- a/1052-single-topic-message/libp2p/protocols/connectivity/relay/utils.html +++ b/1052-single-topic-message/libp2p/protocols/connectivity/relay/utils.html @@ -368,7 +368,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/identify.html b/1052-single-topic-message/libp2p/protocols/identify.html index a4ce733cf..344d7c65d 100644 --- a/1052-single-topic-message/libp2p/protocols/identify.html +++ b/1052-single-topic-message/libp2p/protocols/identify.html @@ -636,7 +636,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/ping.html b/1052-single-topic-message/libp2p/protocols/ping.html index 56686790f..013c6dd8f 100644 --- a/1052-single-topic-message/libp2p/protocols/ping.html +++ b/1052-single-topic-message/libp2p/protocols/ping.html @@ -414,7 +414,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/protocol.html b/1052-single-topic-message/libp2p/protocols/protocol.html index 2a300ae36..ada999413 100644 --- a/1052-single-topic-message/libp2p/protocols/protocol.html +++ b/1052-single-topic-message/libp2p/protocols/protocol.html @@ -467,7 +467,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/pubsub.html b/1052-single-topic-message/libp2p/protocols/pubsub.html index 2f1d30312..b37acc06e 100644 --- a/1052-single-topic-message/libp2p/protocols/pubsub.html +++ b/1052-single-topic-message/libp2p/protocols/pubsub.html @@ -229,7 +229,7 @@ class="link-seesrc" target="_blank">Source

Exports

-maxIncomingStreams=, codec=, libp2p_pubsub_received_subscriptions, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_messages_rebroadcasted, libp2p_pubsub_received_graft, removeValidator, DefaultMaxIncomingStreams, send, libp2p_pubsub_received_prune, ValidatorHandler, libp2p_pubsub_broadcast_iwant, init, unsubscribe, validate, removeObserver, libp2p_pubsub_broadcast_graft, libp2p_pubsub_received_unsubscriptions, sendSubs, codec, MsgIdProvider, PubSub, SubscriptionValidator, start, onTopicSubscription, updateMetrics, libp2p_pubsub_broadcast_subscriptions, addValidator, KnownLibP2PTopics, handleConn, onPubSubPeerEvent, publish, LPProtocol, ValidationResult, broadcast, subscribe, addObserver, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, unsubscribePeer, rpcHandler, init, KnownLibP2PTopicsSeq, handleData, LPProtoHandler, libp2p_pubsub_received_ihave, new, TopicPair, libp2p_pubsub_broadcast_ihave, subscribePeer, libp2p_pubsub_received_iwant, maxIncomingStreams, libp2p_pubsub_broadcast_messages, initPubSub, libp2p_pubsub_messages_published, TopicHandler, unsubscribeAll, InitializationError, libp2p_pubsub_received_messages, unsubscribe, getOrCreatePeer, stop, publish, initPubSub, addSeen, init, unsubscribePeer, rpcHandler, FloodSubCodec, hasSeen, firstSeen, handleSubscribe, FloodSub, sendSubs, onNewPeer, libp2p_pubsub_received_subscriptions, onTopicSubscription, validateParameters, init, MsgIdProvider, validateParameters, updateScores, libp2p_pubsub_broadcast_iwant, removeValidator, GossipSub, handleIDontWant, GossipSubParams, addObserver, libp2p_pubsub_broadcast_ihave, RoutingRecordsPair, codec, scoringHeartbeat, replenishFanout, GossipSubHeartbeatInterval, onPubSubPeerEvent, start, publish, libp2p_pubsub_broadcast_unsubscriptions, onTopicSubscription, addValidator, TopicInfo, disconnectPeer, onPubSubPeerEvent, publish, updateMetrics, PingsPeerBudget, broadcast, rateLimit, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, byScore, MeshMetrics, GossipSubHistoryLength, handleGraft, GossipBackoffPeriod, rpcHandler, KnownLibP2PTopicsSeq, LPProtoHandler, libp2p_pubsub_received_unsubscriptions, getGossipPeers, GossipSubDhi, TopicPair, init, GossipSubDlo, rewardDelivered, maxIncomingStreams=, libp2p_pubsub_received_iwant, maxIncomingStreams, handleIHave, BackoffTable, start, libp2p_pubsub_messages_published, ValidationSeenTable, TopicHandler, InitializationError, dropFanoutPeers, addDirectPeer, ValidationResult, codec=, removeObserver, IHaveMaxLength, libp2p_pubsub_messages_rebroadcasted, unsubscribe, DefaultMaxIncomingStreams, libp2p_pubsub_received_prune, IHavePeerBudget, ValidatorHandler, GossipSubCodec, heartbeat, rpcHandler, init, BackoffSlackTime, libp2p_gossipsub_peers_rate_limit_hits, libp2p_pubsub_broadcast_graft, peerExchangeList, GossipSubCodec_10, GossipSubHistoryGossip, RoutingRecordsHandler, rebalanceMesh, punishInvalidMessage, handleSubscribe, SubscriptionValidator, init, initPubSub, unsubscribe, libp2p_pubsub_broadcast_subscriptions, pruned, KnownLibP2PTopics, LPProtocol, subscribe, GossipSubFanoutTTL, unsubscribePeer, getOrCreatePeer, validate, handleData, PeerStats, libp2p_pubsub_received_graft, libp2p_pubsub_received_ihave, new, addCapped, grafted, send, subscribePeer, PubSub, handleIWant, init, handlePrune, libp2p_pubsub_broadcast_messages, unsubscribePeer, getOrCreatePeer, initPubSub, withPeerStats, handleConn, GossipSubD, unsubscribeAll, stop, libp2p_pubsub_received_messages, disconnectIfBadScorePeer, handleBackingOff, stop, TopicParams +maxIncomingStreams=, codec=, libp2p_pubsub_received_subscriptions, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_messages_rebroadcasted, libp2p_pubsub_received_graft, removeValidator, DefaultMaxIncomingStreams, send, libp2p_pubsub_received_prune, ValidatorHandler, libp2p_pubsub_broadcast_iwant, init, unsubscribe, validate, removeObserver, libp2p_pubsub_broadcast_graft, libp2p_pubsub_received_unsubscriptions, sendSubs, codec, MsgIdProvider, PubSub, SubscriptionValidator, start, onTopicSubscription, updateMetrics, libp2p_pubsub_broadcast_subscriptions, addValidator, KnownLibP2PTopics, handleConn, onPubSubPeerEvent, publish, LPProtocol, ValidationResult, broadcast, subscribe, addObserver, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, unsubscribePeer, rpcHandler, init, KnownLibP2PTopicsSeq, handleData, LPProtoHandler, libp2p_pubsub_received_ihave, new, TopicPair, libp2p_pubsub_broadcast_ihave, subscribePeer, libp2p_pubsub_received_iwant, maxIncomingStreams, libp2p_pubsub_broadcast_messages, initPubSub, libp2p_pubsub_messages_published, TopicHandler, unsubscribeAll, InitializationError, libp2p_pubsub_received_messages, unsubscribe, getOrCreatePeer, stop, publish, initPubSub, addSeen, init, unsubscribePeer, rpcHandler, FloodSubCodec, hasSeen, firstSeen, handleSubscribe, FloodSub, sendSubs, onNewPeer, libp2p_pubsub_received_subscriptions, onTopicSubscription, validateParameters, init, MsgIdProvider, validateParameters, updateScores, libp2p_pubsub_broadcast_iwant, removeValidator, GossipSub, handleIDontWant, GossipSubParams, addObserver, libp2p_pubsub_broadcast_ihave, RoutingRecordsPair, codec, scoringHeartbeat, replenishFanout, GossipSubHeartbeatInterval, onPubSubPeerEvent, start, publish, libp2p_pubsub_broadcast_unsubscriptions, onTopicSubscription, addValidator, TopicInfo, disconnectPeer, onPubSubPeerEvent, publish, updateMetrics, PingsPeerBudget, broadcast, rateLimit, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, byScore, MeshMetrics, GossipSubHistoryLength, handleGraft, GossipBackoffPeriod, rpcHandler, KnownLibP2PTopicsSeq, LPProtoHandler, libp2p_pubsub_received_unsubscriptions, getGossipPeers, GossipSubDhi, TopicPair, init, GossipSubDlo, rewardDelivered, maxIncomingStreams=, libp2p_pubsub_received_iwant, maxIncomingStreams, handleIHave, BackoffTable, start, libp2p_pubsub_messages_published, ValidationSeenTable, TopicHandler, InitializationError, dropFanoutPeers, addDirectPeer, ValidationResult, codec=, removeObserver, IHaveMaxLength, libp2p_pubsub_messages_rebroadcasted, unsubscribe, DefaultMaxIncomingStreams, libp2p_pubsub_received_prune, IHavePeerBudget, ValidatorHandler, GossipSubCodec, heartbeat, rpcHandler, init, BackoffSlackTime, libp2p_gossipsub_peers_rate_limit_hits, libp2p_pubsub_broadcast_graft, peerExchangeList, GossipSubCodec_10, GossipSubHistoryGossip, RoutingRecordsHandler, rebalanceMesh, punishInvalidMessage, handleSubscribe, SubscriptionValidator, init, initPubSub, unsubscribe, libp2p_pubsub_broadcast_subscriptions, pruned, KnownLibP2PTopics, LPProtocol, subscribe, GossipSubFanoutTTL, unsubscribePeer, getOrCreatePeer, validate, handleData, PeerStats, libp2p_pubsub_received_graft, libp2p_pubsub_received_ihave, new, addCapped, grafted, send, subscribePeer, PubSub, handleIWant, init, handlePrune, libp2p_pubsub_broadcast_messages, unsubscribePeer, getOrCreatePeer, initPubSub, withPeerStats, handleConn, GossipSubD, unsubscribeAll, stop, libp2p_pubsub_received_messages, disconnectIfBadScorePeer, handleBackingOff, stop, TopicParams
@@ -239,7 +239,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/pubsub/errors.html b/1052-single-topic-message/libp2p/protocols/pubsub/errors.html index bcb46cdc5..6d1e89767 100644 --- a/1052-single-topic-message/libp2p/protocols/pubsub/errors.html +++ b/1052-single-topic-message/libp2p/protocols/pubsub/errors.html @@ -255,7 +255,7 @@ class="link-seesrc" target="_blank">Source diff --git a/1052-single-topic-message/libp2p/protocols/pubsub/floodsub.html b/1052-single-topic-message/libp2p/protocols/pubsub/floodsub.html index 3511ca0ab..9437f5da8 100644 --- a/1052-single-topic-message/libp2p/protocols/pubsub/floodsub.html +++ b/1052-single-topic-message/libp2p/protocols/pubsub/floodsub.html @@ -264,6 +264,11 @@ window.addEventListener("DOMContentLoaded", main2);
  • publish(f: FloodSub; topic: string; data: seq[byte]): Future[int]
  • + + + + + + + @@ -664,7 +669,7 @@ class="link-seesrc" target="_blank">Source
    -
    MsgIdProvider {.public.} = proc (m: Message): Result[MessageId, ValidationResult] {.
    +
    MsgIdProvider {.public.} = proc (m: Message): Result[MessageId, ValidationResult] {.
         noSideEffect, ...raises: [], gcsafe.}
    @@ -752,7 +757,7 @@ class="link-seesrc" target="_blank">Source
    -
    ValidatorHandler {.public.} = proc (topic: string; message: Message): Future[
    +
    ValidatorHandler {.public.} = proc (topic: string; message: Message): Future[
         ValidationResult] {....gcsafe, raises: [].}
    @@ -812,7 +817,7 @@ class="link-seesrc" target="_blank">Source
    -
    proc broadcast(p: PubSub; sendPeers: auto; msg: RPCMsg; isHighPriority: bool) {.
    +
    proc broadcast(p: PubSub; sendPeers: auto; msg: RPCMsg; isHighPriority: bool) {.
         ...raises: [], raises: [].}
    @@ -880,8 +885,8 @@ class="link-seesrc" target="_blank">Source
    -
    proc send(p: PubSub; peer: PubSubPeer; msg: RPCMsg; isHighPriority: bool) {.
    -    ...raises: [], raises: [], tags: [RootEffect].}
    +
    proc send(p: PubSub; peer: PubSubPeer; msg: RPCMsg; isHighPriority: bool) {.
    +    ...raises: [], raises: [], tags: [RootEffect, WriteIOEffect, TimeEffect].}

    This procedure attempts to send a msg (of type RPCMsg) to the specified remote peer in the PubSub network.

    @@ -902,7 +907,8 @@ class="link-seesrc" target="_blank">Source
    proc sendSubs(p: PubSub; peer: PubSubPeer; topics: openArray[string];
    -              subscribe: bool) {....raises: [], tags: [RootEffect].}
    + subscribe: bool) {....raises: [], + tags: [RootEffect, WriteIOEffect, TimeEffect].}
    send subscriptions to remote peer @@ -933,7 +939,7 @@ class="link-seesrc" target="_blank">Source
    proc unsubscribe(p: PubSub; topic: string; handler: TopicHandler) {.public,
    -    ...raises: [], tags: [RootEffect].}
    + ...raises: [], tags: [RootEffect, WriteIOEffect, TimeEffect].}
    unsubscribe from a topic string @@ -946,7 +952,7 @@ class="link-seesrc" target="_blank">Source
    proc unsubscribe(p: PubSub; topics: openArray[TopicPair]) {.public, ...raises: [],
    -    tags: [RootEffect].}
    + tags: [RootEffect, WriteIOEffect, TimeEffect].}
    unsubscribe from a list of topic handlers @@ -968,6 +974,18 @@ href="https://github.com/status-im/nim-libp2p/tree/1052-single-topic-message/lib class="link-seesrc" target="_blank">Source   Edit +
    +
    +
    +
    proc updateMetrics(p: PubSub; rpcMsg: RPCMsg) {....raises: [], tags: [].}
    +
    + + +  Source +  Edit +
    @@ -1036,7 +1054,7 @@ class="link-seesrc" target="_blank">Source
    method onPubSubPeerEvent(p: PubSub; peer: PubSubPeer; event: PubSubPeerEvent) {.
    -    base, ...gcsafe, raises: [], tags: [RootEffect].}
    + base, ...gcsafe, raises: [], tags: [RootEffect, WriteIOEffect, TimeEffect].}
    @@ -1049,7 +1067,7 @@ class="link-seesrc" target="_blank">Source
    method onTopicSubscription(p: PubSub; topic: string; subscribed: bool) {.base,
    -    ...gcsafe, raises: [], tags: [RootEffect].}
    + ...gcsafe, raises: [], tags: [RootEffect, WriteIOEffect, TimeEffect].}
    @@ -1130,7 +1148,7 @@ class="link-seesrc" target="_blank">Source
    -
    method validate(p: PubSub; message: Message): Future[ValidationResult] {.base,
    +
    method validate(p: PubSub; message: Message): Future[ValidationResult] {.base,
         stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
         tags: [RootEffect].}
    @@ -1158,7 +1176,7 @@ class="link-seesrc" target="_blank">Source
    diff --git a/1052-single-topic-message/libp2p/protocols/pubsub/pubsubpeer.html b/1052-single-topic-message/libp2p/protocols/pubsub/pubsubpeer.html index 5fc815279..198e62d11 100644 --- a/1052-single-topic-message/libp2p/protocols/pubsub/pubsubpeer.html +++ b/1052-single-topic-message/libp2p/protocols/pubsub/pubsubpeer.html @@ -321,6 +321,11 @@ window.addEventListener("DOMContentLoaded", main2);
  • recvObservers(p: PubSubPeer; msg: var RPCMsg)
  • + + + + + + + + + +
    ControlGraft:
    +
    ControlIHave:
    +
    ControlIWant:
    +
    ControlMessage:
    +
    ControlPrune:
    copy:
    +
    decodeGraft:
    +
    decodeIHave:
    +
    decodeIWant:
    +
    decodeMessage:
    decodeMessages:
    +
    decodePrune:
    +
    decodeRpcMsg:
    decodeSubscription:
    +
    defaultMsgIdProvider:
    DefaultPublicExponent:
    +
    encodeRpcMsg:
    encodeVarint:
    +
    handleGraft:
    handleHop:
    +
    handlePrune:
    HandlerHolder:
    +
    Message:
    +
    MessageId:
    MessageType:
    +
    PeerInfoMsg:
    PeerRateLimitError:
    +
    rateLimit:
    read:
    rpcHandler:
    RPCHandler:
    +
    RPCMsg:
    RSA: