app_config_ | kagome::network::PropagateTransactionsProtocol | private |
babe_ | kagome::network::PropagateTransactionsProtocol | private |
base_ | kagome::network::PropagateTransactionsProtocol | private |
Direction enum name | kagome::network::PropagateTransactionsProtocol | private |
ext_event_key_repo_ | kagome::network::PropagateTransactionsProtocol | private |
extrinsic_events_engine_ | kagome::network::PropagateTransactionsProtocol | private |
extrinsic_observer_ | kagome::network::PropagateTransactionsProtocol | private |
kPropogateTransacionsProtocolName | kagome::network::PropagateTransactionsProtocol | inlineprivatestatic |
metric_propagated_tx_counter_ | kagome::network::PropagateTransactionsProtocol | private |
metrics_registry_ | kagome::network::PropagateTransactionsProtocol | private |
newOutgoingStream(const PeerInfo &peer_info, std::function< void(outcome::result< std::shared_ptr< Stream >>)> &&cb) override | kagome::network::PropagateTransactionsProtocol | virtual |
NonCopyable(NonCopyable const &)=delete | NonCopyable | private |
NonCopyable()=default | NonCopyable | private |
NonMovable(NonMovable &&)=delete | NonMovable | private |
NonMovable()=default | NonMovable | private |
onIncomingStream(std::shared_ptr< Stream > stream) override | kagome::network::PropagateTransactionsProtocol | virtual |
kagome::operator=(ProtocolBase &&) noexcept=delete | kagome::network::ProtocolBase | |
kagome::operator=(ProtocolBase const &)=delete | kagome::network::ProtocolBase | |
NonCopyable::operator=(NonCopyable const &)=delete | NonCopyable | private |
NonMovable::operator=(NonMovable &&)=delete | NonMovable | private |
propagateTransactions(gsl::span< const primitives::Transaction > txs) | kagome::network::PropagateTransactionsProtocol | |
PropagateTransactionsProtocol()=delete | kagome::network::PropagateTransactionsProtocol | |
PropagateTransactionsProtocol(libp2p::Host &host, const application::AppConfiguration &app_config, const application::ChainSpec &chain_spec, std::shared_ptr< consensus::babe::Babe > babe, std::shared_ptr< ExtrinsicObserver > extrinsic_observer, std::shared_ptr< StreamEngine > stream_engine, std::shared_ptr< primitives::events::ExtrinsicSubscriptionEngine > extrinsic_events_engine, std::shared_ptr< subscription::ExtrinsicEventKeyRepository > ext_event_key_repo) | kagome::network::PropagateTransactionsProtocol | |
ProtocolBase()=default | kagome::network::ProtocolBase | |
ProtocolBase(ProtocolBase &&) noexcept=delete | kagome::network::ProtocolBase | |
ProtocolBase(const ProtocolBase &)=delete | kagome::network::ProtocolBase | |
protocolName() const override | kagome::network::PropagateTransactionsProtocol | inlinevirtual |
readHandshake(std::shared_ptr< Stream > stream, Direction direction, std::function< void(outcome::result< void >)> &&cb) | kagome::network::PropagateTransactionsProtocol | private |
readPropagatedExtrinsics(std::shared_ptr< Stream > stream) | kagome::network::PropagateTransactionsProtocol | private |
start() override | kagome::network::PropagateTransactionsProtocol | virtual |
stop() override | kagome::network::PropagateTransactionsProtocol | virtual |
stream_engine_ | kagome::network::PropagateTransactionsProtocol | private |
writeHandshake(std::shared_ptr< Stream > stream, Direction direction, std::function< void(outcome::result< void >)> &&cb) | kagome::network::PropagateTransactionsProtocol | private |
~NonCopyable()=default | NonCopyable | private |
~NonMovable()=default | NonMovable | private |
~PropagateTransactionsProtocol() override=default | kagome::network::PropagateTransactionsProtocol | |
~ProtocolBase()=default | kagome::network::ProtocolBase | virtual |