Index

A

AbstractSecureConn (class in libp2p.abc) accept_stream() (libp2p.abc.IMuxedConn method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method) acquire_connection() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) acquire_memory() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) acquire_scoped_stream() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) acquire_stream() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) ACTIVE (libp2p.relay.circuit_v2.resources.ReservationStatus attribute) active_circuits (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) ACTIVE_STREAMS (libp2p.network.CommonTags attribute) adaptive_degree_high (libp2p.pubsub.gossipsub.GossipSub attribute) adaptive_degree_low (libp2p.pubsub.gossipsub.GossipSub attribute) adaptive_gossip_enabled (libp2p.pubsub.gossipsub.GossipSub attribute) add() (libp2p.tools.timed_cache.base_timed_cache.BaseTimedCache method) (libp2p.tools.timed_cache.first_seen_cache.FirstSeenCache method) (libp2p.tools.timed_cache.last_seen_cache.LastSeenCache method) add_addr() (libp2p.abc.IAddrBook method) (libp2p.abc.IPeerStore method) (libp2p.discovery.bootstrap.BootstrapDiscovery method) (libp2p.peer.peerstore.PeerStore method) add_addrs() (libp2p.abc.IAddrBook method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) add_AutoNATServicer_to_server() (in module libp2p.host.autonat.pb.autonat_pb2_grpc) add_block() (libp2p.bitswap.BitswapClient method) add_child() (libp2p.tools.anyio_service.tasks.BaseTaskWithChildren method) (libp2p.tools.anyio_service.tasks.TaskWithChildrenAPI method) add_conn() (libp2p.network.swarm.Swarm method) add_connection() (libp2p.transport.websocket.manager.WebSocketConnectionManager method) add_handler() (libp2p.abc.IMultiselectMuxer method) (libp2p.protocol_muxer.GenericMultistreamSelector method) (libp2p.protocol_muxer.multiselect.Multiselect method) add_key_pair() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) add_libp2p_extension() (in module libp2p.security.tls.certificate) add_multiaddr() (libp2p.rcmgr.allowlist.Allowlist method) add_peer() (libp2p.abc.IPubsubRouter method) (libp2p.discovery.random_walk.rt_refresh_manager.RoutingTableProtocol method) (libp2p.discovery.rendezvous.discovery.PeerCache method) (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.kad_dht.routing_table.KBucket method) (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) (libp2p.rcmgr.allowlist.Allowlist method) add_peer_multiaddr() (libp2p.rcmgr.allowlist.Allowlist method) add_port_mapping() (libp2p.discovery.upnp.upnp.UpnpManager method) add_privkey() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) add_protocols() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) add_provider() (libp2p.kad_dht.provider_store.ProviderStore method) add_pubkey() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method)

add_refresh_done_callback() (libp2p.discovery.random_walk.rt_refresh_manager.RTRefreshManager method) (libp2p.discovery.random_walk.RTRefreshManager method) add_service() (libp2p.discovery.mdns.listener.PeerListener method) add_to_blacklist() (libp2p.pubsub.pubsub.Pubsub method) add_transport() (libp2p.security.security_multistream.SecurityMultistream method) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream method) add_validator() (libp2p.records.validator.NamespacedValidator method) addr_stream() (libp2p.peer.peerstore.PeerStore method) address_protocol() (in module libp2p.filecoin) addresses (libp2p.kad_dht.provider_store.ProviderRecord property) addrs (libp2p.peer.peer_record.PeerRecord attribute) (libp2p.peer.peerdata.PeerData attribute) (libp2p.peer.peerinfo.PeerInfo attribute) (libp2p.relay.circuit_v2.resources.ReservationVoucher attribute) addrs() (libp2p.abc.IAddrBook method) (libp2p.abc.IPeerStore method) (libp2p.host.observed_addr_manager.ObservedAddrManager method) (libp2p.peer.peerstore.PeerStore method) addrs_for() (libp2p.host.observed_addr_manager.ObservedAddrManager method) addrs_from_protobuf() (in module libp2p.peer.peer_record) addrs_to_protobuf() (in module libp2p.peer.peer_record) advanced_tls_config (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute) advertise() (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousDiscovery method) allow_conn() (libp2p.rcmgr.metrics.Metrics method) allow_memory() (libp2p.rcmgr.metrics.Metrics method) allow_stream() (libp2p.rcmgr.metrics.Metrics method) allowed (libp2p.rcmgr.metrics.ResourceMetrics attribute) allowed() (libp2p.rcmgr.allowlist.Allowlist method) allowed_multiaddr() (libp2p.rcmgr.allowlist.Allowlist method) allowed_peer() (libp2p.rcmgr.allowlist.Allowlist method) allowed_peer_and_multiaddr() (libp2p.rcmgr.allowlist.Allowlist method) Allowlist (class in libp2p.rcmgr.allowlist) AllowlistConfig (class in libp2p.rcmgr.allowlist) alpn_protocols (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) anyio_task (libp2p.tools.anyio_service.tasks.FunctionTask property) AnyIOManager (class in libp2p.tools.anyio_service) (class in libp2p.tools.anyio_service.context) (class in libp2p.tools.anyio_service.manager) APPLICATION (libp2p.network.CommonTags attribute) apply_fallbacks() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) as_service() (in module libp2p.tools.anyio_service) (in module libp2p.tools.anyio_service.api) AsyncFn (in module libp2p.tools.anyio_service.api) attach() (libp2p.abc.IPubsubRouter method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) authenticate() (libp2p.crypto.authenticated_encryption.MacAndCipher method) author_login (libp2p.observability.oso.providers.CommitInfo attribute) auto_connector (libp2p.network.swarm.Swarm attribute) auto_relay_timeout (libp2p.relay.circuit_v2.config.ClientConfig attribute) AutoConnector (class in libp2p.network) AutoNAT (class in libp2p.host.autonat.pb.autonat_pb2_grpc) AutoNATService (class in libp2p.host.autonat.autonat) AutoNATServicer (class in libp2p.host.autonat.pb.autonat_pb2_grpc) AutoNATStatus (class in libp2p.host.autonat.autonat) AutoNATStub (class in libp2p.host.autonat.pb.autonat_pb2_grpc) autotls_config (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute) AutoTLSConfig (class in libp2p.transport.websocket) average_days_between_releases (libp2p.observability.oso.models.ReleaseCadenceMetric attribute)

B

back_off (libp2p.pubsub.gossipsub.GossipSub attribute) background_anyio_service() (in module libp2p.tools.anyio_service) (in module libp2p.tools.anyio_service.context) background_nursery (libp2p.network.swarm.Swarm attribute) background_trio_service() (in module libp2p.tools.anyio_service) (in module libp2p.tools.anyio_service.context) base58 (libp2p.peer.id.ID property) BaseLibp2pError BaseMsgReadWriter (class in libp2p.io.msgio) BaseNoiseMsgReadWriter (class in libp2p.security.noise.io) BasePattern (class in libp2p.security.noise.patterns) BaseSecureTransport (class in libp2p.security.base_transport) BaseSession (class in libp2p.security.base_session) BaseSubscriptionAPI (class in libp2p.pubsub.subscription) BaseTask (class in libp2p.tools.anyio_service.tasks) BaseTaskWithChildren (class in libp2p.tools.anyio_service.tasks) BaseTimedCache (class in libp2p.tools.timed_cache.base_timed_cache) BasicHost (class in libp2p.host.basic_host) BITSWAP (libp2p.network.CommonTags attribute) BitswapClient (class in libp2p.bitswap) BitswapError blacklisted_peers (libp2p.pubsub.pubsub.Pubsub attribute) BlankValidator (class in libp2p.records.validator) block_conn() (libp2p.rcmgr.metrics.Metrics method) block_memory() (libp2p.rcmgr.metrics.Metrics method) block_stream() (libp2p.rcmgr.metrics.Metrics method) blocked (libp2p.rcmgr.metrics.ResourceMetrics attribute) BlockNotFoundError

blocks_topic() (in module libp2p.filecoin) (in module libp2p.filecoin.constants) BlockStore (class in libp2p.bitswap) BlockTooLargeError BlockUnavailableError bootstrap (libp2p.host.basic_host.BasicHost attribute) BOOTSTRAP (libp2p.network.CommonTags attribute) bootstrap_addresses (libp2p.filecoin.FilecoinNetworkPreset attribute) (libp2p.filecoin.networks.FilecoinNetworkPreset attribute) bootstrap_relays (libp2p.relay.circuit_v2.config.RelayConfig attribute) BootstrapDiscovery (class in libp2p.discovery.bootstrap) buf (libp2p.security.secure_session.SecureSession attribute) build_dependency_graph() (in module libp2p.observability.oso.dependency_graph) build_filecoin_gossipsub() (in module libp2p.filecoin) (in module libp2p.filecoin.pubsub) build_filecoin_pubsub() (in module libp2p.filecoin) (in module libp2p.filecoin.pubsub) build_filecoin_score_params() (in module libp2p.filecoin) (in module libp2p.filecoin.pubsub) build_parser() (in module libp2p.filecoin.cli) (in module libp2p.observability.oso.cli) build_transitive_graph() (in module libp2p.observability.oso.transitive_graph) bytes_received (libp2p.transport.websocket.connection.WebSocketStats attribute) bytes_sent (libp2p.transport.websocket.connection.WebSocketStats attribute) bytes_to_base58() (in module libp2p.kad_dht.utils) bytes_to_multibase() (in module libp2p.kad_dht.utils) BytesCodec (class in libp2p.request_response) (class in libp2p.request_response.codec)

C

cache (libp2p.tools.timed_cache.base_timed_cache.BaseTimedCache attribute) cache_static_key() (libp2p.security.noise.transport.Transport method) CacheEntry (class in libp2p.pubsub.mcache) calculate_contributor_trend() (in module libp2p.observability.oso.metrics) calculate_dependency_topology() (in module libp2p.observability.oso.metrics) calculate_issue_responsiveness() (in module libp2p.observability.oso.metrics) calculate_peer_id() (libp2p.security.secio.transport.Proposal method) calculate_popularity() (in module libp2p.observability.oso.metrics) calculate_release_cadence() (in module libp2p.observability.oso.metrics) calculate_security_proxy() (in module libp2p.observability.oso.metrics) can_accept_connection() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) (libp2p.relay.circuit_v2.resources.Reservation method) can_accept_reservation() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) can_dial() (libp2p.transport.quic.transport.QUICTransport method) (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) can_read() (libp2p.transport.quic.stream.QUICStream method) can_write() (libp2p.transport.quic.stream.QUICStream method) cancel() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.ManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) (libp2p.tools.anyio_service.tasks.ChildServiceTask method) (libp2p.tools.anyio_service.tasks.FunctionTask method) (libp2p.tools.anyio_service.tasks.TaskAPI method) cancel_want() (libp2p.bitswap.BitswapClient method) cert_template (libp2p.security.tls.IdentityConfig attribute) (libp2p.security.tls.transport.IdentityConfig attribute) certificate (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) (libp2p.transport.quic.security.TLSConfig attribute) certificate_chain (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) CertificateGenerator (class in libp2p.transport.quic.security) channel_id (libp2p.stream_muxer.mplex.datastructures.StreamID attribute) chat_mode() (in module examples.tls.example_tls_client) check_hostname (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) children (libp2p.tools.anyio_service.tasks.TaskWithChildrenAPI attribute) ChildServiceTask (class in libp2p.tools.anyio_service.tasks) cipher_key (libp2p.crypto.authenticated_encryption.EncryptionParameters attribute) cipher_type (libp2p.crypto.authenticated_encryption.EncryptionParameters attribute) (libp2p.security.secio.transport.EncryptionParameters attribute) ciphers (libp2p.security.secio.transport.Proposal attribute) circuit_rate_per_ip (libp2p.relay.circuit_v2.config.HopConfig attribute) CircuitV2Listener (class in libp2p.relay.circuit_v2.transport) CircuitV2Protocol (class in libp2p.relay.circuit_v2.protocol) CircuitV2Transport (class in libp2p.relay.circuit_v2.transport) cleanup_all_expired() (libp2p.discovery.rendezvous.RendezvousService method) (libp2p.discovery.rendezvous.service.RendezvousService method) cleanup_expired() (libp2p.kad_dht.provider_store.ProviderStore method) (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method) cleanup_logging() (in module libp2p.utils.logging) cleanup_routing_table() (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) clear() (libp2p.discovery.rendezvous.discovery.PeerCache method) (libp2p.rcmgr.allowlist.Allowlist method) clear_addrs() (libp2p.abc.IAddrBook method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) clear_all_cooldowns() (libp2p.network.AutoConnector method) clear_blacklist() (libp2p.pubsub.pubsub.Pubsub method) clear_cache() (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousDiscovery method) clear_cooldown() (libp2p.network.AutoConnector method) clear_expired() (libp2p.pubsub.pubsub.ValidationCache method) clear_keydata() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) clear_metadata() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerMetadata method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) clear_metrics() (libp2p.abc.IMetrics method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) clear_peer() (libp2p.network.TagStore method) clear_peerdata() (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) clear_protocol_data() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) clear_static_key_cache() (libp2p.security.noise.transport.Transport method) CLIENT (libp2p.kad_dht.kad_dht.DHTMode attribute) (libp2p.relay.circuit_v2.config.RelayRole attribute) ClientConfig (class in libp2p.relay.circuit_v2.config) close() (libp2p.abc.IHost method) (libp2p.abc.IListener method) (libp2p.abc.IMuxedConn method) (libp2p.abc.INetwork method) (libp2p.discovery.rendezvous.client.RendezvousClient method) (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousClient method) (libp2p.discovery.rendezvous.RendezvousDiscovery method) (libp2p.host.basic_host.BasicHost method) (libp2p.io.abc.Closer method) (libp2p.io.msgio.BaseMsgReadWriter method) (libp2p.io.trio.TrioTCPStream method) (libp2p.network.connection.raw_connection.RawConnection method) (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.network.stream.net_stream.NetStream method) (libp2p.network.swarm.Swarm method) (libp2p.rcmgr.manager.ConnectionScope method) (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) (libp2p.relay.circuit_v2.transport.CircuitV2Listener method) (libp2p.relay.circuit_v2.transport.TrackedRawConnection method) (libp2p.security.insecure.transport.InsecureSession method) (libp2p.security.noise.io.BaseNoiseMsgReadWriter method) (libp2p.security.pnet.psk_conn.PskConn method) (libp2p.security.secio.transport.SecioMsgReadWriter method) (libp2p.security.secure_session.SecureSession method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.security.tls.TLSReadWriter method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method) (libp2p.transport.quic.listener.QUICListener method) (libp2p.transport.quic.stream.QUICStream method) (libp2p.transport.quic.transport.QUICTransport method) (libp2p.transport.tcp.tcp.TCPListener method) (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.listener.WebsocketListener method) (libp2p.transport.websocket.P2PWebSocketConnection method) (libp2p.transport.websocket.WebsocketListener method) close_all() (libp2p.transport.websocket.manager.WebSocketConnectionManager method) CLOSE_BOTH (libp2p.network.stream.net_stream.StreamState attribute) close_lock (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) close_peer() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) CLOSE_READ (libp2p.network.stream.net_stream.StreamState attribute) close_read() (libp2p.network.stream.net_stream.NetStream method) (libp2p.transport.quic.stream.QUICStream method) close_timeout (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute)

CLOSE_WRITE (libp2p.network.stream.net_stream.StreamState attribute) close_write() (libp2p.network.stream.net_stream.NetStream method) (libp2p.transport.quic.stream.QUICStream method) CLOSED (libp2p.transport.quic.stream.StreamState attribute) closed_at (libp2p.observability.oso.providers.IssueInfo attribute) closed_issues (libp2p.observability.oso.models.IssueResponsivenessMetric attribute) closed_stream() (libp2p.abc.INotifee method) (libp2p.pubsub.pubsub_notifee.PubsubNotifee method) CloseInitiator (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) Closer (class in libp2p.io.abc) CloseReceiver (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) codec() (libp2p.abc.IPeerRecord method) (libp2p.peer.peer_record.PeerRecord method) collect_health_report() (in module libp2p.observability.oso) (in module libp2p.observability.oso.service) collect_rcmgr_baseline() (in module libp2p.observability.oso.metrics) combine_configs() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) CommitInfo (class in libp2p.observability.oso.providers) commits_considered (libp2p.observability.oso.models.ContributorTrendMetric attribute) committed_at (libp2p.observability.oso.providers.CommitInfo attribute) common_stream_handler (libp2p.network.swarm.Swarm attribute) CommonTags (class in libp2p.network) condition (libp2p.observability.oso.models.DependencyEntry attribute) config_name (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) conn (libp2p.io.abc.EncryptedMsgReadWriter attribute) (libp2p.security.tls.TLSReadWriter attribute) conn_state() (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.P2PWebSocketConnection method) connect() (in module libp2p.tools.utils) (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) (libp2p.host.routed_host.RoutedHost method) (libp2p.transport.quic.connection.QUICConnection method) connect_swarm() (in module libp2p.tools.utils) connected() (libp2p.abc.INotifee method) (libp2p.pubsub.pubsub_notifee.PubsubNotifee method) connected_at (libp2p.transport.websocket.connection.WebSocketStats attribute) CONNECTION_BLOCKS (libp2p.rcmgr.metrics.MetricType attribute) CONNECTION_CLOSE_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) connection_config (libp2p.network.swarm.Swarm attribute) CONNECTION_FAILED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) CONNECTION_FLOW_CONTROL_WINDOW (libp2p.transport.quic.config.QUICTransportConfig attribute) connection_gate (libp2p.abc.INetworkService attribute) (libp2p.network.swarm.Swarm attribute) CONNECTION_HANDSHAKE_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) connection_pruner (libp2p.network.swarm.Swarm attribute) connection_timeout (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) connection_window (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) ConnectionClosedError ConnectionFailure ConnectionPruner (class in libp2p.network) connections (libp2p.abc.INetwork attribute) (libp2p.network.swarm.Swarm attribute) CONNECTIONS_INBOUND (libp2p.rcmgr.metrics.MetricType attribute) connections_legacy (libp2p.network.swarm.Swarm property) CONNECTIONS_OUTBOUND (libp2p.rcmgr.metrics.MetricType attribute) ConnectionScope (class in libp2p.rcmgr.manager) conns (libp2p.network.TagInfo attribute) consume_envelope() (in module libp2p.peer.envelope) consume_peer_record() (libp2p.abc.ICertifiedAddrBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) consume_peer_records() (libp2p.peer.peerstore.PeerStore method) ContentAddressedMessageIDGenerator (class in libp2p.pubsub.pubsub) continuously_read_stream() (libp2p.pubsub.pubsub.Pubsub method) contributor_logins (libp2p.observability.oso.models.ContributorTrendMetric attribute) contributor_trend (libp2p.observability.oso.models.HealthMetrics attribute) ContributorTrendMetric (class in libp2p.observability.oso.models) ControlExtensions (class in libp2p.pubsub.pb.rpc_pb2) ControlGraft (class in libp2p.pubsub.pb.rpc_pb2) ControlIDontWant (class in libp2p.pubsub.pb.rpc_pb2) ControlIHave (class in libp2p.pubsub.pb.rpc_pb2) ControlIWant (class in libp2p.pubsub.pb.rpc_pb2) ControlMessage (class in libp2p.pubsub.pb.rpc_pb2) ControlObserve (class in libp2p.pubsub.pb.rpc_pb2) ControlPrune (class in libp2p.pubsub.pb.rpc_pb2) ControlUnobserve (class in libp2p.pubsub.pb.rpc_pb2) count_in_stats (libp2p.tools.anyio_service.tasks.FunctionTask property) counter (libp2p.pubsub.pubsub.Pubsub attribute) create_cert_template() (in module libp2p.security.tls) (in module libp2p.security.tls.certificate) create_client_config() (libp2p.transport.quic.security.QUICTLSConfigManager method) create_client_config_from_base() (in module libp2p.transport.quic.utils) create_client_tls_config() (in module libp2p.transport.quic.security) create_connection() (libp2p.transport.websocket.proxy.SOCKSConnectionManager method) create_connection_error() (in module libp2p.transport.quic.exceptions) create_default_stream_handler() (in module libp2p.network.swarm) create_discover_message() (in module libp2p.discovery.rendezvous.messages) create_discover_response_message() (in module libp2p.discovery.rendezvous.messages) create_echo_stream_handler() (in module libp2p.tools.utils) create_ephemeral_key_pair() (in module libp2p.crypto.key_exchange) create_key_from_binary() (in module libp2p.kad_dht) (in module libp2p.kad_dht.utils) create_listener() (libp2p.abc.ITransport method) (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) (libp2p.transport.quic.transport.QUICTransport method) (libp2p.transport.TCP method) (libp2p.transport.tcp.tcp.TCP method) (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) create_mplex_muxer_option() (in module libp2p) create_new_key_pair() (in module libp2p.crypto.ecc) (in module libp2p.crypto.ed25519) (in module libp2p.crypto.rsa) (in module libp2p.crypto.secp256k1) create_noise_state() (libp2p.security.noise.patterns.BasePattern method) create_quic_multiaddr() (in module libp2p.transport.quic.utils) create_quic_security_transport() (in module libp2p.transport.quic.security) create_register_message() (in module libp2p.discovery.rendezvous.messages) create_register_response_message() (in module libp2p.discovery.rendezvous.messages) create_reservation() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) create_secure_session() (in module libp2p.security.secio.transport) create_server_config() (libp2p.transport.quic.security.QUICTLSConfigManager method) create_server_config_from_base() (in module libp2p.transport.quic.utils) create_server_tls_config() (in module libp2p.transport.quic.security) create_signed_key_extension() (libp2p.transport.quic.security.LibP2PExtensionHandler static method) create_signed_peer_record() (in module libp2p.peer.peerstore) create_ssl_context() (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) create_status() (in module libp2p.relay.circuit_v2.protocol_buffer) create_stream_config_for_use_case() (in module libp2p.transport.quic.config) create_stream_error() (in module libp2p.transport.quic.exceptions) create_tcp_host_pair() (in module examples.tcp.test_tcp_data_transfer) create_temp_file() (in module libp2p.utils.paths) create_tls_transport() (in module libp2p.security.tls) (in module libp2p.security.tls.transport) create_transport() (in module libp2p.transport) (libp2p.transport.TransportRegistry method) create_transport_for_multiaddr() (in module libp2p.transport) create_unregister_message() (in module libp2p.discovery.rendezvous.messages) create_yamux_muxer_option() (in module libp2p) created_at (libp2p.observability.oso.providers.IssueInfo attribute) (libp2p.transport.websocket.connection.WebSocketStats attribute) CryptographyError current_usage (libp2p.rcmgr.metrics.ResourceMetrics attribute) curve_type (libp2p.security.secio.transport.EncryptionParameters attribute) custom_quic_version_to_wire_format() (in module libp2p.transport.quic.utils) CustomMessageIDGenerator (class in libp2p.pubsub.pubsub)

