active_peers_ | kagome::network::PeerManagerImpl | private |
activePeersNumber() const override | kagome::network::PeerManagerImpl | virtual |
add_peer_handle_ | kagome::network::PeerManagerImpl | private |
AdvResult typedef | kagome::network::PeerManager | |
align() | kagome::network::PeerManagerImpl | private |
align_timer_ | kagome::network::PeerManagerImpl | private |
app_config_ | kagome::network::PeerManagerImpl | private |
app_state_manager_ | kagome::network::PeerManagerImpl | private |
BlockInfo typedef | kagome::network::PeerManager | |
bootstrap_nodes_ | kagome::network::PeerManagerImpl | private |
clearClosedPingingConnections() | kagome::network::PeerManagerImpl | private |
clock_ | kagome::network::PeerManagerImpl | private |
connecting_peers_ | kagome::network::PeerManagerImpl | private |
connectToPeer(const PeerInfo &peer_info) override | kagome::network::PeerManagerImpl | virtual |
connectToPeer(const PeerId &peer_id) | kagome::network::PeerManagerImpl | private |
disconnectFromPeer(const PeerId &peer_id) | kagome::network::PeerManagerImpl | private |
Error enum name | kagome::network::PeerManagerImpl | |
forEachPeer(std::function< void(const PeerId &)> func) const override | kagome::network::PeerManagerImpl | virtual |
forOnePeer(const PeerId &peer_id, std::function< void(const PeerId &)> func) const override | kagome::network::PeerManagerImpl | virtual |
getPeerState(const PeerId &peer_id) override | kagome::network::PeerManagerImpl | virtual |
getStreamEngine() override | kagome::network::PeerManagerImpl | virtual |
hasher_ | kagome::network::PeerManagerImpl | private |
host_ | kagome::network::PeerManagerImpl | private |
identify_ | kagome::network::PeerManagerImpl | private |
insert_advertisement(PeerState &peer_state, ParachainState ¶chain_state, primitives::BlockHash para_hash) override | kagome::network::PeerManagerImpl | virtual |
isSelfPeer(const PeerId &peer_id) const | kagome::network::PeerManagerImpl | private |
kademlia_ | kagome::network::PeerManagerImpl | private |
keepAlive(const PeerId &peer_id) override | kagome::network::PeerManagerImpl | virtual |
kTimeoutForConnecting | kagome::network::PeerManagerImpl | static |
loadLastActivePeers() | kagome::network::PeerManagerImpl | private |
log_ | kagome::network::PeerManagerImpl | private |
own_peer_info_ | kagome::network::PeerManagerImpl | private |
parachain_state_ | kagome::network::PeerManagerImpl | private |
parachainState() override | kagome::network::PeerManagerImpl | virtual |
peer_disconnected_handler_ | kagome::network::PeerManagerImpl | private |
peer_states_ | kagome::network::PeerManagerImpl | private |
PeerId typedef | kagome::network::PeerManager | |
PeerInfo typedef | kagome::network::PeerManager | |
PeerManagerImpl(std::shared_ptr< application::AppStateManager > app_state_manager, libp2p::Host &host, std::shared_ptr< libp2p::protocol::Identify > identify, std::shared_ptr< libp2p::protocol::kademlia::Kademlia > kademlia, std::shared_ptr< libp2p::basic::Scheduler > scheduler, std::shared_ptr< StreamEngine > stream_engine, const application::AppConfiguration &app_config, std::shared_ptr< clock::SteadyClock > clock, const BootstrapNodes &bootstrap_nodes, const OwnPeerInfo &own_peer_info, std::shared_ptr< network::Router > router, std::shared_ptr< storage::BufferStorage > storage, std::shared_ptr< crypto::Hasher > hasher, std::shared_ptr< ReputationRepository > reputation_repository) | kagome::network::PeerManagerImpl | |
peers_in_queue_ | kagome::network::PeerManagerImpl | private |
pinging_connections_ | kagome::network::PeerManagerImpl | private |
prepare() | kagome::network::PeerManagerImpl | |
processDiscoveredPeer(const PeerId &peer_id) | kagome::network::PeerManagerImpl | private |
processFullyConnectedPeer(const PeerId &peer_id) | kagome::network::PeerManagerImpl | private |
queue_to_connect_ | kagome::network::PeerManagerImpl | private |
recently_active_peers_ | kagome::network::PeerManagerImpl | private |
registry_ | kagome::network::PeerManagerImpl | private |
reputation_repository_ | kagome::network::PeerManagerImpl | private |
reserveStreams(const PeerId &peer_id) const override | kagome::network::PeerManagerImpl | virtual |
router_ | kagome::network::PeerManagerImpl | private |
scheduler_ | kagome::network::PeerManagerImpl | private |
setCollating(const PeerId &peer_id, network::CollatorPublicKey const &collator_id, network::ParachainId para_id) override | kagome::network::PeerManagerImpl | virtual |
start() | kagome::network::PeerManagerImpl | |
startPingingPeer(const PeerId &peer_id) override | kagome::network::PeerManagerImpl | virtual |
stop() | kagome::network::PeerManagerImpl | |
storage_ | kagome::network::PeerManagerImpl | private |
storeActivePeers() | kagome::network::PeerManagerImpl | private |
stream_engine_ | kagome::network::PeerManagerImpl | private |
sync_peer_num_ | kagome::network::PeerManagerImpl | private |
updatePeerState(const PeerId &peer_id, const Status &status) override | kagome::network::PeerManagerImpl | virtual |
updatePeerState(const PeerId &peer_id, const BlockAnnounce &announce) override | kagome::network::PeerManagerImpl | virtual |
updatePeerState(const PeerId &peer_id, const GrandpaNeighborMessage &neighbor_message) override | kagome::network::PeerManagerImpl | virtual |
~PeerManager()=default | kagome::network::PeerManager | virtual |