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) 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.async_service.abc.TaskWithChildrenAPI method) (libp2p.tools.async_service.base.BaseTaskWithChildren 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.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) 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.peer.peerstore.PeerStore 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) apply_fallbacks() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method) as_service() (in module libp2p.tools.async_service.base) attach() (libp2p.abc.IPubsubRouter method) (libp2p.pubsub.floodsub.FloodSub method) (libp2p.pubsub.gossipsub.GossipSub method) authenticate() (libp2p.crypto.authenticated_encryption.MacAndCipher method) auto_relay_timeout (libp2p.relay.circuit_v2.config.ClientConfig attribute) 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)

B

back_off (libp2p.pubsub.gossipsub.GossipSub attribute) background_trio_service() (in module libp2p.tools.async_service.trio_service) base58 (libp2p.peer.id.ID property) BaseChildServiceTask (class in libp2p.tools.async_service.base) BaseFunctionTask (class in libp2p.tools.async_service.base) BaseLibp2pError BaseManager (class in libp2p.tools.async_service.base) 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.async_service.base) BaseTaskWithChildren (class in libp2p.tools.async_service.base) BaseTimedCache (class in libp2p.tools.timed_cache.base_timed_cache) BasicHost (class in libp2p.host.basic_host) BitswapClient (class in libp2p.bitswap)

BitswapError blacklisted_peers (libp2p.pubsub.pubsub.Pubsub attribute) 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 BlockStore (class in libp2p.bitswap) BlockTooLargeError BlockUnavailableError bootstrap (libp2p.host.basic_host.BasicHost attribute) bootstrap_relays (libp2p.relay.circuit_v2.config.RelayConfig attribute) BootstrapDiscovery (class in libp2p.discovery.bootstrap) buf (libp2p.security.secure_session.SecureSession attribute) 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)

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_peer_id() (libp2p.security.secio.transport.Proposal method) 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.async_service.abc.ManagerAPI method) (libp2p.tools.async_service.abc.TaskAPI method) (libp2p.tools.async_service.trio_service.ChildServiceTask method) (libp2p.tools.async_service.trio_service.FunctionTask method) (libp2p.tools.async_service.trio_service.TrioManager 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) child_manager (libp2p.tools.async_service.base.BaseChildServiceTask attribute) children (libp2p.tools.async_service.abc.TaskWithChildrenAPI attribute) ChildServiceTask (class in libp2p.tools.async_service.trio_service) 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_blacklist() (libp2p.pubsub.pubsub.Pubsub method) clear_cache() (libp2p.discovery.rendezvous.discovery.RendezvousDiscovery method) (libp2p.discovery.rendezvous.RendezvousDiscovery 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_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_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) combine_configs() (in module libp2p.transport.websocket) (in module libp2p.transport.websocket.transport) common_stream_handler (libp2p.network.swarm.Swarm 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_HANDSHAKE_TIMEOUT (libp2p.transport.quic.config.QUICTransportConfig 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 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) 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) continuously_read_stream() (libp2p.pubsub.pubsub.Pubsub method) 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) ControlPrune (class in libp2p.pubsub.pb.rpc_pb2) 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_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.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)

D