D

daemon (libp2p.tools.anyio_service.tasks.TaskAPI attribute) DaemonTaskExit, [1] Data (class in libp2p.bitswap.pb.unixfs_pb2) data (libp2p.relay.circuit_v2.resources.RelayLimits attribute) dcutr_read_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) dcutr_write_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) dead_peer_receive_channel (libp2p.pubsub.pubsub.Pubsub attribute) dead_peers_queue (libp2p.pubsub.pubsub_notifee.PubsubNotifee attribute) debug_config() (libp2p.transport.quic.security.QUICTLSSecurityConfig method) debug_dump_envelope() (in module libp2p.peer.envelope) decode_request() (libp2p.request_response.BytesCodec method) (libp2p.request_response.codec.BytesCodec method) (libp2p.request_response.codec.JSONCodec method) (libp2p.request_response.codec.RequestResponseCodec method) (libp2p.request_response.JSONCodec method) (libp2p.request_response.RequestResponseCodec method) decode_response() (libp2p.request_response.BytesCodec method) (libp2p.request_response.codec.BytesCodec method) (libp2p.request_response.codec.JSONCodec method) (libp2p.request_response.codec.RequestResponseCodec method) (libp2p.request_response.JSONCodec method) (libp2p.request_response.RequestResponseCodec method) decode_signed_key() (in module libp2p.security.tls.certificate) decode_uvarint() (in module libp2p.utils.varint) decode_uvarint_from_stream() (in module libp2p.utils.varint) decode_varint_from_bytes() (in module libp2p.utils.varint) decode_varint_with_size() (in module libp2p.utils.varint) decrypt() (libp2p.io.abc.Encrypter method) (libp2p.security.noise.io.NoiseHandshakeReadWriter method) (libp2p.security.noise.io.NoiseTransportReadWriter method) (libp2p.security.secio.transport.SecioMsgReadWriter method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.TLSReadWriter method) decrypt_if_valid() (libp2p.crypto.authenticated_encryption.MacAndCipher method) DecryptionFailedException default_msg_id_fn() (in module libp2p.pubsub.mcache) default_secure_bytes_provider() (in module libp2p.security.base_transport) degree (libp2p.abc.IPubsubRouter attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) degree_high (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) degree_low (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) delete_block() (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) demo_custom_transport_registration() (in module examples.transport.transport_integration_demo) demo_integration_with_libp2p() (in module examples.transport.transport_integration_demo) demo_multiaddr_transport_selection() (in module examples.transport.transport_integration_demo) demo_transport_factory() (in module examples.transport.transport_integration_demo) demo_transport_registry() (in module examples.transport.transport_integration_demo) dependencies (libp2p.observability.oso.models.DependencyGraph attribute) dependency_count (libp2p.observability.oso.models.SecurityProxyMetric attribute) dependency_topology (libp2p.observability.oso.models.HealthMetrics attribute) dependency_type (libp2p.observability.oso.models.DependencyEntry attribute) DependencyEntry (class in libp2p.observability.oso.models) DependencyGraph (class in libp2p.observability.oso.models) DependencyTopologyMetric (class in libp2p.observability.oso.models) DESCRIPTOR (libp2p.bitswap.pb.bitswap_pb2.Message attribute) (libp2p.bitswap.pb.bitswap_pb2.Message.Block attribute) (libp2p.bitswap.pb.bitswap_pb2.Message.BlockPresence attribute) (libp2p.bitswap.pb.bitswap_pb2.Message.Wantlist attribute) (libp2p.bitswap.pb.bitswap_pb2.Message.Wantlist.Entry attribute) (libp2p.bitswap.pb.dag_pb_pb2.PBLink attribute) (libp2p.bitswap.pb.dag_pb_pb2.PBNode attribute) (libp2p.bitswap.pb.unixfs_pb2.Data attribute) (libp2p.bitswap.pb.unixfs_pb2.IPFSTimestamp attribute) (libp2p.bitswap.pb.unixfs_pb2.Metadata attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.Discover attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.DiscoverResponse attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.DiscoverSubscribe attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.DiscoverSubscribeResponse attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.PeerInfo attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.Register attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.RegisterResponse attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message.Unregister attribute) (libp2p.discovery.rendezvous.pb.rendezvous_pb2.RegistrationRecord attribute) (libp2p.host.autonat.pb.autonat_pb2.DialRequest attribute) (libp2p.host.autonat.pb.autonat_pb2.DialResponse attribute) (libp2p.host.autonat.pb.autonat_pb2.Message attribute) (libp2p.host.autonat.pb.autonat_pb2.PeerInfo attribute) (libp2p.identity.identify.pb.identify_pb2.Identify attribute) (libp2p.kad_dht.pb.kademlia_pb2.Message attribute) (libp2p.kad_dht.pb.kademlia_pb2.Message.Peer attribute) (libp2p.kad_dht.pb.kademlia_pb2.Record attribute) (libp2p.pubsub.pb.rpc_pb2.ControlExtensions attribute) (libp2p.pubsub.pb.rpc_pb2.ControlGraft attribute) (libp2p.pubsub.pb.rpc_pb2.ControlIDontWant attribute) (libp2p.pubsub.pb.rpc_pb2.ControlIHave attribute) (libp2p.pubsub.pb.rpc_pb2.ControlIWant attribute) (libp2p.pubsub.pb.rpc_pb2.ControlMessage attribute) (libp2p.pubsub.pb.rpc_pb2.ControlObserve attribute) (libp2p.pubsub.pb.rpc_pb2.ControlPrune attribute) (libp2p.pubsub.pb.rpc_pb2.ControlUnobserve attribute) (libp2p.pubsub.pb.rpc_pb2.Message attribute) (libp2p.pubsub.pb.rpc_pb2.PeerInfo attribute) (libp2p.pubsub.pb.rpc_pb2.RPC attribute) (libp2p.pubsub.pb.rpc_pb2.RPC.SubOpts attribute) (libp2p.pubsub.pb.rpc_pb2.TestExtension attribute) (libp2p.pubsub.pb.rpc_pb2.TopicDescriptor attribute) (libp2p.pubsub.pb.rpc_pb2.TopicDescriptor.AuthOpts attribute) (libp2p.pubsub.pb.rpc_pb2.TopicDescriptor.EncOpts attribute) (libp2p.records.pb.IpnsEntry attribute) (libp2p.relay.circuit_v2.pb.circuit_pb2.HopMessage attribute) (libp2p.relay.circuit_v2.pb.circuit_pb2.Limit attribute) (libp2p.relay.circuit_v2.pb.circuit_pb2.Reservation attribute) (libp2p.relay.circuit_v2.pb.circuit_pb2.Status attribute) (libp2p.relay.circuit_v2.pb.circuit_pb2.StopMessage attribute) (libp2p.security.insecure.pb.plaintext_pb2.Exchange attribute) (libp2p.security.noise.pb.noise_pb2.NoiseExtensions attribute) (libp2p.security.noise.pb.noise_pb2.NoiseHandshakePayload attribute) (libp2p.security.secio.pb.spipe_pb2.Exchange attribute) (libp2p.security.secio.pb.spipe_pb2.Propose attribute)

deserialize() (libp2p.crypto.secp256k1.Secp256k1PrivateKey class method) (libp2p.crypto.secp256k1.Secp256k1PublicKey class method) (libp2p.security.noise.messages.NoiseHandshakePayload class method) (libp2p.security.secio.transport.Proposal class method) deserialize_from_protobuf() (libp2p.crypto.keys.PrivateKey class method) (libp2p.crypto.keys.PublicKey class method) deserialize_private_key() (in module libp2p.crypto.serialization) deserialize_public_key() (in module libp2p.crypto.serialization) (libp2p.transport.quic.security.LibP2PKeyConverter static method) DHT (libp2p.network.CommonTags attribute) dht_discovery_enabled (libp2p.relay.circuit_v2.config.RelayConfig attribute) dht_protocol_name() (in module libp2p.filecoin) (in module libp2p.filecoin.constants) DHTMode (class in libp2p.kad_dht.kad_dht) dial() (libp2p.abc.ITransport method) Dial() (libp2p.host.autonat.pb.autonat_pb2_grpc.AutoNAT static method) (libp2p.host.autonat.pb.autonat_pb2_grpc.AutoNATServicer method) dial() (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) (libp2p.transport.quic.transport.QUICTransport method) (libp2p.transport.TCP method) (libp2p.transport.tcp.tcp.TCP method) (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) dial_addr() (libp2p.network.swarm.Swarm method) dial_peer() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) dial_peer_info() (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) DIAL_REFUSED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) dial_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) DialRequest (class in libp2p.host.autonat.pb.autonat_pb2) DialResponse (class in libp2p.host.autonat.pb.autonat_pb2) did_error (libp2p.tools.anyio_service.AnyIOManager property) (libp2p.tools.anyio_service.api.ManagerAPI property) (libp2p.tools.anyio_service.context.AnyIOManager property) (libp2p.tools.anyio_service.context.TrioManager property) (libp2p.tools.anyio_service.manager.AnyIOManager property) digest() (libp2p.peer.id.IdentityHash method) direct_connect_heartbeat() (libp2p.pubsub.gossipsub.GossipSub method) direct_connect_initial_delay (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) direct_connect_interval (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) direct_dependencies (libp2p.observability.oso.models.DependencyTopologyMetric attribute) direct_peers (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) Direction (class in libp2p.rcmgr) (class in libp2p.rcmgr.metrics) direction (libp2p.network.connection.swarm_connection.SwarmConn property) (libp2p.transport.quic.stream.QUICStream property) discard_child() (libp2p.tools.anyio_service.tasks.BaseTaskWithChildren method) (libp2p.tools.anyio_service.tasks.TaskWithChildrenAPI method) disconnect() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) disconnected() (libp2p.abc.INotifee method) (libp2p.pubsub.pubsub_notifee.PubsubNotifee method) discover() (libp2p.discovery.rendezvous.client.RendezvousClient method) (libp2p.discovery.rendezvous.RendezvousClient method) (libp2p.discovery.upnp.upnp.UpnpManager method) discover_peers() (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) discover_relays() (libp2p.relay.circuit_v2.discovery.RelayDiscovery method) discovered_at (libp2p.relay.circuit_v2.discovery.RelayInfo attribute) discovery_interval (libp2p.relay.circuit_v2.config.RelayConfig attribute) discovery_stream_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) dns_max_retries (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) dns_resolution_timeout (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) dns_resolver (libp2p.network.swarm.Swarm attribute) DNSResolutionMetrics (class in libp2p.utils.dns_utils) do_px (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) domain() (libp2p.abc.IPeerRecord method) (libp2p.peer.peer_record.PeerRecord method) dont_send_message_ids (libp2p.pubsub.gossipsub.GossipSub attribute) download_bytes (libp2p.perf.PerfOutput attribute) (libp2p.perf.types.PerfOutput attribute) duplicate_dependency_specs (libp2p.observability.oso.models.SecurityProxyMetric attribute) duplicate_packages (libp2p.observability.oso.models.DependencyTopologyMetric attribute) duration (libp2p.relay.circuit_v2.resources.RelayLimits attribute)

E

early_data (libp2p.security.noise.messages.NoiseExtensions attribute) (libp2p.security.noise.patterns.BasePattern attribute) (libp2p.security.noise.transport.Transport attribute) (libp2p.security.tls.TLSTransport attribute) (libp2p.security.tls.transport.TLSTransport attribute) early_data_manager (libp2p.security.noise.transport.Transport attribute) ECC_P256 (libp2p.crypto.keys.KeyType attribute) ECCPrivateKey (class in libp2p.crypto.ecc) ECCPublicKey (class in libp2p.crypto.ecc) ECDSA (libp2p.crypto.keys.KeyType attribute) echo_mode() (in module examples.tls.example_tls_client) eclipse_protection_enabled (libp2p.pubsub.gossipsub.GossipSub attribute) Ed25519 (libp2p.crypto.keys.KeyType attribute) Ed25519PrivateKey (class in libp2p.crypto.ed25519) Ed25519PublicKey (class in libp2p.crypto.ed25519) edges (libp2p.observability.oso.models.DependencyGraph attribute) emit_control_message() (libp2p.pubsub.gossipsub.GossipSub method) emit_extension() (libp2p.pubsub.gossipsub.GossipSub method) emit_graft() (libp2p.pubsub.gossipsub.GossipSub method) emit_idontwant() (libp2p.pubsub.gossipsub.GossipSub method) emit_ihave() (libp2p.pubsub.gossipsub.GossipSub method) emit_iwant() (libp2p.pubsub.gossipsub.GossipSub method) emit_observe() (libp2p.pubsub.gossipsub.GossipSub method) emit_peer_discovered() (libp2p.discovery.events.peerDiscovery.PeerDiscovery method) emit_prune() (libp2p.pubsub.gossipsub.GossipSub method) emit_unobserve() (libp2p.pubsub.gossipsub.GossipSub method) enable_auto_relay (libp2p.relay.circuit_v2.config.ClientConfig attribute) enable_client (libp2p.relay.circuit_v2.config.RelayConfig property) enable_dht_discovery (libp2p.relay.circuit_v2.config.RelayConfig property) enable_draft29 (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) enable_hop (libp2p.relay.circuit_v2.config.RelayConfig property) enable_qlog (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) enable_stop (libp2p.relay.circuit_v2.config.RelayConfig property) ENABLE_STREAM_BATCHING (libp2p.transport.quic.config.QUICTransportConfig attribute) ENABLE_STREAM_KEEP_ALIVE (libp2p.transport.quic.config.QUICTransportConfig attribute) ENABLE_STREAM_METRICS (libp2p.transport.quic.config.QUICTransportConfig attribute) ENABLE_STREAM_RESET_ON_ERROR (libp2p.transport.quic.config.QUICTransportConfig attribute) ENABLE_STREAM_RESOURCE_TRACKING (libp2p.transport.quic.config.QUICTransportConfig attribute) ENABLE_STREAM_TIMELINE_TRACKING (libp2p.transport.quic.config.QUICTransportConfig attribute) enable_v1 (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) encode_delim() (in module libp2p.utils.varint) encode_msg() (libp2p.io.msgio.BaseMsgReadWriter method) (libp2p.io.msgio.FixedSizeLenMsgReadWriter method) (libp2p.io.msgio.VarIntLengthMsgReadWriter method) encode_msg_with_length() (in module libp2p.io.msgio) encode_request() (libp2p.request_response.BytesCodec method) (libp2p.request_response.codec.BytesCodec method) (libp2p.request_response.codec.JSONCodec method) (libp2p.request_response.codec.RequestResponseCodec method) (libp2p.request_response.JSONCodec method) (libp2p.request_response.RequestResponseCodec method) encode_response() (libp2p.request_response.BytesCodec method) (libp2p.request_response.codec.BytesCodec method) (libp2p.request_response.codec.JSONCodec method) (libp2p.request_response.codec.RequestResponseCodec method) (libp2p.request_response.JSONCodec method) (libp2p.request_response.RequestResponseCodec method) encode_signed_key() (in module libp2p.security.tls.certificate) encode_uvarint() (in module libp2p.utils.varint) encode_varint_prefixed() (in module libp2p.utils.varint) encrypt() (libp2p.crypto.authenticated_encryption.MacAndCipher method) (libp2p.io.abc.Encrypter method) (libp2p.security.noise.io.NoiseHandshakeReadWriter method) (libp2p.security.noise.io.NoiseTransportReadWriter method) (libp2p.security.secio.transport.SecioMsgReadWriter method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.TLSReadWriter method) EncryptedMsgReadWriter (class in libp2p.io.abc) Encrypter (class in libp2p.io.abc) EncryptionParameters (class in libp2p.crypto.authenticated_encryption) (class in libp2p.security.secio.transport) ENDPOINT_DEPENDENT (libp2p.host.observed_addr_manager.NATDeviceType attribute) ENDPOINT_INDEPENDENT (libp2p.host.observed_addr_manager.NATDeviceType attribute) ensure_dir_exists() (in module libp2p.utils.paths)

env_to_send_in_RPC() (in module libp2p.peer.peerstore) Envelope (class in libp2p.peer.envelope) envelope (libp2p.peer.peerstore.PeerRecordState attribute) EOL (libp2p.records.ipns.ValidityType attribute) ephemeral_public_key (libp2p.security.secio.transport.EncryptionParameters attribute) equal() (libp2p.abc.IEnvelope method) (libp2p.abc.IPeerRecord method) (libp2p.peer.envelope.Envelope method) (libp2p.peer.peer_record.PeerRecord method) equivocation_detection (libp2p.pubsub.gossipsub.GossipSub attribute) ErrBetterRecord ERROR (libp2p.network.stream.net_stream.StreamState attribute) error_message (libp2p.pubsub.pubsub.ValidationResult attribute) errors (libp2p.transport.websocket.connection.WebSocketStats attribute) event_background_nursery_created (libp2p.network.swarm.Swarm attribute) event_closed (libp2p.network.connection.swarm_connection.SwarmConn attribute) (libp2p.stream_muxer.mplex.mplex.Mplex attribute) event_handle_dead_peer_queue_started (libp2p.pubsub.pubsub.Pubsub attribute) event_handle_peer_queue_started (libp2p.pubsub.pubsub.Pubsub attribute) event_local_closed (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) event_remote_closed (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) event_reset (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) event_shutting_down (libp2p.stream_muxer.mplex.mplex.Mplex attribute) event_started (libp2p.abc.IMuxedConn attribute) (libp2p.abc.INetConn attribute) (libp2p.stream_muxer.mplex.mplex.Mplex attribute) examples.autotls module examples.autotls.autotls module examples.cid module examples.cid.cid_usage module examples.nat module examples.nat.dialer module examples.nat.listener module examples.nat.relay module examples.path_handling module examples.path_handling.path_handling module examples.path_handling.path_handling_demo module examples.tcp module examples.tcp.test_tcp_data_transfer module examples.tls module examples.tls.example_tls_client module examples.tls.example_tls_server module examples.transport module examples.transport.transport_integration_demo module Exchange (class in libp2p.security.insecure.pb.plaintext_pb2) (class in libp2p.security.secio.pb.spipe_pb2) exchanges (libp2p.security.secio.transport.Proposal attribute) expand_wildcard_address() (in module libp2p.utils.address_validation) expiration (libp2p.relay.circuit_v2.resources.ReservationVoucher attribute) EXPIRED (libp2p.relay.circuit_v2.resources.ReservationStatus attribute) export_metrics() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) exported_metric_names (libp2p.observability.oso.models.RcmgrSnapshot attribute) extensions (libp2p.security.noise.messages.NoiseHandshakePayload attribute) extensions_state (libp2p.pubsub.gossipsub.GossipSub attribute) external_api() (in module libp2p.tools.anyio_service) (in module libp2p.tools.anyio_service.api) extract_host_from_multiaddr() (in module libp2p.utils.multiaddr_utils) extract_ip_from_multiaddr() (in module libp2p.utils.multiaddr_utils) extract_public_key() (libp2p.peer.id.ID method) extract_thin_waist() (in module libp2p.host.observed_addr_manager)

F

