Seastar
High performance C++ framework for concurrent servers
seastar::rpc::protocol< Serializer, MsgType >::client Member List

This is the complete list of members for seastar::rpc::protocol< Serializer, MsgType >::client, including all inherited members.

_compressor (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_connected (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_error (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_fd (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_id (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_is_stream (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_logger (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_negotiated (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_outgoing_queue (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_outgoing_queue_ready (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_outgoing_queue_size (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_propagate_timeout (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_read_buf (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_serializer (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_sink_closed (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_sink_closed_future (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_source_closed (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_stats (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_stopped (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_stream_queue (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_stream_sem (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_streams (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_timeout_negotiated (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
_write_buf (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
abort() (defined in seastar::rpc::connection)seastar::rpc::connection
abort_all_streams() (defined in seastar::rpc::client)seastar::rpc::client
await_connection() (defined in seastar::rpc::client)seastar::rpc::clientinline
client(protocol &p, const socket_address &addr, const socket_address &local={}) (defined in seastar::rpc::protocol< Serializer, MsgType >::client)seastar::rpc::protocol< Serializer, MsgType >::clientinline
client(protocol &p, client_options options, const socket_address &addr, const socket_address &local={}) (defined in seastar::rpc::protocol< Serializer, MsgType >::client)seastar::rpc::protocol< Serializer, MsgType >::clientinline
client(protocol &p, socket socket, const socket_address &addr, const socket_address &local={})seastar::rpc::protocol< Serializer, MsgType >::clientinline
client(protocol &p, client_options options, socket socket, const socket_address &addr, const socket_address &local={}) (defined in seastar::rpc::protocol< Serializer, MsgType >::client)seastar::rpc::protocol< Serializer, MsgType >::clientinline
seastar::rpc::client::client(const logger &l, void *s, const socket_address &addr, const socket_address &local={})seastar::rpc::client
client(const logger &l, void *s, client_options options, const socket_address &addr, const socket_address &local={}) (defined in seastar::rpc::client)seastar::rpc::client
seastar::rpc::client::client(const logger &l, void *s, socket socket, const socket_address &addr, const socket_address &local={})seastar::rpc::client
client(const logger &l, void *s, client_options options, socket socket, const socket_address &addr, const socket_address &local={}) (defined in seastar::rpc::client)seastar::rpc::client
close_sink() (defined in seastar::rpc::connection)seastar::rpc::connectioninline
close_source() (defined in seastar::rpc::connection)seastar::rpc::connectioninline
compress(snd_buf buf) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
connection(connected_socket &&fd, const logger &l, void *s, connection_id id=invalid_connection_id) (defined in seastar::rpc::connection)seastar::rpc::connectioninline
connection(const logger &l, void *s, connection_id id=invalid_connection_id) (defined in seastar::rpc::connection)seastar::rpc::connectioninline
deregister_this_stream() (defined in seastar::rpc::client)seastar::rpc::client
error() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninline
get_connection_id() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninline
get_logger() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninline
get_stats() const (defined in seastar::rpc::client)seastar::rpc::client
get_stats_internal() noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninline
get_stream(connection_id id) const (defined in seastar::rpc::connection)seastar::rpc::connection
handle_stream_frame() (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
incoming_queue_length() const noexcept (defined in seastar::rpc::client)seastar::rpc::clientinline
is_stream() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninlineprotected
make_stream_sink(socket socket) (defined in seastar::rpc::client)seastar::rpc::clientinline
make_stream_sink() (defined in seastar::rpc::client)seastar::rpc::clientinline
next_message_id() (defined in seastar::rpc::client)seastar::rpc::clientinline
outgoing_queue_length() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninline
peer_address() const override (defined in seastar::rpc::client)seastar::rpc::clientinlinevirtual
read_frame(socket_address info, input_stream< char > &in) (defined in seastar::rpc::connection)seastar::rpc::connection
read_frame_compressed(socket_address info, std::unique_ptr< compressor > &compressor, input_stream< char > &in) (defined in seastar::rpc::connection)seastar::rpc::connection
read_stream_frame_compressed(input_stream< char > &in) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
register_stream(connection_id id, xshard_connection_ptr c) (defined in seastar::rpc::connection)seastar::rpc::connection
request(uint64_t type, int64_t id, snd_buf buf, std::optional< rpc_clock_type::time_point > timeout={}, cancellable *cancel=nullptr) (defined in seastar::rpc::client)seastar::rpc::client
send(snd_buf buf, std::optional< rpc_clock_type::time_point > timeout={}, cancellable *cancel=nullptr) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
send_buffer(snd_buf buf) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
send_entry(outgoing_entry &d) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
send_negotiation_frame(feature_map features) (defined in seastar::rpc::connection)seastar::rpc::connection
serializer() (defined in seastar::rpc::connection)seastar::rpc::connectioninline
set_negotiated() noexcept (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
set_socket(connected_socket &&fd) (defined in seastar::rpc::connection)seastar::rpc::connection
sink_closed() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninline
stop() noexcept (defined in seastar::rpc::client)seastar::rpc::client
stop_send_loop(std::exception_ptr ex) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
stream_check_twoway_closed() const noexcept (defined in seastar::rpc::connection)seastar::rpc::connectioninlineprotected
stream_close() (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
stream_process_incoming(rcv_buf &&) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
stream_receive(circular_buffer< foreign_ptr< std::unique_ptr< rcv_buf >>> &bufs) (defined in seastar::rpc::connection)seastar::rpc::connection
suspend_for_testing(promise<> &p) (defined in seastar::rpc::connection)seastar::rpc::connectioninline
wait_for_reply(id_type id, std::unique_ptr< reply_handler_base > &&h, std::optional< rpc_clock_type::time_point > timeout, cancellable *cancel) (defined in seastar::rpc::client)seastar::rpc::client
wait_timed_out(id_type id) (defined in seastar::rpc::client)seastar::rpc::client
weak_from_this() noexcept (defined in seastar::weakly_referencable< client >)seastar::weakly_referencable< client >inline
weakly_referencable() noexcept (defined in seastar::weakly_referencable< client >)seastar::weakly_referencable< client >inline
weakly_referencable(weakly_referencable &&)=delete (defined in seastar::weakly_referencable< client >)seastar::weakly_referencable< client >
weakly_referencable(const weakly_referencable &)=delete (defined in seastar::weakly_referencable< client >)seastar::weakly_referencable< client >
withdraw(outgoing_entry::container_t::iterator it, std::exception_ptr ex=nullptr) (defined in seastar::rpc::connection)seastar::rpc::connectionprotected
~connection() (defined in seastar::rpc::connection)seastar::rpc::connectioninlinevirtual
~weakly_referencable() noexcept (defined in seastar::weakly_referencable< client >)seastar::weakly_referencable< client >inline