daemon (libp2p.tools.async_service.abc.TaskAPI attribute) DaemonTaskExit 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_signed_key() (in module libp2p.security.tls.certificate) decode_uvarint() (in module libp2p.utils.varint) decode_uvarint_from_stream() (in module libp2p.utils) (in module libp2p.utils.varint) decode_varint_from_bytes() (in module libp2p.utils) (in module libp2p.utils.varint) decode_varint_with_size() (in module libp2p.utils) (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_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) 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.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.ControlPrune 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.TopicDescriptor attribute) (libp2p.pubsub.pb.rpc_pb2.TopicDescriptor.AuthOpts attribute) (libp2p.pubsub.pb.rpc_pb2.TopicDescriptor.EncOpts 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) 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.async_service.abc.ManagerAPI property) (libp2p.tools.async_service.base.BaseManager 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_peers (libp2p.pubsub.gossipsub.GossipSub attribute) (libp2p.tools.constants.GossipsubParams attribute) Direction (class in libp2p.rcmgr) (class in libp2p.rcmgr.metrics) direction (libp2p.transport.quic.stream.QUICStream property) discard_child() (libp2p.tools.async_service.abc.TaskWithChildrenAPI method) (libp2p.tools.async_service.base.BaseTaskWithChildren 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) 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) 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) emit_control_message() (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_peer_discovered() (libp2p.discovery.events.peerDiscovery.PeerDiscovery method) emit_prune() (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) (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_signed_key() (in module libp2p.security.tls.certificate) encode_uvarint() (in module libp2p.utils) (in module libp2p.utils.varint) encode_varint_prefixed() (in module libp2p.utils) (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)

env_to_send_in_RPC() (in module libp2p.peer.peerstore) Envelope (class in libp2p.peer.envelope) envelope (libp2p.peer.peerstore.PeerRecordState 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_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_listener_nursery_created (libp2p.network.swarm.Swarm 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.tls module examples.tls.example_tls_client module examples.tls.example_tls_server 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) 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) extensions (libp2p.security.noise.messages.NoiseHandshakePayload attribute) external_api() (in module libp2p.tools.async_service.trio_service) 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)

F

failure_count (libp2p.relay.circuit_v2.performance_tracker.RelayStats attribute) fanout (libp2p.abc.IPubsubRouter attribute) (libp2p.pubsub.gossipsub.GossipSub attribute) fanout_heartbeat() (libp2p.pubsub.gossipsub.GossipSub method) 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_free_port() (in module libp2p.utils) 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.async_service.stats.TaskStats 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) 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) FunctionTask (class in libp2p.tools.async_service.trio_service)

G