failure_count (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) (libp2p.utils.dns_utils.DNSResolutionMetrics attribute) fanout (libp2p.abc.IPubsubRouter attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) fanout_heartbeat() (libp2p.pubsub.gossipsub.GossipSub method) fetch_commits() (libp2p.observability.oso.providers.GitHubProvider method) fetch_issues() (libp2p.observability.oso.providers.GitHubProvider method) fetch_popularity() (libp2p.observability.oso.providers.GitHubProvider method) fetch_releases() (libp2p.observability.oso.providers.GitHubProvider method) filecoin_message_id() (in module libp2p.filecoin) (in module libp2p.filecoin.constants) FilecoinAddress (class in libp2p.filecoin) FilecoinNetworkPreset (class in libp2p.filecoin) (class in libp2p.filecoin.networks) filter_bootstrap_for_transport() (in module libp2p.filecoin) (in module libp2p.filecoin.bootstrap) find_all_peers() (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousDiscovery method) find_bucket() (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) find_closest_peers_network() (libp2p.kad_dht.peer_routing.PeerRouting method) (libp2p.kad_dht.PeerRouting method) find_executable() (in module libp2p.utils.paths) find_free_port() (in module libp2p.utils.address_validation) find_local_closest_peers() (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) find_peer() (libp2p.abc.IPeerRouting method) (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.kad_dht.peer_routing.PeerRouting method) (libp2p.kad_dht.PeerRouting method) find_peers() (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousDiscovery method)

find_provider_iter() (libp2p.abc.IContentRouting method) find_providers() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.kad_dht.provider_store.ProviderStore method) finished_count (libp2p.tools.anyio_service.stats.TaskStats attribute) (libp2p.tools.anyio_service.TaskStats attribute) first_response_at (libp2p.observability.oso.providers.IssueInfo attribute) first_seen (libp2p.network.TagInfo attribute) first_supported_protocol() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) FirstSeenCache (class in libp2p.tools.timed_cache.first_seen_cache) FixedSizeLenMsgReadWriter (class in libp2p.io.msgio) FloodSub (class in libp2p.pubsub.floodsub) flush_pending_messages() (libp2p.pubsub.gossipsub.GossipSub method) forks (libp2p.observability.oso.models.PopularityMetric attribute) (libp2p.observability.oso.providers.PopularityInfo attribute) format_host_for_url() (in module libp2p.utils.multiaddr_utils) from_base58() (libp2p.peer.id.ID class method) from_bytes() (libp2p.crypto.ecc.ECCPublicKey class method) (libp2p.crypto.ed25519.Ed25519PrivateKey class method) (libp2p.crypto.ed25519.Ed25519PublicKey class method) (libp2p.crypto.rsa.RSAPublicKey class method) (libp2p.crypto.secp256k1.Secp256k1PrivateKey class method) (libp2p.crypto.secp256k1.Secp256k1PublicKey class method) from_multibase() (libp2p.peer.id.ID class method) from_protobuf() (libp2p.security.noise.messages.NoiseExtensions class method) from_pubkey() (libp2p.peer.id.ID class method) from_string() (libp2p.peer.id.ID class method) (libp2p.rcmgr.Direction class method) (libp2p.rcmgr.metrics.Direction class method) FunctionTask (class in libp2p.tools.anyio_service.tasks)

G

generate_certificate() (in module libp2p.security.tls) (in module libp2p.security.tls.certificate) (libp2p.transport.quic.security.CertificateGenerator method) generate_direct_graph_artifacts() (in module libp2p.observability.oso) (in module libp2p.observability.oso.generators) generate_fixed_private_key() (in module examples.nat.dialer) (in module examples.nat.listener) (in module examples.nat.relay) generate_id() (libp2p.pubsub.pubsub.ContentAddressedMessageIDGenerator method) (libp2p.pubsub.pubsub.CustomMessageIDGenerator method) (libp2p.pubsub.pubsub.MessageIDGenerator method) (libp2p.pubsub.pubsub.PeerAndSeqnoMessageIDGenerator method) generate_new_ed25519_identity() (in module libp2p) generate_new_rsa_identity() (in module libp2p) generate_peer_id_from() (in module libp2p) generate_proto() (in module libp2p.host.autonat.pb.generate_proto) generate_random_peer_id() (libp2p.discovery.random_walk.random_walk.RandomWalk method) (libp2p.discovery.random_walk.RandomWalk method) generate_self_signed_cert() (in module libp2p.security.tls.certificate) generate_transitive_graph_artifacts() (in module libp2p.observability.oso) (in module libp2p.observability.oso.transitive_graph) generated_at (libp2p.observability.oso.HealthReport attribute) (libp2p.observability.oso.models.HealthReport attribute) GenericMultistreamSelector (class in libp2p.protocol_muxer) genesis_network_name (libp2p.filecoin.FilecoinNetworkPreset attribute) (libp2p.filecoin.networks.FilecoinNetworkPreset attribute) get() (libp2p.abc.IPeerMetadata method) (libp2p.abc.IPeerStore method) (libp2p.abc.ISubscriptionAPI method) (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method) (libp2p.peer.peerstore.PeerStore method) (libp2p.pubsub.mcache.MessageCache method) (libp2p.pubsub.pubsub.ValidationCache method) (libp2p.pubsub.subscription.TrioSubscriptionAPI method) get_active_connections() (libp2p.transport.websocket.manager.WebSocketConnectionManager method) get_active_streams() (libp2p.transport.quic.connection.QUICConnection method) get_addresses() (libp2p.transport.quic.listener.QUICListener method) get_addrs() (libp2p.abc.IHost method) (libp2p.abc.IListener method) (libp2p.abc.IPeerData method) (libp2p.host.basic_host.BasicHost method) (libp2p.peer.peerdata.PeerData method) (libp2p.relay.circuit_v2.transport.CircuitV2Listener method) (libp2p.transport.quic.listener.QUICListener method) (libp2p.transport.tcp.tcp.TCPListener method) (libp2p.transport.websocket.listener.WebsocketListener method) (libp2p.transport.websocket.WebsocketListener method) get_agent_version() (in module libp2p.utils.version) get_all_cids() (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) get_all_peers() (libp2p.network.TagStore method) get_all_relay_stats() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) get_allowed_multiaddrs() (libp2p.rcmgr.allowlist.Allowlist method) get_allowed_peers() (libp2p.rcmgr.allowlist.Allowlist method) get_alpn_protocols() (in module libp2p.transport.quic.utils) get_autonat_status_string() (in module examples.nat.dialer) (in module examples.nat.listener) get_available_interfaces() (in module libp2p.utils.address_validation) get_binary_path() (in module libp2p.utils.paths) get_blacklisted_peers() (libp2p.pubsub.pubsub.Pubsub method) get_block() (libp2p.bitswap.BitswapClient method) (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) get_bootstrap_addresses() (in module libp2p.filecoin) (in module libp2p.filecoin.bootstrap) get_cached_static_key() (libp2p.security.noise.transport.Transport method) get_certificate_der() (libp2p.transport.quic.security.TLSConfig method) get_certificate_info() (libp2p.transport.quic.security.QUICTLSSecurityConfig method) get_certificate_pem() (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) (libp2p.transport.quic.security.TLSConfig method) get_config_dir() (in module libp2p.utils.paths) get_connected_peers() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_connection() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) (libp2p.transport.websocket.manager.WebSocketConnectionManager method) get_connection_id_stats() (libp2p.transport.quic.connection.QUICConnection method) get_connection_stats() (libp2p.transport.websocket.manager.WebSocketConnectionManager method) get_connection_type() (libp2p.abc.IMuxedConn method) (libp2p.abc.INetConn method) (libp2p.abc.IRawConnection method) (libp2p.io.abc.EncryptedMsgReadWriter method) (libp2p.network.connection.raw_connection.RawConnection method) (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.relay.circuit_v2.transport.TrackedRawConnection method) (libp2p.security.insecure.transport.InsecureSession method) (libp2p.security.secure_session.SecureSession method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method) get_connections() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) get_connections_map() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) get_content_addressed_msg_id() (in module libp2p.pubsub.pubsub) get_counter() (libp2p.rcmgr.metrics.Metrics method) get_current_connection_id() (libp2p.transport.quic.connection.QUICConnection method) get_data_to_sign() (libp2p.relay.circuit_v2.resources.Reservation method) get_default_dns_metrics() (in module libp2p.utils.dns_utils) get_default_muxer() (in module libp2p) get_default_muxer_options() (in module libp2p) get_default_protocols() (in module libp2p.host.defaults) get_early_data() (libp2p.security.noise.messages.NoiseHandshakePayload method) get_external_ip() (libp2p.discovery.upnp.upnp.UpnpManager method) get_gauge() (libp2p.rcmgr.metrics.Metrics method) get_hello_packet() (libp2p.pubsub.pubsub.Pubsub method) get_id() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_installed_package_versions() (in module libp2p.observability.oso.providers) get_installed_packages() (in module libp2p.observability.oso.transitive_graph) get_ip_protocol_from_multiaddr() (in module libp2p.utils.multiaddr_utils) get_keys() (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method) get_last_identified() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) get_listener_socket() (libp2p.transport.quic.transport.QUICTransport method) get_listeners() (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) get_live_peers() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_local_peer() (libp2p.abc.AbstractSecureConn method) (libp2p.security.base_session.BaseSession method) get_local_peer_id() (libp2p.transport.quic.security.QUICTLSConfigManager method) get_local_private_key() (libp2p.abc.AbstractSecureConn method) (libp2p.security.base_session.BaseSession method) get_local_record() (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) get_manager() (libp2p.tools.anyio_service.api.Service method) (libp2p.tools.anyio_service.api.ServiceAPI method) (libp2p.tools.anyio_service.Service method) get_manager_stats() (libp2p.transport.websocket.manager.WebSocketConnectionManager method) get_message_id() (libp2p.pubsub.pubsub.Pubsub method) get_metadata() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) get_metrics() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) get_msg_validators() (libp2p.pubsub.pubsub.Pubsub method) get_mux() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_namespace_stats() (libp2p.discovery.rendezvous.RendezvousService method) (libp2p.discovery.rendezvous.service.RendezvousService method) get_nat_type() (libp2p.host.basic_host.BasicHost method) (libp2p.host.observed_addr_manager.ObservedAddrManager method) get_negotiated_muxer() (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) get_negotiated_protocol() (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.security.tls.TLSReadWriter method) get_network() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_network_preset() (in module libp2p.filecoin) (in module libp2p.filecoin.networks) get_nonce() (libp2p.security.secio.transport.Transport method) get_oldest_peer() (libp2p.kad_dht.routing_table.KBucket method) get_optimal_binding_address() (in module libp2p.utils.address_validation) get_package_dependencies() (in module libp2p.observability.oso.transitive_graph) get_pattern() (libp2p.security.noise.transport.Transport method) get_peer_and_seqno_msg_id() (in module libp2p.pubsub.pubsub) get_peer_certificate() (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.security.tls.TLSReadWriter method) (libp2p.transport.quic.connection.QUICConnection method) get_peer_connection_info() (libp2p.host.basic_host.BasicHost method) get_peer_id() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method)

get_peer_ids() (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) get_peer_info() (libp2p.kad_dht.routing_table.KBucket method) (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) get_peer_infos() (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) get_peer_record() (libp2p.abc.ICertifiedAddrBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) get_peerstore() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_preferred_muxers() (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) get_private_key() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_private_key_der() (libp2p.transport.quic.security.TLSConfig method) get_private_key_pem() (libp2p.transport.quic.security.TLSConfig method) get_privkey() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) get_project_root() (in module libp2p.utils.paths) get_protected_peers() (libp2p.network.TagStore method) get_protocol() (libp2p.abc.INetStream method) (libp2p.network.stream.net_stream.NetStream method) get_protocol_id() (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) get_protocol_layers() (in module libp2p.utils.multiaddr_utils) get_protocols() (libp2p.abc.IMultiselectMuxer method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.abc.IPubsubRouter method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) (libp2p.protocol_muxer.GenericMultistreamSelector method) (libp2p.protocol_muxer.multiselect.Multiselect method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) get_provided_keys() (libp2p.kad_dht.provider_store.ProviderStore method) get_providers() (libp2p.kad_dht.provider_store.ProviderStore method) get_proxy_from_environment() (in module libp2p.transport.websocket.proxy_env) get_proxy_info() (libp2p.transport.websocket.proxy.SOCKSConnectionManager method) get_pubkey() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) get_public_key() (libp2p.abc.IHost method) (libp2p.crypto.ecc.ECCPrivateKey method) (libp2p.crypto.ed25519.Ed25519PrivateKey method) (libp2p.crypto.keys.PrivateKey method) (libp2p.crypto.rsa.RSAPrivateKey method) (libp2p.crypto.secp256k1.Secp256k1PrivateKey method) (libp2p.host.basic_host.BasicHost method) get_python_executable() (in module libp2p.utils.paths) get_relay() (libp2p.relay.circuit_v2.discovery.RelayDiscovery method) get_relay_info() (libp2p.relay.circuit_v2.discovery.RelayDiscovery method) get_relay_score() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) get_relay_stats() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) get_relays() (libp2p.relay.circuit_v2.discovery.RelayDiscovery method) get_remote_address() (libp2p.io.abc.EncryptedMsgReadWriter method) (libp2p.io.abc.ReadWriteCloser method) (libp2p.io.trio.TrioTCPStream method) (libp2p.network.connection.raw_connection.RawConnection method) (libp2p.network.stream.net_stream.NetStream method) (libp2p.relay.circuit_v2.transport.TrackedRawConnection method) (libp2p.security.insecure.transport.InsecureSession method) (libp2p.security.noise.io.BaseNoiseMsgReadWriter method) (libp2p.security.pnet.psk_conn.PskConn method) (libp2p.security.secure_session.SecureSession method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.security.tls.TLSReadWriter method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method) (libp2p.transport.quic.stream.QUICStream method) (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.P2PWebSocketConnection method) get_remote_peer() (libp2p.abc.AbstractSecureConn method) (libp2p.security.base_session.BaseSession method) get_remote_peer_id() (libp2p.relay.circuit_v2.protocol.INetStreamWithExtras method) get_remote_public_key() (libp2p.abc.AbstractSecureConn method) (libp2p.security.base_session.BaseSession method) get_routing_table_size() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) get_runtime_bootstrap_addresses() (in module libp2p.filecoin) (in module libp2p.filecoin.bootstrap) get_script_binary_path() (in module libp2p.utils.paths) get_script_dir() (in module libp2p.utils.paths) get_secure_msg_id() (in module libp2p.pubsub.pubsub) get_security_info() (libp2p.transport.quic.connection.QUICConnection method) get_security_manager() (libp2p.transport.quic.connection.QUICConnection method) (libp2p.transport.quic.transport.QUICTransport method) get_stale_peers() (libp2p.kad_dht.routing_table.KBucket method) (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) get_stats() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) (libp2p.transport.quic.listener.QUICListener method) (libp2p.transport.quic.transport.QUICTransport method) (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.listener.WebsocketListener method) (libp2p.transport.websocket.P2PWebSocketConnection method) (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketListener method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) get_status() (libp2p.host.autonat.autonat.AutoNATService method) get_stream_config_dict() (libp2p.transport.quic.config.QUICTransportConfig method) get_stream_stats() (libp2p.transport.quic.connection.QUICConnection method) get_streams() (libp2p.abc.INetConn method) (libp2p.network.connection.swarm_connection.SwarmConn method) get_streams_by_protocol() (libp2p.transport.quic.connection.QUICConnection method) get_summary() (libp2p.rcmgr.metrics.Metrics method) get_supported_protocols() (libp2p.transport.TransportRegistry method) get_supported_transport_protocols() (in module libp2p.transport) get_tag() (libp2p.network.TagStore method) get_tag_info() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) (libp2p.network.TagStore method) get_tag_value() (libp2p.network.TagStore method) get_task_name() (in module libp2p.tools.anyio_service) (in module libp2p.tools.anyio_service.utils) get_temp_dir() (in module libp2p.utils.paths) get_timestamp_msg_id() (in module libp2p.pubsub.pubsub) get_topic_aware_msg_id() (in module libp2p.pubsub.pubsub) get_total_connections() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) get_total_value() (libp2p.network.TagInfo method) get_transport() (libp2p.transport.TransportRegistry method) get_transport_addresses() (libp2p.abc.IMuxedConn method) (libp2p.abc.INetConn method) (libp2p.abc.IRawConnection method) (libp2p.io.abc.EncryptedMsgReadWriter method) (libp2p.network.connection.raw_connection.RawConnection method) (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.relay.circuit_v2.transport.TrackedRawConnection method) (libp2p.security.insecure.transport.InsecureSession method) (libp2p.security.secure_session.SecureSession method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method) get_transport_addrs() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) get_transport_registry() (in module libp2p.transport) get_ttl() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) get_type() (libp2p.crypto.ecc.ECCPrivateKey method) (libp2p.crypto.ecc.ECCPublicKey method) (libp2p.crypto.ed25519.Ed25519PrivateKey method) (libp2p.crypto.ed25519.Ed25519PublicKey method) (libp2p.crypto.keys.Key method) (libp2p.crypto.rsa.RSAPrivateKey method) (libp2p.crypto.rsa.RSAPublicKey method) (libp2p.crypto.secp256k1.Secp256k1PrivateKey method) (libp2p.crypto.secp256k1.Secp256k1PublicKey method) get_valid_peers() (libp2p.discovery.rendezvous.discovery.PeerCache method) get_value() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) get_value_store_size() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) get_venv_path() (in module libp2p.utils.paths) get_wildcard_address() (in module libp2p.utils.address_validation) github (libp2p.observability.oso.models.SourceStatus attribute) GitHubProvider (class in libp2p.observability.oso.providers) gossip_factor (libp2p.pubsub.gossipsub.GossipSub attribute) gossip_heartbeat() (libp2p.pubsub.gossipsub.GossipSub method) gossip_history (libp2p.tools.constants.GossipsubParams attribute) gossip_window (libp2p.tools.constants.GossipsubParams attribute) GossipSub (class in libp2p.pubsub.gossipsub) GossipsubParams (class in libp2p.tools.constants)

H

handle_data_received() (libp2p.transport.quic.stream.QUICStream method) handle_dead_peer_queue() (libp2p.pubsub.pubsub.Pubsub method) handle_example_protocol() (in module examples.nat.listener) (in module examples.nat.relay) handle_flow_control_update() (libp2p.transport.quic.stream.QUICStream method) handle_graft() (libp2p.pubsub.gossipsub.GossipSub method) handle_idontwant() (libp2p.pubsub.gossipsub.GossipSub method) handle_ihave() (libp2p.pubsub.gossipsub.GossipSub method) handle_incoming() (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.yamux.Yamux method) handle_incoming_connection() (libp2p.relay.circuit_v2.protocol.CircuitV2Protocol method) (libp2p.relay.circuit_v2.transport.CircuitV2Listener method) handle_iwant() (libp2p.pubsub.gossipsub.GossipSub method) handle_observe() (libp2p.pubsub.gossipsub.GossipSub method) handle_peer_queue() (libp2p.pubsub.pubsub.Pubsub method) handle_ping() (in module examples.autotls.autotls) (in module libp2p.host.ping) handle_prune() (libp2p.pubsub.gossipsub.GossipSub method) handle_reset() (libp2p.transport.quic.stream.QUICStream method) handle_rpc() (libp2p.abc.IPubsubRouter method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) handle_sending_messages() (libp2p.pubsub.pubsub.Pubsub method) handle_stop_sending() (libp2p.transport.quic.stream.QUICStream method) handle_stream() (libp2p.host.autonat.autonat.AutoNATService method) (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) handle_subscription() (libp2p.pubsub.pubsub.Pubsub method) handle_unobserve() (libp2p.pubsub.gossipsub.GossipSub method) handlers (libp2p.abc.IMultiselectMuxer attribute) (libp2p.protocol_muxer.GenericMultistreamSelector attribute) (libp2p.protocol_muxer.multiselect.Multiselect attribute) handshake() (libp2p.abc.IMultiselectClient method) (libp2p.protocol_muxer.multiselect.Multiselect method) (libp2p.protocol_muxer.multiselect_client.MultiselectClient method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.security.tls.TLSReadWriter method) handshake_inbound() (libp2p.security.noise.patterns.IPattern method) (libp2p.security.noise.patterns.PatternXX method) handshake_outbound() (libp2p.security.noise.patterns.IPattern method) (libp2p.security.noise.patterns.PatternXX method) handshake_timeout (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute)

HandshakeFailure HandshakeHasNotFinished has() (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method) (libp2p.tools.timed_cache.base_timed_cache.BaseTimedCache method) (libp2p.tools.timed_cache.first_seen_cache.FirstSeenCache method) (libp2p.tools.timed_cache.last_seen_cache.LastSeenCache method) has_anyio_task (libp2p.tools.anyio_service.tasks.FunctionTask property) has_block() (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) has_consistent_transport() (in module libp2p.host.observed_addr_manager) has_early_data() (libp2p.security.noise.messages.NoiseExtensions method) (libp2p.security.noise.messages.NoiseHandshakePayload method) has_extensions() (libp2p.security.noise.messages.NoiseHandshakePayload method) has_libp2p_extension() (libp2p.transport.quic.security.QUICTLSSecurityConfig method) has_peer() (libp2p.kad_dht.routing_table.KBucket method) has_reservation (libp2p.relay.circuit_v2.discovery.RelayInfo attribute) has_reservation() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) has_stream_muxers() (libp2p.security.noise.messages.NoiseExtensions method) has_v1_fields (libp2p.records.ipns.ParsedIPNSRecord attribute) has_webtransport_certhashes() (libp2p.security.noise.messages.NoiseExtensions method) hash_type (libp2p.crypto.authenticated_encryption.EncryptionParameters attribute) (libp2p.security.secio.transport.EncryptionParameters attribute) hashes (libp2p.security.secio.transport.Proposal attribute) have_block() (libp2p.bitswap.BitswapClient method) HeaderTags (class in libp2p.stream_muxer.mplex.constants) HealthMetrics (class in libp2p.observability.oso.models) HealthReport (class in libp2p.observability.oso) (class in libp2p.observability.oso.models) heartbeat() (libp2p.pubsub.gossipsub.GossipSub method) heartbeat_initial_delay (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) heartbeat_interval (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) high_watermark (libp2p.security.secure_session.SecureSession attribute) history (libp2p.pubsub.mcache.MessageCache attribute) history_size (libp2p.pubsub.mcache.MessageCache attribute) HOP (libp2p.relay.circuit_v2.config.RelayRole attribute) HopConfig (class in libp2p.relay.circuit_v2.config) HopMessage (class in libp2p.relay.circuit_v2.pb.circuit_pb2) host (libp2p.perf.PerfComponents attribute) (libp2p.perf.types.PerfComponents attribute) (libp2p.pubsub.pubsub.Pubsub attribute) HostException

