Kagome
Polkadot Runtime Engine in C++17
|
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::StreamEngine | inlineprivate |
addBidirectional(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol) | kagome::network::StreamEngine | inline |
addIncoming(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol) | kagome::network::StreamEngine | inline |
addOutgoing(std::shared_ptr< Stream > stream, const std::shared_ptr< ProtocolBase > &protocol) | kagome::network::StreamEngine | inline |
broadcast(const std::shared_ptr< ProtocolBase > &protocol, const std::shared_ptr< T > &msg, const std::function< bool(const PeerId &peer_id)> &predicate) | kagome::network::StreamEngine | inline |
broadcast(const std::shared_ptr< ProtocolBase > &protocol, const std::shared_ptr< T > &msg) | kagome::network::StreamEngine | inline |
count(F &&filter) const | kagome::network::StreamEngine | inline |
create(Args &&...args) | kagome::network::StreamEngine | inlinestatic |
del(const PeerId &peer_id) | kagome::network::StreamEngine | inline |
Direction enum name | kagome::network::StreamEngine | |
dropReserveOutgoing(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol) | kagome::network::StreamEngine | inline |
dump(std::string_view msg) | kagome::network::StreamEngine | inlineprivate |
forEachPeer(F &&f) | kagome::network::StreamEngine | inline |
forEachPeer(F &&f) const | kagome::network::StreamEngine | inline |
forProtocol(PM &proto_map, const std::shared_ptr< ProtocolBase > &protocol, F &&f) | kagome::network::StreamEngine | inlineprivatestatic |
forSubscriber(PeerId const &peer_id, PM &streams, std::shared_ptr< ProtocolBase > const &protocol, F &&f) | kagome::network::StreamEngine | inlineprivatestatic |
from(TPeerId &&peer_id) const | kagome::network::StreamEngine | inline |
from(std::shared_ptr< Stream > &stream) const | kagome::network::StreamEngine | inline |
isAlive(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol) const | kagome::network::StreamEngine | inline |
kDownVoteByDisconnectionExpirationTimeout | kagome::network::StreamEngine | static |
logger_ | kagome::network::StreamEngine | private |
operator=(const StreamEngine &)=delete | kagome::network::StreamEngine | |
operator=(StreamEngine &&)=delete | kagome::network::StreamEngine | |
outgoingStreamsNumber(const std::shared_ptr< ProtocolBase > &protocol) | kagome::network::StreamEngine | inline |
PeerId typedef | kagome::network::StreamEngine | |
PeerInfo typedef | kagome::network::StreamEngine | |
PeerMap typedef | kagome::network::StreamEngine | private |
Protocol typedef | kagome::network::StreamEngine | |
ProtocolMap typedef | kagome::network::StreamEngine | private |
reputation_repository_ | kagome::network::StreamEngine | private |
reserveOutgoing(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol) | kagome::network::StreamEngine | inline |
reserveStreams(const PeerId &peer_id, const std::shared_ptr< ProtocolBase > &protocol) | kagome::network::StreamEngine | inline |
send(const PeerId &peer_id, const std::shared_ptr< ProtocolBase > &protocol, std::shared_ptr< T > msg) | kagome::network::StreamEngine | inline |
send(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol, std::shared_ptr< Stream > stream, std::shared_ptr< T > const &msg) | kagome::network::StreamEngine | inlineprivate |
Stream typedef | kagome::network::StreamEngine | |
StreamEngine(const StreamEngine &)=delete | kagome::network::StreamEngine | |
StreamEngine(StreamEngine &&)=delete | kagome::network::StreamEngine | |
StreamEngine(std::shared_ptr< ReputationRepository > reputation_repository) | kagome::network::StreamEngine | inline |
StreamEnginePtr typedef | kagome::network::StreamEngine | |
streams_ | kagome::network::StreamEngine | private |
updateStream(PeerId const &peer_id, std::shared_ptr< ProtocolBase > const &protocol, ProtocolDescr &descr) | kagome::network::StreamEngine | inlineprivate |
updateStream(const PeerId &peer_id, const std::shared_ptr< ProtocolBase > &protocol, std::shared_ptr< T > msg) | kagome::network::StreamEngine | inlineprivate |
uploadStream(std::shared_ptr< Stream > &dst, std::shared_ptr< Stream > const &src, std::shared_ptr< ProtocolBase > const &protocol, Direction direction) | kagome::network::StreamEngine | inlineprivate |
~StreamEngine()=default | kagome::network::StreamEngine |