generate_certificate() (in module libp2p.security.tls) (in module libp2p.security.tls.certificate) (libp2p.transport.quic.security.CertificateGenerator method) generate_fixed_private_key() (in module examples.nat.dialer) (in module examples.nat.listener) (in module examples.nat.relay) 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) 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) (in module libp2p.utils.version) get_all_cids() (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore 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) get_blacklisted_peers() (libp2p.pubsub.pubsub.Pubsub method) get_block() (libp2p.bitswap.BitswapClient method) (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) 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_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_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_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_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.async_service.abc.ServiceAPI method) (libp2p.tools.async_service.base.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_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_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_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) 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_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_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.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_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.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_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_transport() (libp2p.transport.TransportRegistry method) get_transport_addresses() (libp2p.abc.INetConn method) (libp2p.network.connection.swarm_connection.SwarmConn 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) 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_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_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) handlers (libp2p.abc.IMultiselectMuxer 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_block() (libp2p.bitswap.BlockStore method) (libp2p.bitswap.MemoryBlockStore method) 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_trio_task (libp2p.tools.async_service.trio_service.FunctionTask property) 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) 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.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) IHostWithStreamHandlers (class in libp2p.relay.circuit_v2.protocol) 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) InternalError InternalManagerAPI (class in libp2p.tools.async_service.abc) 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) IPFSTimestamp (class in libp2p.bitswap.pb.unixfs_pb2) 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.async_service.abc.ManagerAPI property) (libp2p.tools.async_service.trio_service.TrioManager 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.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_dns_addr() (libp2p.discovery.bootstrap.BootstrapDiscovery method) is_done (libp2p.tools.async_service.abc.TaskAPI property) (libp2p.tools.async_service.base.BaseChildServiceTask property) (libp2p.tools.async_service.trio_service.FunctionTask property) is_empty() (libp2p.rcmgr.allowlist.Allowlist method) (libp2p.security.noise.messages.NoiseExtensions method) is_established (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.async_service.abc.ManagerAPI property) (libp2p.tools.async_service.trio_service.TrioManager 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_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.async_service.abc.ManagerAPI property) (libp2p.tools.async_service.base.BaseManager property) is_secure (libp2p.transport.websocket.connection.WebSocketStats attribute) is_started (libp2p.tools.async_service.abc.ManagerAPI property) (libp2p.tools.async_service.trio_service.TrioManager property) (libp2p.transport.quic.connection.QUICConnection property) is_valid (libp2p.pubsub.pubsub.ValidationResult attribute) is_valid_handshake() (in module libp2p.protocol_muxer.multiselect) (in module libp2p.protocol_muxer.multiselect_client) is_valid_timestamp() (in module libp2p.kad_dht.kad_dht) is_valid_websocket_multiaddr() (in module libp2p.transport.websocket.multiaddr_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) ISubscriptionAPI (class in libp2p.abc) iterate_tasks() (libp2p.tools.async_service.base.BaseFunctionTask class method) (libp2p.tools.async_service.trio_service.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)

K

KadDHT (class in libp2p.kad_dht) (class in libp2p.kad_dht.kad_dht) KBucket (class in libp2p.kad_dht.routing_table) 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_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.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.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.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.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.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.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.async_service module libp2p.tools.async_service.abc module libp2p.tools.async_service.base module libp2p.tools.async_service.exceptions module libp2p.tools.async_service.stats module libp2p.tools.async_service.trio_service module libp2p.tools.async_service.typing 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 module libp2p.utils.logging module libp2p.utils.multiaddr_utils 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 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) listener_nursery (libp2p.network.swarm.Swarm attribute) 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.tls.example_tls_client) (in module examples.tls.example_tls_server) make_data_to_be_signed() (in module libp2p.security.noise.messages) 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_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.async_service.base.Service property) ManagerAPI (class in libp2p.tools.async_service.abc) 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_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_OUTGOING_STREAMS (libp2p.transport.quic.config.QUICTransportConfig attribute) max_relay_latency (libp2p.relay.circuit_v2.config.ClientConfig attribute) max_relays (libp2p.relay.circuit_v2.config.RelayConfig 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_STREAM_RECEIVE_BUFFER (libp2p.transport.quic.config.QUICTransportConfig attribute) 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) mcache (libp2p.pubsub.gossipsub.GossipSub attribute) mDNS (libp2p.host.basic_host.BasicHost attribute) MDNSDiscovery (class in libp2p.discovery.mdns.mdns) 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) 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) MessageTooLarge MessageTooLargeError Metadata (class in libp2p.bitswap.pb.unixfs_pb2) metadata (libp2p.peer.peerdata.PeerData attribute) Metrics (class in libp2p.rcmgr.metrics) 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.tls examples.tls.example_tls_client examples.tls.example_tls_server 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.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.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.peer libp2p.peer.envelope libp2p.peer.id libp2p.peer.peer_record libp2p.peer.peerdata libp2p.peer.peerinfo libp2p.peer.peerstore 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.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.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.async_service libp2p.tools.async_service.abc libp2p.tools.async_service.base libp2p.tools.async_service.exceptions libp2p.tools.async_service.stats libp2p.tools.async_service.trio_service libp2p.tools.async_service.typing 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 libp2p.utils.logging libp2p.utils.multiaddr_utils libp2p.utils.varint libp2p.utils.version

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.relay.circuit_v2.discovery.IHostWithMultiselect property) (libp2p.security.security_multistream.SecurityMultistream attribute) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream attribute) multiselect_client (libp2p.host.basic_host.BasicHost attribute) (libp2p.security.security_multistream.SecurityMultistream attribute) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream attribute) MultiselectClient (class in libp2p.protocol_muxer.multiselect_client) MultiselectClientError MultiselectCommunicator (class in libp2p.protocol_muxer.multiselect_communicator) MultiselectCommunicatorError MultiselectError 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.stream_muxer.mplex.mplex_stream.MplexStream attribute) (libp2p.tools.async_service.abc.TaskAPI attribute) NamespacedValidator (class in libp2p.records.validator) 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_quic_multiaddr() (in module libp2p.transport.quic.utils) NotAuthorizedError 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

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_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) order (libp2p.security.secio.transport.SessionParameters 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.async_service.abc.TaskAPI attribute) parse_circuit_ma() (libp2p.relay.circuit_v2.transport.CircuitV2Transport method) parse_identify_response() (in module libp2p.identity.identify.identify) 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) ParsedWebSocketMultiaddr (class in libp2p.transport.websocket.multiaddr_utils) ParseError PatternXX (class in libp2p.security.noise.patterns) 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.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_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) 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.async_service.stats.TaskStats property) perform_random_walk() (libp2p.discovery.random_walk.random_walk.RandomWalk method) (libp2p.discovery.random_walk.RandomWalk method) 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) prefix (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) Proposal (class in libp2p.security.secio.transport) Propose (class in libp2p.security.secio.pb.spipe_pb2) protocol (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) protocol_name (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 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) 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) Pubsub (class in libp2p.pubsub.pubsub) 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)