I

IAddrBook (class in libp2p.abc) ICertifiedAddrBook (class in libp2p.abc) IContentRouting (class in libp2p.abc) ID (class in libp2p.peer.id) id_pubkey (libp2p.security.noise.messages.NoiseHandshakePayload attribute) id_sig (libp2p.security.noise.messages.NoiseHandshakePayload attribute) Identify (class in libp2p.identity.identify.pb.identify_pb2) identify_handler_for() (in module libp2p.identity.identify) (in module libp2p.identity.identify.identify) identify_push_handler_for() (in module libp2p.identity.identify_push) (in module libp2p.identity.identify_push.identify_push) IdentityConfig (class in libp2p.security.tls) (class in libp2p.security.tls.transport) IdentityHash (class in libp2p.peer.id) idle_timeout (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) IEnvelope (class in libp2p.abc) IHost (class in libp2p.abc) IHostWithMultiselect (class in libp2p.relay.circuit_v2.discovery) IKeyBook (class in libp2p.abc) IListener (class in libp2p.abc) IMetrics (class in libp2p.abc) IMultiselectClient (class in libp2p.abc) IMultiselectCommunicator (class in libp2p.abc) IMultiselectMuxer (class in libp2p.abc) IMuxedConn (class in libp2p.abc) IMuxedStream (class in libp2p.abc) INBOUND (libp2p.rcmgr.Direction attribute) (libp2p.rcmgr.metrics.Direction attribute) (libp2p.transport.quic.stream.StreamDirection attribute) incoming_data_channel (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) IncompatibleChoices IncompleteReadError InconsistentNonce increment() (libp2p.rcmgr.metrics.Metrics method) INetConn (class in libp2p.abc) INetStream (class in libp2p.abc) INetStreamWithExtras (class in libp2p.relay.circuit_v2.protocol) INetwork (class in libp2p.abc) INetworkService (class in libp2p.abc) infer_local_type() (in module libp2p.crypto.ecc) info_from_p2p_addr() (in module libp2p.peer.peerinfo) INIT (libp2p.network.stream.net_stream.StreamState attribute) initialize_pair() (in module libp2p.crypto.authenticated_encryption) initiate_autotls_procedure() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) initiator_peers_queue (libp2p.pubsub.pubsub_notifee.PubsubNotifee attribute) INotifee (class in libp2p.abc) InsecureSession (class in libp2p.security.insecure.transport) InsecureTransport (class in libp2p.security.insecure.transport) INTERNAL_SERVICE_RUN (libp2p.tools.anyio_service.tasks.TaskType attribute) (libp2p.tools.anyio_service.TaskType attribute) InternalError InternalManagerAPI (class in libp2p.tools.anyio_service.api) InvalidAddrError InvalidBlockError InvalidCIDError InvalidCookieError InvalidMACException InvalidNamespaceError InvalidPeerInfoError InvalidRecordType InvalidResourceManagerState InvalidSignature InvalidSignatureOnExchange InvalidTTLError IOException IPattern (class in libp2p.security.noise.patterns) IPeerData (class in libp2p.abc) IPeerMetadata (class in libp2p.abc) IPeerRecord (class in libp2p.abc) IPeerRouting (class in libp2p.abc) IPeerStore (class in libp2p.abc) IPerf (class in libp2p.abc) (class in libp2p.perf) IPFSTimestamp (class in libp2p.bitswap.pb.unixfs_pb2) IpnsEntry (class in libp2p.records.pb) IPNSValidator (class in libp2p.records.ipns) IProtoBook (class in libp2p.abc) IPubsub (class in libp2p.abc) IPubsubRouter (class in libp2p.abc) IRawConnection (class in libp2p.abc) is_async (libp2p.pubsub.pubsub.TopicValidator attribute) is_cancelled (libp2p.tools.anyio_service.AnyIOManager property) (libp2p.tools.anyio_service.api.ManagerAPI property) (libp2p.tools.anyio_service.context.AnyIOManager property) (libp2p.tools.anyio_service.context.TrioManager property) (libp2p.tools.anyio_service.manager.AnyIOManager property) is_certificate_valid() (libp2p.transport.quic.security.QUICTLSSecurityConfig method) is_clean_close (libp2p.io.exceptions.IncompleteReadError property) is_client_config (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) is_closed (libp2p.abc.IMuxedConn property) (libp2p.abc.INetConn property) (libp2p.network.connection.swarm_connection.SwarmConn property) (libp2p.stream_muxer.mplex.mplex.Mplex property) (libp2p.stream_muxer.yamux.Yamux property) (libp2p.transport.quic.connection.QUICConnection property) (libp2p.transport.websocket.listener.WebsocketListener property) (libp2p.transport.websocket.WebsocketListener property)

is_closed() (libp2p.relay.circuit_v2.protocol.INetStreamWithExtras method) (libp2p.transport.quic.stream.QUICStream method) (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.P2PWebSocketConnection method) is_connection_direct() (in module examples.nat.dialer) is_delegated (libp2p.filecoin.FilecoinAddress property) is_dns_addr() (libp2p.discovery.bootstrap.BootstrapDiscovery method) is_done (libp2p.tools.anyio_service.tasks.ChildServiceTask property) (libp2p.tools.anyio_service.tasks.FunctionTask property) (libp2p.tools.anyio_service.tasks.TaskAPI property) is_empty() (libp2p.rcmgr.allowlist.Allowlist method) (libp2p.security.noise.messages.NoiseExtensions method) is_established (libp2p.abc.IMuxedConn property) (libp2p.stream_muxer.mplex.mplex.Mplex property) (libp2p.stream_muxer.yamux.Yamux property) (libp2p.transport.quic.connection.QUICConnection property) is_expired() (libp2p.abc.IPeerData method) (libp2p.discovery.rendezvous.service.RegistrationRecord method) (libp2p.kad_dht.provider_store.ProviderRecord method) (libp2p.peer.peerdata.PeerData method) (libp2p.relay.circuit_v2.resources.Reservation method) is_finished (libp2p.tools.anyio_service.AnyIOManager property) (libp2p.tools.anyio_service.api.ManagerAPI property) (libp2p.tools.anyio_service.context.AnyIOManager property) (libp2p.tools.anyio_service.context.TrioManager property) (libp2p.tools.anyio_service.manager.AnyIOManager property) is_initiator (libp2p.abc.IMuxedConn property) (libp2p.abc.IRawConnection attribute) (libp2p.network.connection.raw_connection.RawConnection attribute) (libp2p.stream_muxer.mplex.datastructures.StreamID attribute) (libp2p.stream_muxer.mplex.mplex.Mplex property) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream property) (libp2p.stream_muxer.yamux.Yamux property) (libp2p.transport.quic.connection.QUICConnection property) (libp2p.transport.quic.stream.QUICStream property) is_listening() (libp2p.transport.quic.listener.QUICListener method) is_open() (libp2p.relay.circuit_v2.protocol.INetStreamWithExtras method) is_operational() (libp2p.network.stream.net_stream.NetStream method) is_peer_blacklisted() (libp2p.pubsub.pubsub.Pubsub method) is_peer_connected() (libp2p.host.basic_host.BasicHost method) is_peer_verified (libp2p.transport.quic.connection.QUICConnection property) is_protected() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) (libp2p.network.TagStore method) is_quic_multiaddr() (in module libp2p.transport.quic.utils) is_random_walk_enabled() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) is_reset() (libp2p.transport.quic.stream.QUICStream method) is_resource_available() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) is_running (libp2p.tools.anyio_service.AnyIOManager property) (libp2p.tools.anyio_service.api.ManagerAPI property) (libp2p.tools.anyio_service.context.AnyIOManager property) (libp2p.tools.anyio_service.context.TrioManager property) (libp2p.tools.anyio_service.manager.AnyIOManager property) is_secure (libp2p.transport.websocket.connection.WebSocketStats attribute) is_started (libp2p.tools.anyio_service.AnyIOManager property) (libp2p.tools.anyio_service.api.ManagerAPI property) (libp2p.tools.anyio_service.context.AnyIOManager property) (libp2p.tools.anyio_service.context.TrioManager property) (libp2p.tools.anyio_service.manager.AnyIOManager property) (libp2p.transport.quic.connection.QUICConnection property) is_started() (libp2p.abc.IPerf method) (libp2p.perf.IPerf method) (libp2p.perf.perf_service.PerfService method) (libp2p.perf.PerfService method) is_testnet (libp2p.filecoin.FilecoinAddress attribute) is_valid (libp2p.pubsub.pubsub.ValidationResult attribute) is_valid_address() (in module libp2p.filecoin) is_valid_handshake() (in module libp2p.protocol_muxer.multiselect) (in module libp2p.protocol_muxer.multiselect_client) is_valid_observation() (in module libp2p.host.observed_addr_manager) is_valid_timestamp() (in module libp2p.kad_dht.kad_dht) is_valid_websocket_multiaddr() (in module libp2p.transport.websocket.multiaddr_utils) is_verbose_logging_enabled() (in module libp2p.tools.anyio_service) (in module libp2p.tools.anyio_service.utils) is_wss (libp2p.transport.websocket.multiaddr_utils.ParsedWebSocketMultiaddr attribute) ISecureConn (class in libp2p.abc) ISecureTransport (class in libp2p.abc) issue_and_cache_local_record() (in module libp2p.peer.peerstore) issue_responsiveness (libp2p.observability.oso.models.HealthMetrics attribute) IssueInfo (class in libp2p.observability.oso.providers) IssueResponsivenessMetric (class in libp2p.observability.oso.models) issues_considered (libp2p.observability.oso.models.IssueResponsivenessMetric attribute) ISubscriptionAPI (class in libp2p.abc) iterate_tasks() (libp2p.tools.anyio_service.tasks.FunctionTask class method) ITransport (class in libp2p.abc) iv (libp2p.crypto.authenticated_encryption.EncryptionParameters attribute)

J

join() (libp2p.abc.IPubsubRouter method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method)

join_multiaddrs() (in module libp2p.utils.multiaddr_utils) join_paths() (in module libp2p.utils.paths) JSONCodec (class in libp2p.request_response) (class in libp2p.request_response.codec)

K

KadDHT (class in libp2p.kad_dht) (class in libp2p.kad_dht.kad_dht) KBucket (class in libp2p.kad_dht.routing_table) KEEP_ALIVE (libp2p.network.CommonTags attribute) Key (class in libp2p.crypto.keys)

key_in_range() (libp2p.kad_dht.routing_table.KBucket method) key_log_writer (libp2p.security.tls.IdentityConfig attribute) (libp2p.security.tls.transport.IdentityConfig attribute) key_to_int() (in module libp2p.kad_dht.routing_table) KeyPair (class in libp2p.crypto.keys) KeyType (class in libp2p.crypto.keys)

L

last_activity (libp2p.transport.websocket.connection.WebSocketStats attribute) last_error (libp2p.transport.websocket.connection.WebSocketStats attribute) last_health_update (libp2p.pubsub.gossipsub.GossipSub attribute) last_identified (libp2p.peer.peerdata.PeerData attribute) last_release_at (libp2p.observability.oso.models.ReleaseCadenceMetric attribute) last_seen (libp2p.relay.circuit_v2.discovery.RelayInfo attribute) last_updated (libp2p.rcmgr.metrics.ResourceMetrics attribute) (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) LastSeenCache (class in libp2p.tools.timed_cache.last_seen_cache) latency_ema_ms (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) latency_EWMA() (libp2p.abc.IMetrics method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) latmap (libp2p.peer.peerdata.PeerData attribute) leave() (libp2p.abc.IPubsubRouter method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) length() (libp2p.tools.timed_cache.base_timed_cache.BaseTimedCache method) libp2p module libp2p.abc module libp2p.bitswap.config module libp2p.bitswap.errors module libp2p.bitswap.pb module libp2p.bitswap.pb.bitswap_pb2 module libp2p.bitswap.pb.dag_pb_pb2 module libp2p.bitswap.pb.unixfs_pb2 module libp2p.crypto module libp2p.crypto.authenticated_encryption module libp2p.crypto.ecc module libp2p.crypto.ed25519 module libp2p.crypto.exceptions module libp2p.crypto.key_exchange module libp2p.crypto.keys module libp2p.crypto.rsa module libp2p.crypto.secp256k1 module libp2p.crypto.serialization module libp2p.custom_types module libp2p.discovery module libp2p.discovery.bootstrap module libp2p.discovery.events module libp2p.discovery.events.peerDiscovery module libp2p.discovery.mdns module libp2p.discovery.mdns.broadcaster module libp2p.discovery.mdns.listener module libp2p.discovery.mdns.mdns module libp2p.discovery.mdns.utils module libp2p.discovery.random_walk module libp2p.discovery.random_walk.config module libp2p.discovery.random_walk.exceptions module libp2p.discovery.random_walk.random_walk module libp2p.discovery.random_walk.rt_refresh_manager module libp2p.discovery.rendezvous module libp2p.discovery.rendezvous.client module libp2p.discovery.rendezvous.config module libp2p.discovery.rendezvous.discovery module libp2p.discovery.rendezvous.messages module libp2p.discovery.rendezvous.pb module libp2p.discovery.rendezvous.pb.rendezvous_pb2 module libp2p.discovery.rendezvous.service module libp2p.discovery.upnp module libp2p.discovery.upnp.upnp module libp2p.exceptions module libp2p.filecoin module libp2p.filecoin.bootstrap module libp2p.filecoin.cli module libp2p.filecoin.constants module libp2p.filecoin.networks module libp2p.filecoin.pubsub module libp2p.host module libp2p.host.autonat.autonat module libp2p.host.autonat.pb module libp2p.host.autonat.pb.autonat_pb2 module libp2p.host.autonat.pb.autonat_pb2_grpc module libp2p.host.autonat.pb.generate_proto module libp2p.host.basic_host module libp2p.host.defaults module libp2p.host.exceptions module libp2p.host.observed_addr_manager module libp2p.host.ping module libp2p.host.routed_host module libp2p.identity module libp2p.identity.identify module libp2p.identity.identify.identify module libp2p.identity.identify.pb module libp2p.identity.identify.pb.identify_pb2 module libp2p.identity.identify_push module libp2p.identity.identify_push.identify_push module libp2p.io module libp2p.io.abc module libp2p.io.exceptions module libp2p.io.msgio module libp2p.io.trio module libp2p.io.utils module libp2p.kad_dht module libp2p.kad_dht.kad_dht module libp2p.kad_dht.pb module libp2p.kad_dht.pb.kademlia_pb2 module libp2p.kad_dht.peer_routing module libp2p.kad_dht.provider_store module libp2p.kad_dht.routing_table module libp2p.kad_dht.utils module libp2p.kad_dht.value_store module libp2p.network module libp2p.network.connection module libp2p.network.connection.exceptions module libp2p.network.connection.raw_connection module libp2p.network.connection.swarm_connection module libp2p.network.exceptions module libp2p.network.stream module libp2p.network.stream.exceptions module libp2p.network.stream.net_stream module libp2p.network.swarm module libp2p.observability module libp2p.observability.oso module libp2p.observability.oso.cli module libp2p.observability.oso.dependency_graph module libp2p.observability.oso.generators module libp2p.observability.oso.metrics module libp2p.observability.oso.models module libp2p.observability.oso.providers module libp2p.observability.oso.report module libp2p.observability.oso.service module libp2p.observability.oso.transitive_graph module libp2p.peer module libp2p.peer.envelope module libp2p.peer.id module libp2p.peer.peer_record module libp2p.peer.peerdata module libp2p.peer.peerinfo module libp2p.peer.peerstore module libp2p.perf module libp2p.perf.constants module libp2p.perf.perf_service module libp2p.perf.types module libp2p.protocol_muxer module libp2p.protocol_muxer.exceptions module libp2p.protocol_muxer.multiselect module libp2p.protocol_muxer.multiselect_client module libp2p.protocol_muxer.multiselect_communicator module libp2p.pubsub module libp2p.pubsub.exceptions module libp2p.pubsub.floodsub module libp2p.pubsub.gossipsub module libp2p.pubsub.mcache module libp2p.pubsub.pb module

libp2p.pubsub.pb.rpc_pb2 module libp2p.pubsub.pubsub module libp2p.pubsub.pubsub_notifee module libp2p.pubsub.subscription module libp2p.pubsub.validators module libp2p.rcmgr module libp2p.rcmgr.allowlist module libp2p.rcmgr.exceptions module libp2p.rcmgr.limits module libp2p.rcmgr.manager module libp2p.rcmgr.metrics module libp2p.records module libp2p.records.ipns module libp2p.records.pb module libp2p.records.pb.ipns_pb2 module libp2p.records.pubkey module libp2p.records.record module libp2p.records.utils module libp2p.records.validator module libp2p.relay.circuit_v2.config module libp2p.relay.circuit_v2.discovery module libp2p.relay.circuit_v2.pb.circuit_pb2 module libp2p.relay.circuit_v2.performance_tracker module libp2p.relay.circuit_v2.protocol module libp2p.relay.circuit_v2.protocol_buffer module libp2p.relay.circuit_v2.resources module libp2p.relay.circuit_v2.transport module libp2p.request_response module libp2p.request_response.api module libp2p.request_response.codec module libp2p.request_response.exceptions module libp2p.security module libp2p.security.base_session module libp2p.security.base_transport module libp2p.security.exceptions module libp2p.security.insecure module libp2p.security.insecure.pb module libp2p.security.insecure.pb.plaintext_pb2 module libp2p.security.insecure.transport module libp2p.security.noise module libp2p.security.noise.exceptions module libp2p.security.noise.io module libp2p.security.noise.messages module libp2p.security.noise.patterns module libp2p.security.noise.pb module libp2p.security.noise.pb.noise_pb2 module libp2p.security.noise.transport module libp2p.security.pnet module libp2p.security.pnet.protector module libp2p.security.pnet.psk_conn module libp2p.security.secio module libp2p.security.secio.exceptions module libp2p.security.secio.pb module libp2p.security.secio.pb.spipe_pb2 module libp2p.security.secio.transport module libp2p.security.secure_session module libp2p.security.security_multistream module libp2p.security.tls module libp2p.security.tls.certificate module libp2p.security.tls.io module libp2p.security.tls.transport module libp2p.stream_muxer module libp2p.stream_muxer.exceptions module libp2p.stream_muxer.mplex module libp2p.stream_muxer.mplex.constants module libp2p.stream_muxer.mplex.datastructures module libp2p.stream_muxer.mplex.exceptions module libp2p.stream_muxer.mplex.mplex module libp2p.stream_muxer.mplex.mplex_stream module libp2p.stream_muxer.muxer_multistream module libp2p.stream_muxer.yamux module libp2p.tools module libp2p.tools.anyio_service module libp2p.tools.anyio_service.api module libp2p.tools.anyio_service.context module libp2p.tools.anyio_service.exceptions module libp2p.tools.anyio_service.manager module libp2p.tools.anyio_service.stats module libp2p.tools.anyio_service.tasks module libp2p.tools.anyio_service.utils module libp2p.tools.constants module libp2p.tools.timed_cache module libp2p.tools.timed_cache.base_timed_cache module libp2p.tools.timed_cache.first_seen_cache module libp2p.tools.timed_cache.last_seen_cache module libp2p.tools.utils module libp2p.transport module libp2p.transport.exceptions module libp2p.transport.quic module libp2p.transport.quic.config module libp2p.transport.quic.connection module libp2p.transport.quic.exceptions module libp2p.transport.quic.listener module libp2p.transport.quic.security module libp2p.transport.quic.stream module libp2p.transport.quic.transport module libp2p.transport.quic.utils module libp2p.transport.tcp module libp2p.transport.tcp.tcp module libp2p.transport.upgrader module libp2p.transport.websocket module libp2p.transport.websocket.connection module libp2p.transport.websocket.listener module libp2p.transport.websocket.manager module libp2p.transport.websocket.multiaddr_utils module libp2p.transport.websocket.proxy module libp2p.transport.websocket.proxy_env module libp2p.transport.websocket.transport module libp2p.utils.address_validation module libp2p.utils.dns_utils module libp2p.utils.logging module libp2p.utils.multiaddr_utils module libp2p.utils.paths module libp2p.utils.varint module libp2p.utils.version module libp2p_privkey (libp2p.security.noise.patterns.BasePattern attribute) (libp2p.security.noise.transport.Transport attribute) (libp2p.security.tls.TLSTransport attribute) (libp2p.security.tls.transport.TLSTransport attribute) libp2p_to_tls_private_key() (libp2p.transport.quic.security.LibP2PKeyConverter static method) LibP2PExtensionHandler (class in libp2p.transport.quic.security) LibP2PKeyConverter (class in libp2p.transport.quic.security) LifecycleError, [1] Limit (class in libp2p.relay.circuit_v2.pb.circuit_pb2) limits (libp2p.relay.circuit_v2.config.RelayConfig attribute) listen() (libp2p.abc.IListener method) (libp2p.abc.INetwork method) (libp2p.abc.INotifee method) (libp2p.network.swarm.Swarm method) (libp2p.pubsub.pubsub_notifee.PubsubNotifee method) (libp2p.relay.circuit_v2.transport.CircuitV2Listener method) (libp2p.transport.quic.listener.QUICListener method) (libp2p.transport.tcp.tcp.TCPListener method) (libp2p.transport.websocket.listener.WebsocketListener method) (libp2p.transport.websocket.WebsocketListener method) listen_close() (libp2p.abc.INotifee method) (libp2p.pubsub.pubsub_notifee.PubsubNotifee method) listen_maddr (libp2p.transport.websocket.listener.WebsocketListener property) (libp2p.transport.websocket.WebsocketListener property) listen_order() (libp2p.transport.quic.transport.QUICTransport method) listeners (libp2p.abc.INetwork attribute) (libp2p.network.swarm.Swarm attribute) (libp2p.transport.tcp.tcp.TCPListener attribute) load_keypair() (in module libp2p) local_encrypter (libp2p.security.secio.transport.SecioMsgReadWriter attribute) local_encryption_parameters (libp2p.security.secio.transport.SessionParameters attribute) local_peer (libp2p.security.base_session.BaseSession attribute) (libp2p.security.noise.patterns.BasePattern attribute) (libp2p.security.noise.transport.Transport attribute) (libp2p.security.secio.transport.SessionParameters attribute) (libp2p.security.tls.TLSTransport attribute) (libp2p.security.tls.transport.TLSTransport attribute) local_peer_id() (libp2p.transport.quic.connection.QUICConnection method) local_port (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) local_private_key (libp2p.security.base_session.BaseSession attribute) log_autonat_status() (in module examples.nat.listener) logger (in module libp2p.security.security_multistream) low_watermark (libp2p.security.secure_session.SecureSession attribute)

