libp2p.tools package

Subpackages

Submodules

libp2p.tools.constants module

class libp2p.tools.constants.GossipsubParams(degree, degree_low, degree_high, direct_peers, time_to_live, gossip_window, gossip_history, heartbeat_initial_delay, heartbeat_interval, direct_connect_initial_delay, direct_connect_interval, do_px, px_peers_count, prune_back_off, unsubscribe_back_off, max_pending_messages_per_peer, pending_messages_ttl)

Bases: NamedTuple

degree: int: Alias for field number 0

degree_high: int: Alias for field number 2

degree_low: int: Alias for field number 1

direct_connect_initial_delay: float: Alias for field number 9

direct_connect_interval: int: Alias for field number 10

direct_peers: Sequence[PeerInfo]: Alias for field number 3

do_px: bool: Alias for field number 11

gossip_history: int: Alias for field number 6

gossip_window: int: Alias for field number 5

heartbeat_initial_delay: float: Alias for field number 7

heartbeat_interval: float: Alias for field number 8

max_pending_messages_per_peer: int: Alias for field number 15

pending_messages_ttl: float: Alias for field number 16

prune_back_off: int: Alias for field number 13

px_peers_count: int: Alias for field number 12

time_to_live: int: Alias for field number 4

unsubscribe_back_off: int: Alias for field number 14

libp2p.tools.utils module

async libp2p.tools.utils.connect(node1: IHost, node2: IHost) → None: Connect node1 to node2.

async libp2p.tools.utils.connect_swarm(swarm_0: Swarm, swarm_1: Swarm) → None

libp2p.tools.utils.create_echo_stream_handler(ack_prefix: str) → Callable[[INetStream], Awaitable[None]]

libp2p.tools package

Subpackages

Submodules

libp2p.tools.constants module

libp2p.tools.utils module

Module contents