Q

qlog_dir (libp2p.transport.quic.config.QUICTransportConfig attribute) (libp2p.transport.quic.config.QUICTransportKwargs attribute) query_multistream_command() (libp2p.protocol_muxer.multiselect_client.MultiselectClient method) 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] raw_payload (libp2p.peer.envelope.Envelope attribute) RawConnection (class in libp2p.network.connection.raw_connection) RawConnError 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) (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) (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) (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.rcmgr.metrics.Metrics method) record_connection_attempt() (libp2p.relay.circuit_v2.performance_tracker.RelayPerformanceTracker method) record_error() (libp2p.transport.websocket.connection.WebSocketStats 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_open() (libp2p.transport.quic.stream.StreamTimeline method) record_reset() (libp2p.transport.quic.stream.StreamTimeline method) record_stream() (libp2p.rcmgr.metrics.Metrics 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_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.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_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) 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.network.swarm.Swarm method) (libp2p.rcmgr.metrics.Metrics method) remove_connection() (libp2p.transport.websocket.manager.WebSocketConnectionManager method) remove_from_blacklist() (libp2p.pubsub.pubsub.Pubsub 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.relay.circuit_v2.protocol.IHostWithStreamHandlers method) remove_topic_validator() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) 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) request_client_certificate (libp2p.transport.quic.security.QUICTLSSecurityConfig attribute) 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) 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] 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) 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.async_service.abc.ManagerAPI method) (libp2p.tools.async_service.abc.ServiceAPI method) (libp2p.tools.async_service.abc.TaskAPI method) (libp2p.tools.async_service.base.BaseChildServiceTask method) (libp2p.tools.async_service.trio_service.FunctionTask method) (libp2p.tools.async_service.trio_service.TrioManager method) run_child_service() (libp2p.tools.async_service.abc.InternalManagerAPI method) (libp2p.tools.async_service.trio_service.TrioManager 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.async_service.abc.InternalManagerAPI method) (libp2p.tools.async_service.base.BaseManager method) run_daemon_task() (libp2p.tools.async_service.abc.InternalManagerAPI method) (libp2p.tools.async_service.base.BaseManager method) run_handshake() (in module libp2p.security.insecure.transport) run_service() (libp2p.tools.async_service.abc.ManagerAPI class method) (libp2p.tools.async_service.trio_service.TrioManager class method) run_task() (libp2p.tools.async_service.abc.InternalManagerAPI method) (libp2p.tools.async_service.trio_service.TrioManager method) rw_lock (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute)

S