M

mac_key (libp2p.crypto.authenticated_encryption.EncryptionParameters attribute) MacAndCipher (class in libp2p.crypto.authenticated_encryption) main() (in module examples.autotls.autotls) (in module examples.cid.cid_usage) (in module examples.nat.dialer) (in module examples.nat.listener) (in module examples.nat.relay) (in module examples.path_handling.path_handling) (in module examples.tls.example_tls_client) (in module examples.tls.example_tls_server) (in module examples.transport.transport_integration_demo) (in module libp2p.filecoin.cli) (in module libp2p.observability.oso.cli) make_data_to_be_signed() (in module libp2p.security.noise.messages) make_delegated_address() (in module libp2p.filecoin) make_exchange_message() (in module libp2p.security.insecure.transport) make_handshake_payload() (libp2p.security.noise.patterns.BasePattern method) make_handshake_payload_sig() (in module libp2p.security.noise.messages) make_id_address() (in module libp2p.filecoin) make_put_record() (in module libp2p.records.record) make_reservation() (libp2p.relay.circuit_v2.discovery.RelayDiscovery method) make_unsigned() (in module libp2p.peer.envelope) MALFORMED_MESSAGE (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) manager (libp2p.tools.anyio_service.api.Service property) (libp2p.tools.anyio_service.Service property) ManagerAPI (class in libp2p.tools.anyio_service.api) map_quic_error_code() (in module libp2p.transport.quic.exceptions) marshal_envelope() (libp2p.abc.IEnvelope method) (libp2p.peer.envelope.Envelope method) marshal_record() (libp2p.abc.IPeerRecord method) (libp2p.peer.peer_record.PeerRecord method) max_auto_relay_attempts (libp2p.relay.circuit_v2.config.ClientConfig attribute) max_bandwidth_per_circuit (libp2p.relay.circuit_v2.config.HopConfig attribute) max_bandwidth_total (libp2p.relay.circuit_v2.config.HopConfig attribute) max_buffered_amount (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) max_circuit_bytes (libp2p.relay.circuit_v2.config.RelayConfig attribute) max_circuit_conns (libp2p.relay.circuit_v2.resources.RelayLimits attribute) max_circuit_duration (libp2p.relay.circuit_v2.config.RelayConfig attribute) max_circuits_per_ip (libp2p.relay.circuit_v2.config.HopConfig attribute) max_circuits_total (libp2p.relay.circuit_v2.config.HopConfig attribute) max_concurrent_inbound (libp2p.request_response.api.RequestResponseConfig attribute) (libp2p.request_response.RequestResponseConfig attribute) max_concurrent_reservations (libp2p.relay.circuit_v2.config.ClientConfig attribute) MAX_CONCURRENT_STREAMS (libp2p.transport.quic.config.QUICTransportConfig attribute) max_concurrent_streams (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) max_connections (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute) max_datagram_size (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) max_idontwant_messages (libp2p.pubsub.gossipsub.GossipSub attribute) MAX_INCOMING_STREAMS (libp2p.transport.quic.config.QUICTransportConfig attribute) max_message_size (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute) max_messages_per_topic_per_second (libp2p.pubsub.gossipsub.GossipSub attribute) max_msg_size (libp2p.io.msgio.VarIntLengthMsgReadWriter attribute) (libp2p.security.insecure.transport.PlaintextHandshakeReadWriter attribute) max_out_degree (libp2p.observability.oso.models.DependencyTopologyMetric attribute) MAX_OUTGOING_STREAMS (libp2p.transport.quic.config.QUICTransportConfig attribute) max_pending_messages_per_peer (libp2p.tools.constants.GossipsubParams attribute) max_relay_latency (libp2p.relay.circuit_v2.config.ClientConfig attribute) max_relays (libp2p.relay.circuit_v2.config.RelayConfig attribute) max_request_size (libp2p.request_response.api.RequestResponseConfig attribute) (libp2p.request_response.RequestResponseConfig attribute) max_reservations (libp2p.relay.circuit_v2.resources.RelayLimits attribute) max_reservations_per_ip (libp2p.relay.circuit_v2.config.HopConfig attribute) max_reservations_total (libp2p.relay.circuit_v2.config.HopConfig attribute) max_response_size (libp2p.request_response.api.RequestResponseConfig attribute) (libp2p.request_response.RequestResponseConfig attribute) MAX_STREAM_RECEIVE_BUFFER (libp2p.transport.quic.config.QUICTransportConfig attribute) maybe_connect() (libp2p.network.AutoConnector method) maybe_consume_signed_record() (in module libp2p.kad_dht.utils) maybe_delete_peer_record() (libp2p.abc.ICertifiedAddrBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) maybe_prune_connections() (libp2p.network.ConnectionPruner method) mcache (libp2p.pubsub.gossipsub.GossipSub attribute) mDNS (libp2p.host.basic_host.BasicHost attribute) MDNSDiscovery (class in libp2p.discovery.mdns.mdns) measure_performance() (libp2p.abc.IPerf method) (libp2p.perf.IPerf method) (libp2p.perf.perf_service.PerfService method) (libp2p.perf.PerfService method) median_days_between_releases (libp2p.observability.oso.models.ReleaseCadenceMetric attribute) median_hours_to_close (libp2p.observability.oso.models.IssueResponsivenessMetric attribute) median_hours_to_first_response (libp2p.observability.oso.models.IssueResponsivenessMetric attribute) MEMORY_BLOCKS (libp2p.rcmgr.metrics.MetricType attribute) MEMORY_USAGE (libp2p.rcmgr.metrics.MetricType attribute) MemoryBlockStore (class in libp2p.bitswap) MemoryLimitExceeded mesh (libp2p.abc.IPubsubRouter attribute) (libp2p.pubsub.floodsub.FloodSub attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) mesh_heartbeat() (libp2p.pubsub.gossipsub.GossipSub method) Message (class in libp2p.bitswap.pb.bitswap_pb2) (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) (class in libp2p.host.autonat.pb.autonat_pb2) (class in libp2p.kad_dht.pb.kademlia_pb2) (class in libp2p.pubsub.pb.rpc_pb2) Message.Block (class in libp2p.bitswap.pb.bitswap_pb2) Message.BlockPresence (class in libp2p.bitswap.pb.bitswap_pb2) Message.Discover (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.DiscoverResponse (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.DiscoverSubscribe (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.DiscoverSubscribeResponse (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.Peer (class in libp2p.kad_dht.pb.kademlia_pb2) Message.PeerInfo (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.Register (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.RegisterResponse (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.Unregister (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) Message.Wantlist (class in libp2p.bitswap.pb.bitswap_pb2) Message.Wantlist.Entry (class in libp2p.bitswap.pb.bitswap_pb2) message_all_peers() (libp2p.pubsub.pubsub.Pubsub method) message_rate_limits (libp2p.pubsub.gossipsub.GossipSub attribute) MessageCache (class in libp2p.pubsub.mcache) MessageIDGenerator (class in libp2p.pubsub.pubsub) MessageInitiator (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) MessageReceiver (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) messages_received (libp2p.transport.websocket.connection.WebSocketStats attribute) messages_sent (libp2p.transport.websocket.connection.WebSocketStats attribute) messages_topic() (in module libp2p.filecoin) (in module libp2p.filecoin.constants) MessageTooLarge MessageTooLargeError, [1], [2] Metadata (class in libp2p.bitswap.pb.unixfs_pb2) metadata (libp2p.peer.peerdata.PeerData attribute) Metrics (class in libp2p.rcmgr.metrics) metrics (libp2p.observability.oso.HealthReport attribute) (libp2p.observability.oso.models.HealthReport attribute) metrics_available (libp2p.observability.oso.models.RcmgrSnapshot attribute) MetricType (class in libp2p.rcmgr.metrics) mid (libp2p.pubsub.mcache.CacheEntry attribute) min_mesh_diversity_ips (libp2p.pubsub.gossipsub.GossipSub attribute) min_relay_score (libp2p.relay.circuit_v2.config.ClientConfig attribute) min_relays (libp2p.relay.circuit_v2.config.RelayConfig attribute) MissingDeserializerError MissingLengthException MissingMessageException module examples.autotls examples.autotls.autotls examples.cid examples.cid.cid_usage examples.nat examples.nat.dialer examples.nat.listener examples.nat.relay examples.path_handling examples.path_handling.path_handling examples.path_handling.path_handling_demo examples.tcp examples.tcp.test_tcp_data_transfer examples.tls examples.tls.example_tls_client examples.tls.example_tls_server examples.transport examples.transport.transport_integration_demo libp2p libp2p.abc libp2p.bitswap.config libp2p.bitswap.errors libp2p.bitswap.pb libp2p.bitswap.pb.bitswap_pb2 libp2p.bitswap.pb.dag_pb_pb2 libp2p.bitswap.pb.unixfs_pb2 libp2p.crypto libp2p.crypto.authenticated_encryption libp2p.crypto.ecc libp2p.crypto.ed25519 libp2p.crypto.exceptions libp2p.crypto.key_exchange libp2p.crypto.keys libp2p.crypto.rsa libp2p.crypto.secp256k1 libp2p.crypto.serialization libp2p.custom_types libp2p.discovery libp2p.discovery.bootstrap libp2p.discovery.events libp2p.discovery.events.peerDiscovery libp2p.discovery.mdns libp2p.discovery.mdns.broadcaster libp2p.discovery.mdns.listener libp2p.discovery.mdns.mdns libp2p.discovery.mdns.utils libp2p.discovery.random_walk libp2p.discovery.random_walk.config libp2p.discovery.random_walk.exceptions libp2p.discovery.random_walk.random_walk libp2p.discovery.random_walk.rt_refresh_manager libp2p.discovery.rendezvous libp2p.discovery.rendezvous.client libp2p.discovery.rendezvous.config libp2p.discovery.rendezvous.discovery libp2p.discovery.rendezvous.messages libp2p.discovery.rendezvous.pb libp2p.discovery.rendezvous.pb.rendezvous_pb2 libp2p.discovery.rendezvous.service libp2p.discovery.upnp libp2p.discovery.upnp.upnp libp2p.exceptions libp2p.filecoin libp2p.filecoin.bootstrap libp2p.filecoin.cli libp2p.filecoin.constants libp2p.filecoin.networks libp2p.filecoin.pubsub libp2p.host libp2p.host.autonat.autonat libp2p.host.autonat.pb libp2p.host.autonat.pb.autonat_pb2 libp2p.host.autonat.pb.autonat_pb2_grpc libp2p.host.autonat.pb.generate_proto libp2p.host.basic_host libp2p.host.defaults libp2p.host.exceptions libp2p.host.observed_addr_manager libp2p.host.ping libp2p.host.routed_host libp2p.identity libp2p.identity.identify libp2p.identity.identify.identify libp2p.identity.identify.pb libp2p.identity.identify.pb.identify_pb2 libp2p.identity.identify_push libp2p.identity.identify_push.identify_push libp2p.io libp2p.io.abc libp2p.io.exceptions libp2p.io.msgio libp2p.io.trio libp2p.io.utils libp2p.kad_dht libp2p.kad_dht.kad_dht libp2p.kad_dht.pb libp2p.kad_dht.pb.kademlia_pb2 libp2p.kad_dht.peer_routing libp2p.kad_dht.provider_store libp2p.kad_dht.routing_table libp2p.kad_dht.utils libp2p.kad_dht.value_store libp2p.network libp2p.network.connection libp2p.network.connection.exceptions libp2p.network.connection.raw_connection libp2p.network.connection.swarm_connection libp2p.network.exceptions libp2p.network.stream libp2p.network.stream.exceptions libp2p.network.stream.net_stream libp2p.network.swarm libp2p.observability libp2p.observability.oso libp2p.observability.oso.cli libp2p.observability.oso.dependency_graph libp2p.observability.oso.generators libp2p.observability.oso.metrics libp2p.observability.oso.models libp2p.observability.oso.providers libp2p.observability.oso.report libp2p.observability.oso.service libp2p.observability.oso.transitive_graph libp2p.peer libp2p.peer.envelope libp2p.peer.id libp2p.peer.peer_record libp2p.peer.peerdata libp2p.peer.peerinfo libp2p.peer.peerstore libp2p.perf libp2p.perf.constants libp2p.perf.perf_service libp2p.perf.types libp2p.protocol_muxer libp2p.protocol_muxer.exceptions libp2p.protocol_muxer.multiselect libp2p.protocol_muxer.multiselect_client libp2p.protocol_muxer.multiselect_communicator libp2p.pubsub libp2p.pubsub.exceptions libp2p.pubsub.floodsub libp2p.pubsub.gossipsub libp2p.pubsub.mcache libp2p.pubsub.pb libp2p.pubsub.pb.rpc_pb2 libp2p.pubsub.pubsub libp2p.pubsub.pubsub_notifee libp2p.pubsub.subscription libp2p.pubsub.validators libp2p.rcmgr libp2p.rcmgr.allowlist libp2p.rcmgr.exceptions libp2p.rcmgr.limits libp2p.rcmgr.manager libp2p.rcmgr.metrics libp2p.records libp2p.records.ipns libp2p.records.pb libp2p.records.pb.ipns_pb2 libp2p.records.pubkey libp2p.records.record libp2p.records.utils libp2p.records.validator libp2p.relay.circuit_v2.config libp2p.relay.circuit_v2.discovery libp2p.relay.circuit_v2.pb.circuit_pb2 libp2p.relay.circuit_v2.performance_tracker libp2p.relay.circuit_v2.protocol libp2p.relay.circuit_v2.protocol_buffer libp2p.relay.circuit_v2.resources libp2p.relay.circuit_v2.transport libp2p.request_response libp2p.request_response.api libp2p.request_response.codec libp2p.request_response.exceptions libp2p.security libp2p.security.base_session libp2p.security.base_transport libp2p.security.exceptions libp2p.security.insecure libp2p.security.insecure.pb libp2p.security.insecure.pb.plaintext_pb2 libp2p.security.insecure.transport libp2p.security.noise libp2p.security.noise.exceptions libp2p.security.noise.io libp2p.security.noise.messages libp2p.security.noise.patterns libp2p.security.noise.pb libp2p.security.noise.pb.noise_pb2 libp2p.security.noise.transport libp2p.security.pnet libp2p.security.pnet.protector libp2p.security.pnet.psk_conn libp2p.security.secio libp2p.security.secio.exceptions libp2p.security.secio.pb libp2p.security.secio.pb.spipe_pb2 libp2p.security.secio.transport libp2p.security.secure_session libp2p.security.security_multistream libp2p.security.tls libp2p.security.tls.certificate libp2p.security.tls.io libp2p.security.tls.transport libp2p.stream_muxer libp2p.stream_muxer.exceptions libp2p.stream_muxer.mplex libp2p.stream_muxer.mplex.constants libp2p.stream_muxer.mplex.datastructures libp2p.stream_muxer.mplex.exceptions libp2p.stream_muxer.mplex.mplex libp2p.stream_muxer.mplex.mplex_stream libp2p.stream_muxer.muxer_multistream libp2p.stream_muxer.yamux libp2p.tools libp2p.tools.anyio_service libp2p.tools.anyio_service.api libp2p.tools.anyio_service.context libp2p.tools.anyio_service.exceptions libp2p.tools.anyio_service.manager libp2p.tools.anyio_service.stats libp2p.tools.anyio_service.tasks libp2p.tools.anyio_service.utils libp2p.tools.constants libp2p.tools.timed_cache libp2p.tools.timed_cache.base_timed_cache libp2p.tools.timed_cache.first_seen_cache libp2p.tools.timed_cache.last_seen_cache libp2p.tools.utils libp2p.transport libp2p.transport.exceptions libp2p.transport.quic libp2p.transport.quic.config libp2p.transport.quic.connection libp2p.transport.quic.exceptions libp2p.transport.quic.listener libp2p.transport.quic.security libp2p.transport.quic.stream libp2p.transport.quic.transport libp2p.transport.quic.utils libp2p.transport.tcp libp2p.transport.tcp.tcp libp2p.transport.upgrader libp2p.transport.websocket libp2p.transport.websocket.connection libp2p.transport.websocket.listener libp2p.transport.websocket.manager libp2p.transport.websocket.multiaddr_utils libp2p.transport.websocket.proxy libp2p.transport.websocket.proxy_env libp2p.transport.websocket.transport libp2p.utils.address_validation libp2p.utils.dns_utils libp2p.utils.logging libp2p.utils.multiaddr_utils libp2p.utils.paths libp2p.utils.varint libp2p.utils.version

monitoring_available (libp2p.observability.oso.models.RcmgrSnapshot attribute) most_connected_packages (libp2p.observability.oso.models.DependencyTopologyMetric attribute) Mplex (class in libp2p.stream_muxer.mplex.mplex) MplexError MplexStream (class in libp2p.stream_muxer.mplex.mplex_stream) MplexStreamClosed MplexStreamEOF MplexStreamReset MplexUnavailable MsgioException MsgReader (class in libp2p.io.abc) MsgReadWriteCloser (class in libp2p.io.abc) msgs (libp2p.pubsub.mcache.MessageCache attribute) MsgWriter (class in libp2p.io.abc) multiaddr() (libp2p.transport.quic.connection.QUICConnection method) multiaddr_from_socket() (in module libp2p.utils.multiaddr_utils) multiaddr_to_quic_version() (in module libp2p.transport.quic.utils) multiaddrs (libp2p.rcmgr.allowlist.AllowlistConfig attribute) multibase_to_bytes() (in module libp2p.kad_dht.utils) MultiError Multiselect (class in libp2p.protocol_muxer.multiselect) multiselect (libp2p.host.basic_host.BasicHost attribute) (libp2p.protocol_muxer.GenericMultistreamSelector attribute) (libp2p.relay.circuit_v2.discovery.IHostWithMultiselect property) (libp2p.security.security_multistream.SecurityMultistream property) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream property) multiselect_client (libp2p.host.basic_host.BasicHost attribute) (libp2p.protocol_muxer.GenericMultistreamSelector attribute) (libp2p.security.security_multistream.SecurityMultistream property) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream property) MultiselectClient (class in libp2p.protocol_muxer.multiselect_client) MultiselectClientError MultiselectCommunicator (class in libp2p.protocol_muxer.multiselect_communicator) MultiselectCommunicatorError MultiselectError multistream_client (libp2p.stream_muxer.muxer_multistream.MuxerMultistream property) muxed_conn (libp2p.abc.IMuxedStream attribute) (libp2p.abc.INetConn attribute) (libp2p.abc.INetStream attribute) (libp2p.network.connection.swarm_connection.SwarmConn attribute) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) (libp2p.transport.quic.stream.QUICStream property) muxed_stream (libp2p.network.stream.net_stream.NetStream attribute) MuxedConnError MuxedConnUnavailable MuxedStreamClosed MuxedStreamEOF MuxedStreamError MuxedStreamReset muxer_multistream (libp2p.transport.upgrader.TransportUpgrader attribute) MuxerMultistream (class in libp2p.stream_muxer.muxer_multistream) MuxerUpgradeFailure my_id (libp2p.abc.IPubsub property) (libp2p.pubsub.pubsub.Pubsub property)

N

name (libp2p.filecoin.FilecoinNetworkPreset attribute) (libp2p.filecoin.networks.FilecoinNetworkPreset attribute) (libp2p.observability.oso.models.DependencyEntry attribute) (libp2p.observability.oso.models.ProjectMetadata attribute) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) (libp2p.tools.anyio_service.tasks.TaskAPI attribute) namespace (libp2p.filecoin.FilecoinAddress attribute) NamespacedValidator (class in libp2p.records.validator) NATDeviceType (class in libp2p.host.observed_addr_manager) negotiate() (libp2p.abc.IMultiselectMuxer method) (libp2p.protocol_muxer.multiselect.Multiselect method) negotiate_timeout (libp2p.stream_muxer.muxer_multistream.MuxerMultistream attribute) NEGOTIATE_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) NEGOTIATION_SEMAPHORE_LIMIT (libp2p.transport.quic.config.QUICTransportConfig attribute) NetStream (class in libp2p.network.stream.net_stream) network_health_score (libp2p.pubsub.gossipsub.GossipSub attribute) new() (libp2p.crypto.ecc.ECCPrivateKey class method) (libp2p.crypto.ed25519.Ed25519PrivateKey class method) (libp2p.crypto.rsa.RSAPrivateKey class method) (libp2p.crypto.secp256k1.Secp256k1PrivateKey class method) new_allowlist() (in module libp2p.rcmgr.allowlist) new_allowlist_with_config() (in module libp2p.rcmgr.allowlist) new_conn() (libp2p.stream_muxer.muxer_multistream.MuxerMultistream method) new_host() (in module libp2p) new_protected_conn() (in module libp2p.security.pnet.protector) new_resource_manager() (in module libp2p.rcmgr) (in module libp2p.rcmgr.manager) new_stream() (libp2p.abc.IHost method) (libp2p.abc.INetConn method) (libp2p.abc.INetwork method) (libp2p.host.basic_host.BasicHost method) (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.network.swarm.Swarm method) new_stream_receive_channel (libp2p.stream_muxer.mplex.mplex.Mplex attribute)

new_stream_send_channel (libp2p.stream_muxer.mplex.mplex.Mplex attribute) new_swarm() (in module libp2p) NewStream (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) next_channel_id (libp2p.stream_muxer.mplex.mplex.Mplex attribute) next_msg_len() (libp2p.io.msgio.BaseMsgReadWriter method) (libp2p.io.msgio.FixedSizeLenMsgReadWriter method) (libp2p.io.msgio.VarIntLengthMsgReadWriter method) noise_privkey (libp2p.security.noise.transport.Transport attribute) noise_state (libp2p.security.noise.io.BaseNoiseMsgReadWriter attribute) noise_static_key (libp2p.security.noise.patterns.BasePattern attribute) NoiseExtensions (class in libp2p.security.noise.messages) (class in libp2p.security.noise.pb.noise_pb2) NoiseFailure NoiseHandshakePayload (class in libp2p.security.noise.messages) (class in libp2p.security.noise.pb.noise_pb2) NoiseHandshakeReadWriter (class in libp2p.security.noise.io) NoisePacketReadWriter (class in libp2p.security.noise.io) NoiseStateError NoiseTransportReadWriter (class in libp2p.security.noise.io) nonce (libp2p.security.secio.transport.Proposal attribute) NoPubsubAttached normalize_path() (in module libp2p.utils.paths) normalize_quic_multiaddr() (in module libp2p.transport.quic.utils) NotAuthorizedError notes (libp2p.observability.oso.models.SourceStatus attribute) notifees (libp2p.network.swarm.Swarm attribute) notify_all() (libp2p.network.swarm.Swarm method) notify_closed_stream() (libp2p.network.swarm.Swarm method) notify_connected() (libp2p.network.swarm.Swarm method) notify_disconnected() (libp2p.network.swarm.Swarm method) notify_listen() (libp2p.network.swarm.Swarm method) notify_listen_close() (libp2p.network.swarm.Swarm method) notify_opened_stream() (libp2p.network.swarm.Swarm method) notify_subscriptions() (libp2p.pubsub.pubsub.Pubsub method)

O

ObservedAddrManager (class in libp2p.host.observed_addr_manager) observer_group() (in module libp2p.host.observed_addr_manager) OK (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) on_close (libp2p.stream_muxer.mplex.mplex.Mplex attribute) OPEN (libp2p.network.stream.net_stream.StreamState attribute) (libp2p.transport.quic.stream.StreamState attribute) open_connection() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) open_issues (libp2p.observability.oso.models.IssueResponsivenessMetric attribute) open_stream() (libp2p.abc.IMuxedConn method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method)

OpenConnectionError opened_stream() (libp2p.abc.INotifee method) (libp2p.pubsub.pubsub_notifee.PubsubNotifee method) optional_dependencies (libp2p.observability.oso.models.DependencyGraph attribute) (libp2p.observability.oso.models.DependencyTopologyMetric attribute) order (libp2p.security.secio.transport.SessionParameters attribute) oso (libp2p.observability.oso.models.SourceStatus attribute) OsoProvider (class in libp2p.observability.oso.providers) osv_vulnerable_packages (libp2p.observability.oso.models.SecurityProxyMetric attribute) OUTBOUND (libp2p.rcmgr.Direction attribute) (libp2p.rcmgr.metrics.Direction attribute) (libp2p.transport.quic.stream.StreamDirection attribute)

P

P2PWebSocketConnection (class in libp2p.transport.websocket) (class in libp2p.transport.websocket.connection) pack_control_msgs() (libp2p.pubsub.gossipsub.GossipSub method) parent (libp2p.tools.anyio_service.tasks.TaskAPI attribute) parse_address() (in module libp2p.filecoin) parse_circuit_ma() (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) parse_identify_response() (in module libp2p.identity.identify.identify) parse_iso_datetime() (in module libp2p.observability.oso.providers) parse_peer_info() (in module libp2p.discovery.rendezvous.messages) parse_quic_packet() (libp2p.transport.quic.listener.QUICListener method) parse_signed_key_extension() (libp2p.transport.quic.security.LibP2PExtensionHandler static method) parse_websocket_multiaddr() (in module libp2p.transport.websocket.multiaddr_utils) ParsedIPNSRecord (class in libp2p.records.ipns) ParsedWebSocketMultiaddr (class in libp2p.transport.websocket.multiaddr_utils) ParseError PatternXX (class in libp2p.security.noise.patterns) payload (libp2p.filecoin.FilecoinAddress attribute) payload_type (libp2p.peer.envelope.Envelope property) payload_type_code (libp2p.peer.envelope.Envelope attribute) PBLink (class in libp2p.bitswap.pb.dag_pb_pb2) PBNode (class in libp2p.bitswap.pb.dag_pb_pb2) PEAK_CONNECTIONS (libp2p.rcmgr.metrics.MetricType attribute) PEAK_MEMORY (libp2p.rcmgr.metrics.MetricType attribute) PEAK_STREAMS (libp2p.rcmgr.metrics.MetricType attribute) peak_usage (libp2p.rcmgr.metrics.ResourceMetrics attribute) peer (libp2p.relay.circuit_v2.resources.ReservationVoucher attribute) peer_data_map (libp2p.peer.peerstore.PeerStore attribute) peer_id (libp2p.abc.IMuxedConn attribute) (libp2p.kad_dht.provider_store.ProviderRecord property) (libp2p.peer.peer_record.PeerRecord attribute) (libp2p.peer.peerinfo.PeerInfo attribute) (libp2p.relay.circuit_v2.discovery.RelayInfo attribute) (libp2p.request_response.api.RequestContext attribute) (libp2p.request_response.RequestContext attribute) (libp2p.stream_muxer.mplex.mplex.Mplex attribute) (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) (libp2p.transport.quic.security.TLSConfig attribute) peer_id_in_range() (libp2p.kad_dht.routing_table.KBucket method) peer_id_to_key() (in module libp2p.kad_dht.routing_table) peer_ids() (libp2p.abc.IPeerStore method) (libp2p.kad_dht.routing_table.KBucket method) (libp2p.peer.peerstore.PeerStore method) peer_in_table() (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) peer_info() (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) peer_info_from_bytes() (in module libp2p.peer.peerinfo) peer_info_to_bytes() (in module libp2p.peer.peerinfo) peer_infos() (libp2p.kad_dht.routing_table.KBucket method) peer_multiaddrs (libp2p.rcmgr.allowlist.AllowlistConfig attribute) peer_protocol (libp2p.abc.IPubsubRouter attribute) (libp2p.pubsub.floodsub.FloodSub attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) peer_protocol_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) peer_queues (libp2p.pubsub.pubsub.Pubsub attribute) peer_receive_channel (libp2p.pubsub.pubsub.Pubsub attribute) peer_record_from_peer_info() (in module libp2p.peer.peer_record) peer_record_from_protobuf() (in module libp2p.peer.peer_record) peer_topics (libp2p.pubsub.pubsub.Pubsub attribute) peer_with_keys() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) PeerAndSeqnoMessageIDGenerator (class in libp2p.pubsub.pubsub) PeerAuthenticator (class in libp2p.transport.quic.security) PeerBroadcaster (class in libp2p.discovery.mdns.broadcaster) PeerCache (class in libp2p.discovery.rendezvous.discovery) PeerData (class in libp2p.peer.peerdata) PeerDataError PeerDiscovery (class in libp2p.discovery.events.peerDiscovery) PeerIDMismatchesPubkey PeerInfo (class in libp2p.host.autonat.pb.autonat_pb2) (class in libp2p.peer.peerinfo) (class in libp2p.pubsub.pb.rpc_pb2) PeerListener (class in libp2p.discovery.mdns.listener) PeerMismatchException PeerRecord (class in libp2p.peer.peer_record) PeerRecordState (class in libp2p.peer.peerstore) PeerRouting (class in libp2p.kad_dht) (class in libp2p.kad_dht.peer_routing) peers (libp2p.pubsub.pubsub.Pubsub attribute) (libp2p.rcmgr.allowlist.AllowlistConfig attribute) peers_with_addrs() (libp2p.abc.IAddrBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) PeerStore (class in libp2p.peer.peerstore) peerstore (libp2p.abc.INetwork attribute) (libp2p.host.basic_host.BasicHost attribute) (libp2p.network.swarm.Swarm attribute) PeerStoreError PeerValidationError, [1] pending_count (libp2p.tools.anyio_service.stats.TaskStats property) (libp2p.tools.anyio_service.TaskStats property) pending_messages_ttl (libp2p.tools.constants.GossipsubParams attribute) PerfComponents (class in libp2p.perf) (class in libp2p.perf.types) PerfInit (class in libp2p.perf) (class in libp2p.perf.types) perform_random_walk() (libp2p.discovery.random_walk.random_walk.RandomWalk method) (libp2p.discovery.random_walk.RandomWalk method) PerfOutput (class in libp2p.perf) (class in libp2p.perf.types) PerfService (class in libp2p.perf) (class in libp2p.perf.perf_service) permanent_public_key (libp2p.security.secio.transport.EncryptionParameters attribute) PERMISSION_DENIED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) ping() (libp2p.host.ping.PingService method) ping_interval (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute) ping_mode() (in module examples.tls.example_tls_client) ping_rtt_ms (libp2p.transport.websocket.connection.WebSocketStats attribute) ping_timeout (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute)

