libp2p.tools.pubsub package¶
Submodules¶
libp2p.tools.pubsub.dummy_account_node module¶
libp2p.tools.pubsub.floodsub_integration_test_settings module¶
libp2p.tools.pubsub.utils module¶
-
async
libp2p.tools.pubsub.utils.
connect_some
(hosts: Sequence[libp2p.host.host_interface.IHost], degree: int) → None¶
-
async
libp2p.tools.pubsub.utils.
dense_connect
(hosts: Sequence[libp2p.host.host_interface.IHost]) → None¶
-
libp2p.tools.pubsub.utils.
make_pubsub_msg
(origin_id: libp2p.peer.id.ID, topic_ids: Sequence[str], data: bytes, seqno: bytes) → libp2p.pubsub.pb.rpc_pb2.Message¶
-
async
libp2p.tools.pubsub.utils.
one_to_all_connect
(hosts: Sequence[libp2p.host.host_interface.IHost], central_host_index: int) → None¶