save_keypair() (in module libp2p) ScopeClosedException 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) SecurityError SecurityMultistream (class in libp2p.security.security_multistream) SecurityUpgradeFailure SedesException seen_messages (libp2p.pubsub.pubsub.Pubsub attribute) select() (libp2p.records.pubkey.PublicKeyValidator 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) seq (libp2p.peer.peer_record.PeerRecord attribute) (libp2p.peer.peerstore.PeerRecordState 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.async_service.base) ServiceAPI (class in libp2p.tools.async_service.abc) ServiceException 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_muxer() (in module libp2p) set_gauge() (libp2p.rcmgr.metrics.Metrics 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_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 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_peer_ids_by_distance() (in module libp2p.kad_dht.utils) spam_protection_enabled (libp2p.pubsub.gossipsub.GossipSub attribute) split() (libp2p.kad_dht.routing_table.KBucket method) split_key() (in module libp2p.records.utils) start() (libp2p.abc.IMuxedConn 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.connection.swarm_connection.SwarmConn 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) state (libp2p.network.stream.net_stream.NetStream property) (libp2p.transport.quic.stream.QUICStream property) Stats (class in libp2p.tools.async_service.stats) stats (libp2p.tools.async_service.abc.ManagerAPI property) (libp2p.tools.async_service.base.BaseManager 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.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.tools.async_service.abc.ManagerAPI method) (libp2p.tools.async_service.base.BaseManager method) (libp2p.tools.timed_cache.base_timed_cache.BaseTimedCache method) STOP_FAILED (libp2p.relay.circuit_v2.protocol_buffer.StatusCode attribute) 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) stringGen() (in module libp2p.discovery.mdns.utils) 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) success_rate (libp2p.relay.circuit_v2.performance_tracker.RelayStats property) 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_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) SwarmException switch_mode() (libp2p.kad_dht.kad_dht.KadDHT method) (libp2p.kad_dht.KadDHT method)

T

TaskAPI (class in libp2p.tools.async_service.abc) tasks (libp2p.tools.async_service.stats.Stats attribute) TaskStats (class in libp2p.tools.async_service.stats) TaskWithChildrenAPI (class in libp2p.tools.async_service.abc) TCP (class in libp2p.transport) (class in libp2p.transport.tcp.tcp) TCPListener (class in libp2p.transport.tcp.tcp) 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) 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_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 topic_ids (libp2p.abc.IPubsub property) (libp2p.pubsub.pubsub.Pubsub property) 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.async_service.stats.TaskStats 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 attribute) (libp2p.stream_muxer.muxer_multistream.MuxerMultistream attribute) TransportUpgrader (class in libp2p.transport.upgrader) trio_task (libp2p.tools.async_service.trio_service.FunctionTask property) TrioManager (class in libp2p.tools.async_service.trio_service) 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)

U

UnavailableError UNKNOWN (libp2p.host.autonat.autonat.AutoNATStatus attribute) unmarshal_envelope() (in module libp2p.peer.envelope) unmarshal_public_key() (in module libp2p.records.pubkey) unmarshal_record() (in module libp2p.peer.peer_record) 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) 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) 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) upnp (libp2p.host.basic_host.BasicHost attribute) UpnpManager (class in libp2p.discovery.upnp.upnp)

V

valid_peer_ids() (libp2p.peer.peerstore.PeerStore method) validate() (libp2p.abc.IEnvelope method) (libp2p.peer.envelope.Envelope method) (libp2p.records.pubkey.PublicKeyValidator 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) 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) 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)

W

wait_done() (libp2p.tools.async_service.abc.TaskAPI method) (libp2p.tools.async_service.base.BaseChildServiceTask method) (libp2p.tools.async_service.trio_service.FunctionTask method) wait_finished() (libp2p.tools.async_service.abc.ManagerAPI method) (libp2p.tools.async_service.trio_service.TrioManager method) wait_ready_for_io() (libp2p.transport.quic.stream.QUICStream method) wait_started() (libp2p.tools.async_service.abc.ManagerAPI method) (libp2p.tools.async_service.trio_service.TrioManager method) wait_until_ready() (libp2p.abc.IPubsub method) (libp2p.pubsub.pubsub.Pubsub method) want_block() (libp2p.bitswap.BitswapClient method) 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) 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_CLOSED (libp2p.transport.quic.stream.StreamState attribute) write_deadline (libp2p.stream_muxer.mplex.mplex_stream.MplexStream attribute) write_lock (libp2p.io.trio.TrioTCPStream attribute) 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)