PingService (class in libp2p.host.ping) PlaintextHandshakeReadWriter (class in libp2p.security.insecure.transport) popularity (libp2p.observability.oso.models.HealthMetrics attribute) PopularityInfo (class in libp2p.observability.oso.providers) PopularityMetric (class in libp2p.observability.oso.models) prefix (libp2p.filecoin.FilecoinAddress property) (libp2p.security.noise.io.BaseNoiseMsgReadWriter attribute) pretty() (libp2p.peer.id.ID method) PRIVATE (libp2p.host.autonat.autonat.AutoNATStatus attribute) private_key (libp2p.crypto.keys.KeyPair attribute) (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) (libp2p.transport.quic.security.TLSConfig attribute) PrivateKey (class in libp2p.crypto.keys) privkey (libp2p.peer.peerdata.PeerData attribute) privkey() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) project (libp2p.observability.oso.HealthReport attribute) (libp2p.observability.oso.models.DependencyGraph attribute) (libp2p.observability.oso.models.HealthReport attribute) ProjectMetadata (class in libp2p.observability.oso.models) prometheus_available (libp2p.observability.oso.models.RcmgrSnapshot attribute) Proposal (class in libp2p.security.secio.transport) Propose (class in libp2p.security.secio.pb.spipe_pb2) protect() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) (libp2p.network.TagStore method) protocol (libp2p.filecoin.FilecoinAddress attribute) (libp2p.transport.quic.stream.QUICStream property) (libp2p.transport.websocket.connection.WebSocketStats attribute) protocol_close_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) protocol_id (libp2p.network.stream.net_stream.NetStream attribute) (libp2p.request_response.api.RequestContext attribute) (libp2p.request_response.RequestContext attribute) protocol_name (libp2p.perf.PerfInit attribute) (libp2p.perf.types.PerfInit attribute) (libp2p.security.noise.patterns.BasePattern attribute) PROTOCOL_QUIC_DRAFT29 (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) PROTOCOL_QUIC_V1 (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) protocol_read_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) protocol_write_timeout (libp2p.relay.circuit_v2.config.TimeoutConfig attribute) ProtocolNotSupportedError, [1], [2] protocols (libp2p.abc.IPubsub property) (libp2p.peer.peerdata.PeerData attribute) (libp2p.pubsub.floodsub.FloodSub attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.pubsub.pubsub.Pubsub property) protocols() (libp2p.transport.quic.transport.QUICTransport method) provide() (libp2p.abc.IContentRouting method) (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.kad_dht.provider_store.ProviderStore method) ProviderRecord (class in libp2p.kad_dht.provider_store) ProviderStore (class in libp2p.kad_dht.provider_store) proxy_auth (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) proxy_url (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) prune_back_off (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) PskConn (class in libp2p.security.pnet.psk_conn) pub_key_from_cert_chain() (in module libp2p.security.tls) (in module libp2p.security.tls.certificate) pub_key_from_protobuf() (in module libp2p.peer.envelope) pub_key_to_protobuf() (in module libp2p.peer.envelope) pubkey (libp2p.peer.peerdata.PeerData attribute) pubkey() (libp2p.abc.IKeyBook method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) PUBLIC (libp2p.host.autonat.autonat.AutoNATStatus attribute) public_key (libp2p.crypto.keys.KeyPair attribute) (libp2p.peer.envelope.Envelope attribute) (libp2p.security.secio.transport.Proposal attribute) public_key_bytes (libp2p.security.tls.certificate.SignedKey attribute) (libp2p.security.tls.SignedKey attribute) public_key_inlined (libp2p.records.ipns.ParsedIPNSRecord attribute) PublicKey (class in libp2p.crypto.keys) PublicKeyValidator (class in libp2p.records.pubkey) publish() (libp2p.abc.IPubsub method) (libp2p.abc.IPubsubRouter method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) (libp2p.pubsub.pubsub.Pubsub method) published_at (libp2p.observability.oso.providers.ReleaseInfo attribute) Pubsub (class in libp2p.pubsub.pubsub) PUBSUB (libp2p.network.CommonTags attribute) pubsub (libp2p.pubsub.floodsub.FloodSub attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) PubsubNotifee (class in libp2p.pubsub.pubsub_notifee) PubsubRouterError push_identify_to_peer() (in module libp2p.identity.identify_push) (in module libp2p.identity.identify_push.identify_push) push_identify_to_peers() (in module libp2p.identity.identify_push) (in module libp2p.identity.identify_push.identify_push) push_msg() (libp2p.pubsub.pubsub.Pubsub method) put() (libp2p.abc.IPeerMetadata method) (libp2p.abc.IPeerStore method) (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method) (libp2p.peer.peerstore.PeerStore method) (libp2p.pubsub.mcache.MessageCache method) (libp2p.pubsub.pubsub.ValidationCache method) put_block() (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) put_metadata() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) put_value() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) px_peers_count (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) python_version (libp2p.observability.oso.models.ProjectMetadata attribute)

Q

qlog_dir (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) query() (libp2p.observability.oso.providers.OsoProvider method) query_multistream_command() (libp2p.protocol_muxer.multiselect_client.MultiselectClient method) query_osv_vulnerabilities() (in module libp2p.observability.oso.providers) query_osv_vulnerabilities_for_version() (in module libp2p.observability.oso.providers) quic_multiaddr_to_endpoint() (in module libp2p.transport.quic.utils) quic_version_to_wire_format() (in module libp2p.transport.quic.utils) QUICAddressError QUICAddressResolutionError QUICCertificateError QUICConfigurationError QUICConnection (class in libp2p.transport.quic.connection) QUICConnectionClosedError QUICConnectionError QUICConnectionLimitError QUICConnectionTimeoutError QUICDialError QUICError QUICErrorContext (class in libp2p.transport.quic.exceptions) QUICFlowControlDeadlockError QUICFlowControlError QUICFlowControlViolationError QUICHandshakeError QUICInvalidConfigError

QUICInvalidMultiaddrError QUICListener (class in libp2p.transport.quic.listener) QUICListenError QUICMemoryLimitError QUICPacketInfo (class in libp2p.transport.quic.listener) QUICPeerVerificationError QUICProtocolError QUICResourceError QUICSecurityError QUICStream (class in libp2p.transport.quic.stream) QUICStreamBackpressureError QUICStreamClosedError QUICStreamError QUICStreamFlowControlConfig (class in libp2p.transport.quic.config) QUICStreamLimitError QUICStreamResetError QUICStreamStateError QUICStreamTimeoutError QUICTLSConfigManager (class in libp2p.transport.quic.security) QUICTLSSecurityConfig (class in libp2p.transport.quic.security) QUICTransport (class in libp2p.transport.quic.transport) QUICTransportConfig (class in libp2p.transport.quic.config) QUICTransportError QUICTransportKwargs (class in libp2p.transport.quic.config) QUICUnsupportedVersionError QUICVersionNegotiationError

R

