Kagome
Polkadot Runtime Engine in C++17
kagome::network::StreamEngine Member List

This is the complete list of members for kagome::network::StreamEngine, including all inherited members.

add(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol, Direction direction)kagome::network::StreamEngineinlineprivate
addBidirectional(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol)kagome::network::StreamEngineinline
addIncoming(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol)kagome::network::StreamEngineinline
addOutgoing(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol)kagome::network::StreamEngineinline
broadcast(const std::shared_ptr< ProtocolBase > &protocol, const std::shared_ptr< T > &msg, const std::function< bool(const PeerId &peer_id)> &predicate)kagome::network::StreamEngineinline
broadcast(const std::shared_ptr< ProtocolBase > &protocol, const std::shared_ptr< T > &msg)kagome::network::StreamEngineinline
count(F &&filter) const kagome::network::StreamEngineinline
create(Args &&...args)kagome::network::StreamEngineinlinestatic
del(const PeerId &peer_id)kagome::network::StreamEngineinline
Direction enum namekagome::network::StreamEngine
dropReserveOutgoing(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol)kagome::network::StreamEngineinline
dump(std::string_view msg)kagome::network::StreamEngineinlineprivate
forEachPeer(F &&f)kagome::network::StreamEngineinline
forEachPeer(F &&f) const kagome::network::StreamEngineinline
forProtocol(PM &proto_map, const std::shared_ptr< ProtocolBase > &protocol, F &&f)kagome::network::StreamEngineinlineprivatestatic
forSubscriber(PeerId const &peer_id, PM &streams, std::shared_ptr< ProtocolBase > const &protocol, F &&f)kagome::network::StreamEngineinlineprivatestatic
from(TPeerId &&peer_id) const kagome::network::StreamEngineinline
from(std::shared_ptr< Stream > &stream) const kagome::network::StreamEngineinline
isAlive(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol) const kagome::network::StreamEngineinline
kDownVoteByDisconnectionExpirationTimeoutkagome::network::StreamEnginestatic
logger_kagome::network::StreamEngineprivate
operator=(const StreamEngine &)=deletekagome::network::StreamEngine
operator=(StreamEngine &&)=deletekagome::network::StreamEngine
outgoingStreamsNumber(const std::shared_ptr< ProtocolBase > &protocol)kagome::network::StreamEngineinline
PeerId typedefkagome::network::StreamEngine
PeerInfo typedefkagome::network::StreamEngine
PeerMap typedefkagome::network::StreamEngineprivate
Protocol typedefkagome::network::StreamEngine
ProtocolMap typedefkagome::network::StreamEngineprivate
reputation_repository_kagome::network::StreamEngineprivate
reserveOutgoing(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol)kagome::network::StreamEngineinline
reserveStreams(const PeerId &peer_id, const std::shared_ptr< ProtocolBase > &protocol)kagome::network::StreamEngineinline
send(const PeerId &peer_id, const std::shared_ptr< ProtocolBase > &protocol, std::shared_ptr< T > msg)kagome::network::StreamEngineinline
send(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol, std::shared_ptr< Stream > stream, std::shared_ptr< T > const &msg)kagome::network::StreamEngineinlineprivate
Stream typedefkagome::network::StreamEngine
StreamEngine(const StreamEngine &)=deletekagome::network::StreamEngine
StreamEngine(StreamEngine &&)=deletekagome::network::StreamEngine
StreamEngine(std::shared_ptr< ReputationRepository > reputation_repository)kagome::network::StreamEngineinline
StreamEnginePtr typedefkagome::network::StreamEngine
streams_kagome::network::StreamEngineprivate
updateStream(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol, ProtocolDescr &descr)kagome::network::StreamEngineinlineprivate
updateStream(const PeerId &peer_id, const std::shared_ptr< ProtocolBase > &protocol, std::shared_ptr< T > msg)kagome::network::StreamEngineinlineprivate
uploadStream(std::shared_ptr< Stream > &dst, std::shared_ptr< Stream > const &src, std::shared_ptr< ProtocolBase > const &protocol, Direction direction)kagome::network::StreamEngineinlineprivate
~StreamEngine()=defaultkagome::network::StreamEngine