busy_ | kagome::telemetry::TelemetryConnectionImpl | private |
callback_ | kagome::telemetry::TelemetryConnectionImpl | private |
close() | kagome::telemetry::TelemetryConnectionImpl | private |
connect() override | kagome::telemetry::TelemetryConnectionImpl | virtual |
endpoint() const override | kagome::telemetry::TelemetryConnectionImpl | virtual |
endpoint_ | kagome::telemetry::TelemetryConnectionImpl | private |
instance_ | kagome::telemetry::TelemetryConnectionImpl | privatestatic |
io_context_ | kagome::telemetry::TelemetryConnectionImpl | private |
is_connected_ | kagome::telemetry::TelemetryConnectionImpl | private |
isConnected() const override | kagome::telemetry::TelemetryConnectionImpl | virtual |
log_ | kagome::telemetry::TelemetryConnectionImpl | private |
message_pool_ | kagome::telemetry::TelemetryConnectionImpl | private |
onConnect(boost::beast::error_code ec, boost::asio::ip::tcp::resolver::results_type::endpoint_type endpoint) | kagome::telemetry::TelemetryConnectionImpl | private |
OnConnectedCallback typedef | kagome::telemetry::TelemetryConnection | |
onHandshake(boost::beast::error_code ec) | kagome::telemetry::TelemetryConnectionImpl | private |
onResolve(boost::beast::error_code ec, boost::asio::ip::tcp::resolver::results_type results) | kagome::telemetry::TelemetryConnectionImpl | private |
onSslHandshake(boost::beast::error_code ec) | kagome::telemetry::TelemetryConnectionImpl | private |
path_ | kagome::telemetry::TelemetryConnectionImpl | private |
port_ | kagome::telemetry::TelemetryConnectionImpl | private |
queue_ | kagome::telemetry::TelemetryConnectionImpl | private |
reconnect() | kagome::telemetry::TelemetryConnectionImpl | private |
reconnect_timeout_ | kagome::telemetry::TelemetryConnectionImpl | private |
releaseQueue() | kagome::telemetry::TelemetryConnectionImpl | private |
resolver_ | kagome::telemetry::TelemetryConnectionImpl | private |
scheduler_ | kagome::telemetry::TelemetryConnectionImpl | private |
secure_ | kagome::telemetry::TelemetryConnectionImpl | private |
send(const std::string &data) override | kagome::telemetry::TelemetryConnectionImpl | virtual |
send(MessageHandle message_handle) override | kagome::telemetry::TelemetryConnectionImpl | virtual |
setOptionsAndRunWsHandshake(WsStreamT &ws) | kagome::telemetry::TelemetryConnectionImpl | private |
shutdown() override | kagome::telemetry::TelemetryConnectionImpl | virtual |
shutdown_requested_ | kagome::telemetry::TelemetryConnectionImpl | private |
ssl_ctx_ | kagome::telemetry::TelemetryConnectionImpl | private |
SslStream typedef | kagome::telemetry::TelemetryConnectionImpl | private |
stream_lowest_layer() | kagome::telemetry::TelemetryConnectionImpl | private |
TcpStream typedef | kagome::telemetry::TelemetryConnectionImpl | private |
TelemetryConnectionImpl(std::shared_ptr< boost::asio::io_context > io_context, const TelemetryEndpoint &endpoint, OnConnectedCallback callback, std::shared_ptr< MessagePool > message_pool, std::shared_ptr< libp2p::basic::Scheduler > scheduler) | kagome::telemetry::TelemetryConnectionImpl | |
TelemetryConnectionImpl(const TelemetryConnectionImpl &)=delete | kagome::telemetry::TelemetryConnectionImpl | |
TelemetryConnectionImpl(TelemetryConnectionImpl &&)=delete | kagome::telemetry::TelemetryConnectionImpl | |
write(WsStreamT &ws, MessageHandle message_handle) | kagome::telemetry::TelemetryConnectionImpl | private |
ws_ | kagome::telemetry::TelemetryConnectionImpl | private |
ws_handshake_hostname_ | kagome::telemetry::TelemetryConnectionImpl | private |
WsSslStream typedef | kagome::telemetry::TelemetryConnectionImpl | private |
WsSslStreamPtr typedef | kagome::telemetry::TelemetryConnectionImpl | private |
WsStream typedef | kagome::telemetry::TelemetryConnectionImpl | private |
WsTcpStream typedef | kagome::telemetry::TelemetryConnectionImpl | private |
WsTcpStreamPtr typedef | kagome::telemetry::TelemetryConnectionImpl | private |
~TelemetryConnection()=default | kagome::telemetry::TelemetryConnection | virtual |