RandomWalk (class in libp2p.discovery.random_walk) (class in libp2p.discovery.random_walk.random_walk) RandomWalkError, [1] RateLimitError raw_payload (libp2p.peer.envelope.Envelope attribute) RawConnection (class in libp2p.network.connection.raw_connection) RawConnError rcmgr (libp2p.observability.oso.models.SourceStatus attribute) rcmgr_baseline (libp2p.observability.oso.HealthReport attribute) (libp2p.observability.oso.models.HealthReport attribute) RcmgrSnapshot (class in libp2p.observability.oso.models) read() (libp2p.abc.IMultiselectCommunicator method) (libp2p.io.abc.Reader method) (libp2p.io.trio.TrioTCPStream method) (libp2p.network.connection.raw_connection.RawConnection method) (libp2p.network.stream.net_stream.NetStream method) (libp2p.protocol_muxer.multiselect_communicator.MultiselectCommunicator method) (libp2p.relay.circuit_v2.transport.TrackedRawConnection method) (libp2p.security.insecure.transport.InsecureSession method) (libp2p.security.pnet.psk_conn.PskConn method) (libp2p.security.secure_session.SecureSession method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) (libp2p.transport.quic.connection.QUICConnection method) (libp2p.transport.quic.stream.QUICStream method) (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.P2PWebSocketConnection method) READ_CLOSED (libp2p.transport.quic.stream.StreamState attribute) read_deadline (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) read_delim() (in module libp2p.utils.varint) read_exactly() (in module libp2p.io.utils) read_length() (in module libp2p.io.msgio) read_length_prefixed_protobuf() (in module libp2p.utils.varint) read_lock (libp2p.io.trio.TrioTCPStream attribute) read_message() (libp2p.stream_muxer.mplex.mplex.Mplex method) read_msg() (libp2p.io.abc.MsgReader method) (libp2p.io.msgio.BaseMsgReadWriter method) (libp2p.security.noise.io.BaseNoiseMsgReadWriter method) (libp2p.security.secio.transport.SecioMsgReadWriter method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.TLSReadWriter method) read_stream() (libp2p.stream_muxer.yamux.Yamux method) read_varint_prefixed_bytes() (in module libp2p.utils.varint) read_varint_prefixed_bytes_sync() (in module libp2p.utils.varint) read_write_closer (libp2p.io.msgio.BaseMsgReadWriter attribute) read_writer (libp2p.protocol_muxer.multiselect_communicator.MultiselectCommunicator attribute) (libp2p.security.noise.io.BaseNoiseMsgReadWriter attribute) (libp2p.security.secio.transport.SecioMsgReadWriter attribute) ReadCloser (class in libp2p.io.abc) Reader (class in libp2p.io.abc) ReadWriteCloser (class in libp2p.io.abc) ReadWriter (class in libp2p.io.abc) receive_channel (libp2p.pubsub.subscription.TrioSubscriptionAPI attribute) Record (class in libp2p.kad_dht.pb.kademlia_pb2) record() (libp2p.abc.IEnvelope method) (libp2p.peer.envelope.Envelope method) record_block() (libp2p.rcmgr.metrics.Metrics method) record_circuit_closed() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) record_circuit_opened() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) record_close() (libp2p.transport.quic.stream.StreamTimeline method) record_connection() (libp2p.network.TagStore method) (libp2p.rcmgr.metrics.Metrics method) record_connection_attempt() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) record_error() (libp2p.transport.websocket.connection.WebSocketStats method) record_failed_connection() (libp2p.network.AutoConnector method) record_failure() (libp2p.utils.dns_utils.DNSResolutionMetrics method) record_first_data() (libp2p.transport.quic.stream.StreamTimeline method) record_latency() (libp2p.abc.IMetrics method) (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) record_memory() (libp2p.rcmgr.metrics.Metrics method) record_message_received() (libp2p.transport.websocket.connection.WebSocketStats method) record_message_sent() (libp2p.transport.websocket.connection.WebSocketStats method) record_observation() (libp2p.host.observed_addr_manager.ObservedAddrManager method) record_open() (libp2p.transport.quic.stream.StreamTimeline method) record_reset() (libp2p.transport.quic.stream.StreamTimeline method) record_stream() (libp2p.rcmgr.metrics.Metrics method) record_success() (libp2p.utils.dns_utils.DNSResolutionMetrics method) record_successful_connection() (libp2p.network.AutoConnector method) refresh_peer_last_seen() (libp2p.kad_dht.routing_table.KBucket method) refresh_reservation() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) refresh_routing_table() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.kad_dht.peer_routing.PeerRouting method) (libp2p.kad_dht.PeerRouting method) register() (libp2p.discovery.mdns.broadcaster.PeerBroadcaster method) (libp2p.discovery.rendezvous.client.RendezvousClient method) (libp2p.discovery.rendezvous.RendezvousClient method) register_extension_handler() (libp2p.pubsub.gossipsub.GossipSub method) register_notifee() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) register_peer_discovered_handler() (libp2p.discovery.events.peerDiscovery.PeerDiscovery method) register_transport() (in module libp2p.transport) (libp2p.transport.TransportRegistry method) register_validator() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) RegistrationRecord (class in libp2p.discovery.rendezvous.pb.rendezvous_pb2) (class in libp2p.discovery.rendezvous.service) REJECTED (libp2p.relay.circuit_v2.resources.ReservationStatus attribute) rekey_manager (libp2p.security.noise.transport.Transport attribute) RELAY (libp2p.network.CommonTags attribute) relay (libp2p.relay.circuit_v2.resources.ReservationVoucher attribute) relay_id (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) RelayConfig (class in libp2p.relay.circuit_v2.config) RelayDiscovery (class in libp2p.relay.circuit_v2.discovery) RelayInfo (class in libp2p.relay.circuit_v2.discovery) RelayLimits (class in libp2p.relay.circuit_v2.resources) RelayPerformanceTracker (class in libp2p.relay.circuit_v2.performance_tracker) RelayResourceManager (class in libp2p.relay.circuit_v2.resources) RelayRole (class in libp2p.relay.circuit_v2.config) RelayStats (class in libp2p.relay.circuit_v2.performance_tracker) release_cadence (libp2p.observability.oso.models.HealthMetrics attribute) release_connection() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) release_memory() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.metrics.Metrics method) (libp2p.rcmgr.ResourceManager method) release_scoped_stream() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) release_stream() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) ReleaseCadenceMetric (class in libp2p.observability.oso.models) ReleaseInfo (class in libp2p.observability.oso.providers) releases_considered (libp2p.observability.oso.models.ReleaseCadenceMetric attribute) remote_encrypter (libp2p.security.secio.transport.SecioMsgReadWriter attribute) remote_encryption_parameters (libp2p.security.secio.transport.SessionParameters attribute) remote_peer (libp2p.security.base_session.BaseSession attribute) (libp2p.security.secio.transport.SessionParameters attribute) remote_peer_id() (libp2p.transport.quic.connection.QUICConnection method) remote_permanent_pubkey (libp2p.security.base_session.BaseSession attribute) remove() (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method) (libp2p.network.stream.net_stream.NetStream method) remove_conn() (libp2p.host.observed_addr_manager.ObservedAddrManager method) (libp2p.network.swarm.Swarm method) (libp2p.rcmgr.metrics.Metrics method) remove_connection() (libp2p.network.TagStore method) (libp2p.transport.websocket.manager.WebSocketConnectionManager method) remove_from_blacklist() (libp2p.pubsub.pubsub.Pubsub method) remove_handler() (libp2p.abc.IMultiselectMuxer method) (libp2p.protocol_muxer.multiselect.Multiselect method) (libp2p.request_response.api.RequestResponse method) (libp2p.request_response.RequestResponse method) remove_multiaddr() (libp2p.rcmgr.allowlist.Allowlist method) remove_peer() (libp2p.abc.IPubsubRouter method) (libp2p.kad_dht.routing_table.KBucket method) (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) (libp2p.rcmgr.allowlist.Allowlist method)

remove_peer_multiaddr() (libp2p.rcmgr.allowlist.Allowlist method) remove_port_mapping() (libp2p.discovery.upnp.upnp.UpnpManager method) remove_protocols() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) remove_refresh_done_callback() (libp2p.discovery.random_walk.rt_refresh_manager.RTRefreshManager method) (libp2p.discovery.random_walk.RTRefreshManager method) remove_service() (libp2p.discovery.mdns.listener.PeerListener method) remove_stream() (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.rcmgr.metrics.Metrics method) remove_stream_handler() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) remove_topic_validator() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) render_markdown_report() (in module libp2p.observability.oso.report) RendezvousClient (class in libp2p.discovery.rendezvous) (class in libp2p.discovery.rendezvous.client) RendezvousDiscovery (class in libp2p.discovery.rendezvous) (class in libp2p.discovery.rendezvous.discovery) RendezvousError RendezvousService (class in libp2p.discovery.rendezvous) (class in libp2p.discovery.rendezvous.service) repository (libp2p.observability.oso.models.ProjectMetadata attribute) request_client_certificate (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) RequestContext (class in libp2p.request_response) (class in libp2p.request_response.api) RequestDecodeError, [1] RequestEncodeError, [1] RequestResponse (class in libp2p.request_response) (class in libp2p.request_response.api) RequestResponseCodec (class in libp2p.request_response) (class in libp2p.request_response.codec) RequestResponseConfig (class in libp2p.request_response) (class in libp2p.request_response.api) RequestResponseError, [1] RequestTimeoutError, [1] RequestTransportError, [1] Reservation (class in libp2p.relay.circuit_v2.pb.circuit_pb2) (class in libp2p.relay.circuit_v2.resources) reservation_data_limit (libp2p.relay.circuit_v2.discovery.RelayInfo attribute) reservation_expires_at (libp2p.relay.circuit_v2.discovery.RelayInfo attribute) reservation_rate_per_ip (libp2p.relay.circuit_v2.config.HopConfig attribute) reservation_refresh_threshold (libp2p.relay.circuit_v2.config.ClientConfig attribute) RESERVATION_REFUSED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) reservation_ttl (libp2p.relay.circuit_v2.config.RelayConfig attribute) ReservationStatus (class in libp2p.relay.circuit_v2.resources) ReservationVoucher (class in libp2p.relay.circuit_v2.resources) reserve() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) RESET (libp2p.network.stream.net_stream.StreamState attribute) (libp2p.transport.quic.stream.StreamState attribute) reset() (libp2p.abc.IMuxedStream method) (libp2p.abc.INetStream method) (libp2p.network.stream.net_stream.NetStream method) (libp2p.rcmgr.metrics.Metrics method) (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) (libp2p.transport.quic.stream.QUICStream method) ResetInitiator (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) ResetReceiver (libp2p.stream_muxer.mplex.constants.HeaderTags attribute) resolve() (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) resolve_dns_bootstrap_to_ip4_tcp() (in module libp2p.filecoin) (in module libp2p.filecoin.bootstrap) resolve_multiaddr_with_retry() (in module libp2p.utils.dns_utils) resolve_relative_path() (in module libp2p.utils.paths) RESOURCE_LIMIT_EXCEEDED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) ResourceLimitExceeded ResourceLimits (class in libp2p.rcmgr) (class in libp2p.rcmgr.manager) ResourceManager (class in libp2p.rcmgr) (class in libp2p.rcmgr.manager) ResourceManagerException ResourceMetrics (class in libp2p.rcmgr.metrics) ResourceScopeClosed, [1] ResponseDecodeError, [1] ResponseEncodeError, [1] ResponseStatus (libp2p.discovery.rendezvous.pb.rendezvous_pb2.Message attribute) rest_multiaddr (libp2p.transport.websocket.multiaddr_utils.ParsedWebSocketMultiaddr attribute) retry_config (libp2p.network.swarm.Swarm attribute) roles (libp2p.relay.circuit_v2.config.RelayConfig attribute) RoutedHost (class in libp2p.host.routed_host) router (libp2p.pubsub.pubsub.Pubsub attribute) RoutingTable (class in libp2p.kad_dht) (class in libp2p.kad_dht.routing_table) RoutingTableProtocol (class in libp2p.discovery.random_walk.rt_refresh_manager) RoutingTableRefreshError, [1] RPC (class in libp2p.pubsub.pb.rpc_pb2) RPC.SubOpts (class in libp2p.pubsub.pb.rpc_pb2) RSA (libp2p.crypto.keys.KeyType attribute) RSAPrivateKey (class in libp2p.crypto.rsa) RSAPublicKey (class in libp2p.crypto.rsa) RTRefreshManager (class in libp2p.discovery.random_walk) (class in libp2p.discovery.random_walk.rt_refresh_manager) rtt() (libp2p.stream_muxer.yamux.Yamux method) run() (in module examples.autotls.autotls) (in module examples.tls.example_tls_client) (in module examples.tls.example_tls_server) (libp2p.abc.IHost method) (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousDiscovery method) (libp2p.host.basic_host.BasicHost method) (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.network.swarm.Swarm method) (libp2p.pubsub.gossipsub.GossipSub method) (libp2p.pubsub.pubsub.Pubsub method) (libp2p.relay.circuit_v2.discovery.RelayDiscovery method) (libp2p.relay.circuit_v2.protocol.CircuitV2Protocol method) (libp2p.relay.circuit_v2.transport.CircuitV2Listener method) (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.ServiceAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) (libp2p.tools.anyio_service.tasks.ChildServiceTask method) (libp2p.tools.anyio_service.tasks.FunctionTask method) (libp2p.tools.anyio_service.tasks.TaskAPI method) run_background_task() (libp2p.network.AutoConnector method) run_child_service() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.InternalManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) run_concurrent_random_walks() (libp2p.discovery.random_walk.random_walk.RandomWalk method) (libp2p.discovery.random_walk.RandomWalk method) run_daemon_child_service() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.InternalManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) run_daemon_task() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.InternalManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) run_handshake() (in module libp2p.security.insecure.transport) run_service() (libp2p.tools.anyio_service.AnyIOManager class method) (libp2p.tools.anyio_service.context.AnyIOManager class method) (libp2p.tools.anyio_service.context.TrioManager class method) (libp2p.tools.anyio_service.manager.AnyIOManager class method) run_task() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.InternalManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) runtime_package_versions (libp2p.observability.oso.models.DependencyTopologyMetric attribute) rw_lock (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute)

S

save_keypair() (in module libp2p) ScopeClosedException scorer (libp2p.pubsub.gossipsub.GossipSub attribute) seal_record() (in module libp2p.peer.envelope) SecioException SecioMsgReadWriter (class in libp2p.security.secio.transport) SecioPacketReadWriter (class in libp2p.security.secio.transport) Secp256k1 (libp2p.crypto.keys.KeyType attribute) Secp256k1PrivateKey (class in libp2p.crypto.secp256k1) Secp256k1PublicKey (class in libp2p.crypto.secp256k1) secure_inbound() (libp2p.abc.ISecureTransport method) (libp2p.security.insecure.transport.InsecureTransport method) (libp2p.security.noise.transport.Transport method) (libp2p.security.secio.transport.Transport method) (libp2p.security.security_multistream.SecurityMultistream method) (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) secure_outbound() (libp2p.abc.ISecureTransport method) (libp2p.security.insecure.transport.InsecureTransport method) (libp2p.security.noise.transport.Transport method) (libp2p.security.secio.transport.Transport method) (libp2p.security.security_multistream.SecurityMultistream method) (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) secured_conn (libp2p.stream_muxer.mplex.mplex.Mplex attribute) SecureSession (class in libp2p.security.secure_session) security_multistream (libp2p.transport.upgrader.TransportUpgrader attribute) security_proxy (libp2p.observability.oso.models.HealthMetrics attribute) SecurityError SecurityMultistream (class in libp2p.security.security_multistream) SecurityProxyMetric (class in libp2p.observability.oso.models) SecurityUpgradeFailure SedesException seen_messages (libp2p.pubsub.pubsub.Pubsub attribute) select() (libp2p.protocol_muxer.GenericMultistreamSelector method) (libp2p.records.ipns.IPNSValidator method) (libp2p.records.pubkey.PublicKeyValidator method) (libp2p.records.validator.BlankValidator method) (libp2p.records.validator.NamespacedValidator method) (libp2p.records.validator.Validator method) select_best_relay() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) select_from_minus() (libp2p.pubsub.gossipsub.GossipSub static method) select_one_of() (libp2p.abc.IMultiselectClient method) (libp2p.protocol_muxer.multiselect_client.MultiselectClient method) select_transport() (libp2p.security.security_multistream.SecurityMultistream method) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream method) self_id (libp2p.network.swarm.Swarm attribute) SelfEncryption send_command() (libp2p.host.basic_host.BasicHost method) send_message() (libp2p.stream_muxer.mplex.mplex.Mplex method) send_ping() (in module examples.autotls.autotls) send_recent_messages() (libp2p.pubsub.gossipsub.GossipSub method) send_request() (libp2p.request_response.api.RequestResponse method) (libp2p.request_response.RequestResponse method) send_rpc() (libp2p.pubsub.gossipsub.GossipSub method) seq (libp2p.peer.peer_record.PeerRecord attribute) (libp2p.peer.peerstore.PeerRecordState attribute) sequence (libp2p.records.ipns.ParsedIPNSRecord attribute) serialize() (libp2p.crypto.keys.PrivateKey method) (libp2p.crypto.keys.PublicKey method) (libp2p.security.noise.messages.NoiseHandshakePayload method) (libp2p.security.secio.transport.Proposal method) serialize_public_key() (libp2p.transport.quic.security.LibP2PKeyConverter static method) SERVER (libp2p.kad_dht.kad_dht.DHTMode attribute) Service (class in libp2p.tools.anyio_service) (class in libp2p.tools.anyio_service.api) ServiceAPI (class in libp2p.tools.anyio_service.api) ServiceException, [1] SessionParameters (class in libp2p.security.secio.transport) set_background_nursery() (libp2p.transport.quic.transport.QUICTransport method) (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) set_deadline() (libp2p.abc.IMuxedStream method) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) (libp2p.transport.quic.stream.QUICStream method) set_default_dns_metrics() (in module libp2p.utils.dns_utils) set_default_muxer() (in module libp2p) set_gauge() (libp2p.rcmgr.metrics.Metrics method) set_handler() (libp2p.request_response.api.RequestResponse method) (libp2p.request_response.RequestResponse method) set_listener_context() (libp2p.transport.quic.connection.QUICConnection method) set_local_record() (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) set_namespace_validator() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) set_nursery() (libp2p.bitswap.BitswapClient method) (libp2p.discovery.rendezvous.client.RendezvousClient method) (libp2p.discovery.rendezvous.RendezvousClient method) set_peer_id() (libp2p.transport.websocket.transport.WebsocketTransport method) (libp2p.transport.websocket.WebsocketTransport method) (libp2p.transport.WebsocketTransport method) set_protocol() (libp2p.abc.INetStream method) (libp2p.network.stream.net_stream.NetStream method) set_protocol_peer_stream_limit() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) set_protocol_stream_limit() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) set_protocols() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) set_read_deadline() (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) set_resource_manager() (libp2p.network.swarm.Swarm method) set_resource_scope() (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.transport.quic.connection.QUICConnection method) set_service_peer_stream_limit() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) set_service_stream_limit() (libp2p.rcmgr.manager.ResourceManager method) (libp2p.rcmgr.ResourceManager method) set_state() (libp2p.network.stream.net_stream.NetStream method) set_stream_handler() (libp2p.abc.IHost method) (libp2p.abc.INetwork method) (libp2p.host.basic_host.BasicHost method) (libp2p.network.swarm.Swarm method) (libp2p.transport.quic.connection.QUICConnection method) set_swarm() (libp2p.transport.quic.transport.QUICTransport method) set_topic_validator() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) set_transport_info() (libp2p.network.connection.swarm_connection.SwarmConn method) set_ttl() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) set_validator() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) set_write_deadline() (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) setup_dialer_node() (in module examples.nat.dialer) setup_listener_node() (in module examples.nat.listener) setup_logging() (in module examples.path_handling.path_handling) (in module libp2p.utils.logging) setup_relay_node() (in module examples.nat.relay) sha256_digest() (in module libp2p.peer.id) shared_key (libp2p.security.secio.transport.SessionParameters attribute) shared_prefix_len() (in module libp2p.kad_dht.utils) shift() (libp2p.pubsub.mcache.MessageCache method) should_do_primitive_key_exchang() (libp2p.security.tls.io.TLSStreamReadWriter method) should_republish() (libp2p.kad_dht.provider_store.ProviderRecord method) sign() (libp2p.crypto.ecc.ECCPrivateKey method) (libp2p.crypto.ed25519.Ed25519PrivateKey method) (libp2p.crypto.keys.PrivateKey method) (libp2p.crypto.rsa.RSAPrivateKey method) (libp2p.crypto.secp256k1.Secp256k1PrivateKey method) sign_key (libp2p.pubsub.pubsub.Pubsub attribute) signature (libp2p.peer.envelope.Envelope attribute) (libp2p.security.tls.certificate.SignedKey attribute) (libp2p.security.tls.SignedKey attribute) signature_validator() (in module libp2p.pubsub.validators) SignedKey (class in libp2p.security.tls) (class in libp2p.security.tls.certificate) size() (libp2p.bitswap.MemoryBlockStore method) (libp2p.discovery.random_walk.rt_refresh_manager.RoutingTableProtocol method) (libp2p.kad_dht.provider_store.ProviderStore method) (libp2p.kad_dht.routing_table.KBucket method) (libp2p.kad_dht.routing_table.RoutingTable method) (libp2p.kad_dht.RoutingTable method) (libp2p.kad_dht.value_store.ValueStore method) (libp2p.kad_dht.ValueStore method)

