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::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