size_len_bytes (libp2p.io.msgio.BaseMsgReadWriter attribute) (libp2p.io.msgio.FixedSizeLenMsgReadWriter attribute) (libp2p.security.noise.io.NoisePacketReadWriter attribute) (libp2p.security.secio.transport.SecioPacketReadWriter attribute) sni (libp2p.transport.websocket.multiaddr_utils.ParsedWebSocketMultiaddr attribute) SOCKSConnectionManager (class in libp2p.transport.websocket.proxy) sort_connections() (libp2p.network.ConnectionPruner method) sort_peer_ids_by_distance() (in module libp2p.kad_dht.utils) source_status (libp2p.observability.oso.HealthReport attribute) (libp2p.observability.oso.models.HealthReport attribute) SourceStatus (class in libp2p.observability.oso.models) spam_protection_enabled (libp2p.pubsub.gossipsub.GossipSub attribute) split() (libp2p.kad_dht.routing_table.KBucket method) split_key() (in module libp2p.records.utils) stars (libp2p.observability.oso.models.PopularityMetric attribute) (libp2p.observability.oso.providers.PopularityInfo attribute) start() (libp2p.abc.IMuxedConn method) (libp2p.abc.IPerf method) (libp2p.bitswap.BitswapClient method) (libp2p.discovery.bootstrap.BootstrapDiscovery method) (libp2p.discovery.mdns.mdns.MDNSDiscovery method) (libp2p.discovery.random_walk.rt_refresh_manager.RTRefreshManager method) (libp2p.discovery.random_walk.RTRefreshManager method) (libp2p.network.AutoConnector method) (libp2p.network.connection.swarm_connection.SwarmConn method) (libp2p.network.ConnectionPruner method) (libp2p.perf.IPerf method) (libp2p.perf.perf_service.PerfService method) (libp2p.perf.PerfService method) (libp2p.stream_muxer.mplex.mplex.Mplex method) (libp2p.stream_muxer.yamux.Yamux method) (libp2p.transport.quic.connection.QUICConnection method) start_cleanup_task() (libp2p.abc.IPeerStore method) (libp2p.peer.peerstore.PeerStore method) start_observing_topic() (libp2p.pubsub.gossipsub.GossipSub method) state (libp2p.network.stream.net_stream.NetStream property) (libp2p.transport.quic.stream.QUICStream property) Stats (class in libp2p.tools.anyio_service) (class in libp2p.tools.anyio_service.stats) stats (libp2p.tools.anyio_service.AnyIOManager property) (libp2p.tools.anyio_service.api.ManagerAPI property) (libp2p.tools.anyio_service.context.AnyIOManager property) (libp2p.tools.anyio_service.context.TrioManager property) (libp2p.tools.anyio_service.manager.AnyIOManager property) Status (class in libp2p.relay.circuit_v2.pb.circuit_pb2) status (libp2p.relay.circuit_v2.resources.Reservation property) StatusCode (class in libp2p.relay.circuit_v2.protocol_buffer) STOP (libp2p.relay.circuit_v2.config.RelayRole attribute) stop() (libp2p.abc.IPerf method) (libp2p.bitswap.BitswapClient method) (libp2p.discovery.bootstrap.BootstrapDiscovery method) (libp2p.discovery.mdns.listener.PeerListener method) (libp2p.discovery.mdns.mdns.MDNSDiscovery method) (libp2p.discovery.random_walk.rt_refresh_manager.RTRefreshManager method) (libp2p.discovery.random_walk.RTRefreshManager method) (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) (libp2p.network.AutoConnector method) (libp2p.network.ConnectionPruner method) (libp2p.perf.IPerf method) (libp2p.perf.perf_service.PerfService method) (libp2p.perf.PerfService method) (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.ManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) (libp2p.tools.timed_cache.base_timed_cache.BaseTimedCache method) STOP_FAILED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) stop_observing_topic() (libp2p.pubsub.gossipsub.GossipSub method) StopMessage (class in libp2p.relay.circuit_v2.pb.circuit_pb2) stream (libp2p.io.trio.TrioTCPStream attribute) (libp2p.network.connection.raw_connection.RawConnection attribute) STREAM_ACCEPT_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_BATCH_SIZE (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_BLOCKS (libp2p.rcmgr.metrics.MetricType attribute) STREAM_CLOSE_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_ERROR_RETRY_ATTEMPTS (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_ERROR_RETRY_BACKOFF_FACTOR (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_ERROR_RETRY_DELAY (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_FLOW_CONTROL_WINDOW (libp2p.transport.quic.config.QUICTransportConfig attribute) stream_handler() (libp2p.pubsub.pubsub.Pubsub method) stream_id (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) (libp2p.transport.quic.stream.QUICStream property) STREAM_KEEP_ALIVE_INTERVAL (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_MEMORY_LIMIT_PER_CONNECTION (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_MEMORY_LIMIT_PER_STREAM (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_METRICS_COLLECTION_INTERVAL (libp2p.transport.quic.config.QUICTransportConfig attribute) stream_muxers (libp2p.security.noise.messages.NoiseExtensions attribute) STREAM_OPEN_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_PROCESSING_CONCURRENCY (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_READ_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_RECEIVE_BUFFER_HIGH_WATERMARK (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_RECEIVE_BUFFER_LOW_WATERMARK (libp2p.transport.quic.config.QUICTransportConfig attribute) STREAM_RESET_ERROR_CODE (libp2p.transport.quic.config.QUICTransportConfig attribute) stream_window (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) STREAM_WRITE_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig attribute) stream_writer (libp2p.security.tls.io.TLSReadWriter attribute) (libp2p.security.tls.TLSReadWriter attribute) StreamClosed StreamDirection (class in libp2p.transport.quic.stream) StreamEOF StreamError StreamFailure StreamID (class in libp2p.stream_muxer.mplex.datastructures) StreamOrConnLimitExceeded StreamReset streams (libp2p.network.connection.swarm_connection.SwarmConn attribute) (libp2p.stream_muxer.mplex.mplex.Mplex attribute) STREAMS_INBOUND (libp2p.rcmgr.metrics.MetricType attribute) streams_lock (libp2p.stream_muxer.mplex.mplex.Mplex attribute) streams_msg_channels (libp2p.stream_muxer.mplex.mplex.Mplex attribute) STREAMS_OUTBOUND (libp2p.rcmgr.metrics.MetricType attribute) StreamState (class in libp2p.network.stream.net_stream) (class in libp2p.transport.quic.stream) StreamTimeline (class in libp2p.transport.quic.stream) strict_signing (libp2p.pubsub.pubsub.Pubsub attribute) strict_validation (libp2p.kad_dht.kad_dht.KadDHT property) (libp2p.kad_dht.KadDHT property) (libp2p.records.validator.NamespacedValidator property) stringGen() (in module libp2p.discovery.mdns.utils) subaddress (libp2p.filecoin.FilecoinAddress property) subscribe() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) subscribed_topics_receive (libp2p.pubsub.pubsub.Pubsub attribute) subscribed_topics_send (libp2p.pubsub.pubsub.Pubsub attribute) success_count (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) (libp2p.utils.dns_utils.DNSResolutionMetrics attribute) success_rate (libp2p.relay.circuit_v2.performance_tracker.RelayStats property) supports_protocol_feature() (libp2p.pubsub.gossipsub.GossipSub method) supports_protocols() (libp2p.abc.IPeerData method) (libp2p.abc.IPeerStore method) (libp2p.abc.IProtoBook method) (libp2p.peer.peerdata.PeerData method) (libp2p.peer.peerstore.PeerStore method) supports_scoring() (libp2p.pubsub.gossipsub.GossipSub method) supports_v13_features() (libp2p.pubsub.gossipsub.GossipSub method) supports_v20_features() (libp2p.pubsub.gossipsub.GossipSub method) Swarm (class in libp2p.network.swarm) swarm (libp2p.network.connection.swarm_connection.SwarmConn attribute) SwarmConn (class in libp2p.network.connection.swarm_connection) SwarmDialAllFailedError SwarmException switch_mode() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method)

T

tag_peer() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) (libp2p.network.TagStore method) tag_store (libp2p.network.swarm.Swarm attribute) TagInfo (class in libp2p.network) tags (libp2p.network.TagInfo attribute) TagStore (class in libp2p.network) TaskAPI (class in libp2p.tools.anyio_service.tasks) tasks (libp2p.tools.anyio_service.Stats attribute) (libp2p.tools.anyio_service.stats.Stats attribute) TaskStats (class in libp2p.tools.anyio_service) (class in libp2p.tools.anyio_service.stats) TaskType (class in libp2p.tools.anyio_service) (class in libp2p.tools.anyio_service.tasks) TaskWithChildrenAPI (class in libp2p.tools.anyio_service.tasks) TCP (class in libp2p.transport) (class in libp2p.transport.tcp.tcp) TCPListener (class in libp2p.transport.tcp.tcp) test_tcp_basic_connection() (in module examples.tcp.test_tcp_data_transfer) test_tcp_bidirectional_transfer() (in module examples.tcp.test_tcp_data_transfer) test_tcp_data_transfer() (in module examples.tcp.test_tcp_data_transfer) test_tcp_large_data_transfer() (in module examples.tcp.test_tcp_data_transfer) TestExtension (class in libp2p.pubsub.pb.rpc_pb2) time_seconds (libp2p.perf.PerfOutput attribute) (libp2p.perf.types.PerfOutput attribute) time_since_last_publish (libp2p.pubsub.floodsub.FloodSub attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) time_to_live (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) timeout (libp2p.request_response.api.RequestResponseConfig attribute) (libp2p.request_response.RequestResponseConfig attribute) TimeoutConfig (class in libp2p.relay.circuit_v2.config) TimeoutError timeouts (libp2p.relay.circuit_v2.config.RelayConfig attribute) timestamp (libp2p.pubsub.pubsub.ValidationResult attribute) timestamp_seq() (in module libp2p.peer.peer_record) tls_client_config (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) tls_config (libp2p.transport.websocket.listener.WebsocketListenerConfig attribute) (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketListenerConfig attribute) tls_server_config (libp2p.transport.websocket.transport.WebsocketConfig attribute) (libp2p.transport.websocket.WebsocketConfig attribute) TLSConfig (class in libp2p.transport.quic.security) TLSReadWriter (class in libp2p.security.tls) (class in libp2p.security.tls.io) TLSStreamReadWriter (class in libp2p.security.tls.io) TLSTransport (class in libp2p.security.tls) (class in libp2p.security.tls.transport) to_base58() (libp2p.peer.id.ID method) to_bytes() (libp2p.crypto.ecc.ECCPrivateKey method) (libp2p.crypto.ecc.ECCPublicKey method) (libp2p.crypto.ed25519.Ed25519PrivateKey method) (libp2p.crypto.ed25519.Ed25519PublicKey method) (libp2p.crypto.keys.Key method) (libp2p.crypto.rsa.RSAPrivateKey method) (libp2p.crypto.rsa.RSAPublicKey method) (libp2p.crypto.secp256k1.Secp256k1PrivateKey method) (libp2p.crypto.secp256k1.Secp256k1PublicKey method) (libp2p.peer.id.ID method)

to_dict() (libp2p.network.TagInfo method) (libp2p.observability.oso.HealthReport method) (libp2p.observability.oso.models.HealthReport method) to_multibase() (libp2p.peer.id.ID method) to_proto() (libp2p.relay.circuit_v2.resources.Reservation method) to_protobuf() (libp2p.abc.IPeerRecord method) (libp2p.peer.peer_record.PeerRecord method) (libp2p.security.noise.messages.NoiseExtensions method) to_protobuf_register() (libp2p.discovery.rendezvous.service.RegistrationRecord method) to_string() (libp2p.peer.id.ID method) TooManyChildrenException, [1] topic_ids (libp2p.abc.IPubsub property) (libp2p.pubsub.pubsub.Pubsub property) topic_observation (libp2p.pubsub.gossipsub.GossipSub attribute) topic_validators (libp2p.pubsub.pubsub.Pubsub attribute) TopicDescriptor (class in libp2p.pubsub.pb.rpc_pb2) TopicDescriptor.AuthOpts (class in libp2p.pubsub.pb.rpc_pb2) TopicDescriptor.EncOpts (class in libp2p.pubsub.pb.rpc_pb2) topics (libp2p.pubsub.mcache.CacheEntry attribute) TopicValidator (class in libp2p.pubsub.pubsub) total_attempts (libp2p.relay.circuit_v2.performance_tracker.RelayStats property) total_count (libp2p.tools.anyio_service.stats.TaskStats attribute) (libp2p.tools.anyio_service.TaskStats attribute) total_dependency_entries (libp2p.observability.oso.models.DependencyTopologyMetric attribute) track_data_transfer() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) (libp2p.relay.circuit_v2.resources.Reservation method) TrackedRawConnection (class in libp2p.relay.circuit_v2.transport) Transport (class in libp2p.security.noise.transport) (class in libp2p.security.secio.transport) transport (libp2p.network.swarm.Swarm attribute) TransportRegistry (class in libp2p.transport) transports (libp2p.security.security_multistream.SecurityMultistream property) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream property) TransportUpgrader (class in libp2p.transport.upgrader) TrioManager (class in libp2p.tools.anyio_service.context) TrioSubscriptionAPI (class in libp2p.pubsub.subscription) TrioTCPStream (class in libp2p.io.trio) trust_peer_cert_pem() (libp2p.security.tls.TLSTransport method) (libp2p.security.tls.transport.TLSTransport method) try_select() (libp2p.abc.IMultiselectClient method) (libp2p.protocol_muxer.multiselect_client.MultiselectClient method) ttl (libp2p.peer.peerdata.PeerData attribute) (libp2p.records.ipns.ParsedIPNSRecord attribute) type (libp2p.perf.PerfOutput attribute) (libp2p.perf.types.PerfOutput attribute)

U

UnavailableError unique_contributors (libp2p.observability.oso.models.ContributorTrendMetric attribute) unique_packages (libp2p.observability.oso.models.DependencyTopologyMetric attribute) UNKNOWN (libp2p.host.autonat.autonat.AutoNATStatus attribute) (libp2p.host.observed_addr_manager.NATDeviceType attribute) (libp2p.rcmgr.Direction attribute) (libp2p.rcmgr.metrics.Direction attribute) unmarshal_envelope() (in module libp2p.peer.envelope) unmarshal_public_key() (in module libp2p.records.pubkey) unmarshal_record() (in module libp2p.peer.peer_record) unprotect() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) (libp2p.network.TagStore method) unregister() (libp2p.discovery.mdns.broadcaster.PeerBroadcaster method) (libp2p.discovery.rendezvous.client.RendezvousClient method) (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousClient method) (libp2p.discovery.rendezvous.RendezvousDiscovery method) unregister_extension_handler() (libp2p.pubsub.gossipsub.GossipSub method) unsubscribe() (libp2p.abc.IPubsub method) (libp2p.abc.ISubscriptionAPI method) (libp2p.pubsub.pubsub.Pubsub method) (libp2p.pubsub.subscription.TrioSubscriptionAPI method) unsubscribe_back_off (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) unsubscribe_fn (libp2p.pubsub.subscription.TrioSubscriptionAPI attribute) untag_peer() (libp2p.abc.INetworkService method) (libp2p.network.swarm.Swarm method) (libp2p.network.TagStore method)

update() (libp2p.peer.id.IdentityHash method) update_activity() (libp2p.transport.websocket.connection.WebSocketStats method) update_last_identified() (libp2p.abc.IPeerData method) (libp2p.peer.peerdata.PeerData method) update_service() (libp2p.discovery.mdns.listener.PeerListener method) update_status() (libp2p.host.autonat.autonat.AutoNATService method) upgrade_connection() (libp2p.transport.upgrader.TransportUpgrader method) upgrade_inbound_connection() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) upgrade_inbound_raw_conn() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) upgrade_outbound_connection() (libp2p.abc.IHost method) (libp2p.host.basic_host.BasicHost method) upgrade_outbound_raw_conn() (libp2p.abc.INetwork method) (libp2p.network.swarm.Swarm method) upgrade_security() (libp2p.transport.upgrader.TransportUpgrader method) UpgradeFailure upgrader (libp2p.network.swarm.Swarm attribute) upload_bytes (libp2p.perf.PerfOutput attribute) (libp2p.perf.types.PerfOutput attribute) upnp (libp2p.host.basic_host.BasicHost attribute) UpnpManager (class in libp2p.discovery.upnp.upnp) upsert_add() (in module libp2p.network) upsert_bounded() (in module libp2p.network) upsert_set() (in module libp2p.network) upsert_tag() (libp2p.network.TagStore method) USER (libp2p.tools.anyio_service.tasks.TaskType attribute) (libp2p.tools.anyio_service.TaskType attribute) utc_now_iso() (in module libp2p.observability.oso.models)

V

valid_peer_ids() (libp2p.peer.peerstore.PeerStore method) validate() (libp2p.abc.IEnvelope method) (libp2p.peer.envelope.Envelope method) (libp2p.records.ipns.IPNSValidator method) (libp2p.records.pubkey.PublicKeyValidator method) (libp2p.records.validator.BlankValidator method) (libp2p.records.validator.NamespacedValidator method) (libp2p.records.validator.Validator method) (libp2p.transport.websocket.AutoTLSConfig method) (libp2p.transport.websocket.transport.WebsocketConfig method) (libp2p.transport.websocket.WebsocketConfig method) validate_certificate_key_match() (libp2p.transport.quic.security.QUICTLSSecurityConfig method) validate_config() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) validate_msg() (libp2p.pubsub.pubsub.Pubsub method) validate_proxy_url() (in module libp2p.transport.websocket.proxy_env) validate_rsa_key_length() (in module libp2p.crypto.rsa) validate_rsa_key_size() (in module libp2p.crypto.rsa) validate_with_details() (libp2p.records.ipns.IPNSValidator method) validation_cache (libp2p.pubsub.pubsub.Pubsub attribute) validation_timeout (libp2p.pubsub.pubsub.Pubsub attribute) ValidationCache (class in libp2p.pubsub.pubsub) ValidationError ValidationResult (class in libp2p.pubsub.pubsub) Validator (class in libp2p.records.validator)

validator (libp2p.pubsub.pubsub.TopicValidator attribute) validator_by_key() (libp2p.records.validator.NamespacedValidator method) validity (libp2p.records.ipns.ParsedIPNSRecord attribute) validity_type (libp2p.records.ipns.ParsedIPNSRecord attribute) ValidityType (class in libp2p.records.ipns) value (libp2p.network.TagInfo attribute) (libp2p.records.ipns.ParsedIPNSRecord attribute) ValueStore (class in libp2p.kad_dht) (class in libp2p.kad_dht.value_store) VarIntLengthMsgReadWriter (class in libp2p.io.msgio) verify() (libp2p.crypto.ecc.ECCPublicKey method) (libp2p.crypto.ed25519.Ed25519PublicKey method) (libp2p.crypto.keys.PublicKey method) (libp2p.crypto.rsa.RSAPublicKey method) (libp2p.crypto.secp256k1.Secp256k1PublicKey method) verify_certificate_chain() (in module libp2p.security.tls) (in module libp2p.security.tls.certificate) verify_handshake_payload_sig() (in module libp2p.security.noise.messages) verify_mode (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) verify_peer_certificate() (libp2p.transport.quic.security.PeerAuthenticator method) verify_peer_identity() (libp2p.transport.quic.security.QUICTLSConfigManager method) verify_reservation() (libp2p.relay.circuit_v2.resources.RelayResourceManager method) version (libp2p.observability.oso.models.ProjectMetadata attribute) version_spec (libp2p.observability.oso.models.DependencyEntry attribute)

W

wait_done() (libp2p.tools.anyio_service.tasks.ChildServiceTask method) (libp2p.tools.anyio_service.tasks.FunctionTask method) (libp2p.tools.anyio_service.tasks.TaskAPI method) wait_finished() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.ManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) wait_for_peer() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) wait_for_subscription() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) wait_ready_for_io() (libp2p.transport.quic.stream.QUICStream method) wait_started() (libp2p.tools.anyio_service.AnyIOManager method) (libp2p.tools.anyio_service.api.ManagerAPI method) (libp2p.tools.anyio_service.context.AnyIOManager method) (libp2p.tools.anyio_service.context.TrioManager method) (libp2p.tools.anyio_service.manager.AnyIOManager method) wait_until_ready() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) want_block() (libp2p.bitswap.BitswapClient method) watchers (libp2p.observability.oso.models.PopularityMetric attribute) (libp2p.observability.oso.providers.PopularityInfo attribute) WebsocketConfig (class in libp2p.transport.websocket) (class in libp2p.transport.websocket.transport) WebSocketConnectionError WebSocketConnectionManager (class in libp2p.transport.websocket.manager) WebSocketHandshakeError WebsocketListener (class in libp2p.transport.websocket) (class in libp2p.transport.websocket.listener) WebsocketListenerConfig (class in libp2p.transport.websocket) (class in libp2p.transport.websocket.listener) WebSocketMessageError WebSocketProtocolError WebSocketStats (class in libp2p.transport.websocket.connection) WebsocketTransport (class in libp2p.transport) (class in libp2p.transport.websocket) (class in libp2p.transport.websocket.transport) WebSocketTransport (in module libp2p.transport.websocket) webtransport_certhashes (libp2p.security.noise.messages.NoiseExtensions attribute) webtransport_support (libp2p.security.noise.transport.Transport attribute) weekly_commit_counts (libp2p.observability.oso.models.ContributorTrendMetric attribute) window() (libp2p.pubsub.mcache.MessageCache method) window_size (libp2p.pubsub.mcache.MessageCache attribute) WithAdvancedTLS() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) WithAutoTLS() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport)

WithHandshakeTimeout() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) WithMaxConnections() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) WithProxy() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) WithProxyFromEnvironment() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) WithTLSClientConfig() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) WithTLSServerConfig() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) write() (libp2p.abc.IMultiselectCommunicator method) (libp2p.io.abc.Writer method) (libp2p.io.trio.TrioTCPStream method) (libp2p.network.connection.raw_connection.RawConnection method) (libp2p.network.stream.net_stream.NetStream method) (libp2p.protocol_muxer.multiselect_communicator.MultiselectCommunicator method) (libp2p.relay.circuit_v2.transport.TrackedRawConnection method) (libp2p.security.insecure.transport.InsecureSession method) (libp2p.security.pnet.psk_conn.PskConn method) (libp2p.security.secure_session.SecureSession method) (libp2p.security.tls.io.TLSStreamReadWriter method) (libp2p.stream_muxer.mplex.mplex_stream.MplexStream method) (libp2p.transport.quic.connection.QUICConnection method) (libp2p.transport.quic.stream.QUICStream method) (libp2p.transport.websocket.connection.P2PWebSocketConnection method) (libp2p.transport.websocket.P2PWebSocketConnection method) write_and_read_temp_file() (in module examples.path_handling.path_handling) write_block_size (libp2p.perf.PerfInit attribute) (libp2p.perf.types.PerfInit attribute) WRITE_CLOSED (libp2p.transport.quic.stream.StreamState attribute) write_deadline (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) write_json_report() (in module libp2p.observability.oso.report) write_lock (libp2p.io.trio.TrioTCPStream attribute) write_markdown_report() (in module libp2p.observability.oso.report) write_msg() (libp2p.io.abc.MsgWriter method) (libp2p.io.msgio.BaseMsgReadWriter method) (libp2p.pubsub.pubsub.Pubsub method) (libp2p.security.noise.io.BaseNoiseMsgReadWriter method) (libp2p.security.secio.transport.SecioMsgReadWriter method) (libp2p.security.tls.io.TLSReadWriter method) (libp2p.security.tls.TLSReadWriter method) write_to_stream() (libp2p.stream_muxer.mplex.mplex.Mplex method) WriteCloser (class in libp2p.io.abc) Writer (class in libp2p.io.abc)

X

X25519 (libp2p.crypto.keys.KeyType attribute)

xor_distance() (in module libp2p.kad_dht.utils) xor_id (libp2p.peer.id.ID property)

Y

Yamux (class in libp2p.stream_muxer.yamux)