abstract_broker(abstract_broker &&)=delete (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
abstract_broker(const abstract_broker &&)=delete (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
abstract_broker(actor_config &cfg) (defined in caf::io::abstract_broker) | caf::io::abstract_broker | explicitprotected |
ack_writes(connection_handle hdl, bool enable) | caf::io::abstract_broker | |
ack_writes(datagram_handle hdl, bool enable) | caf::io::abstract_broker | |
add_datagram_servant(datagram_servant_ptr ptr) | caf::io::abstract_broker | |
add_datagram_servant(network::native_socket fd) | caf::io::abstract_broker | |
add_datagram_servant_for_endpoint(network::native_socket fd, const network::ip_endpoint &ep) | caf::io::abstract_broker | |
add_doorman(doorman_ptr ptr) | caf::io::abstract_broker | |
add_doorman(network::native_socket fd) | caf::io::abstract_broker | |
add_hdl_for_datagram_servant(datagram_servant_ptr ptr, datagram_handle hdl) | caf::io::abstract_broker | |
add_scribe(scribe_ptr ptr) | caf::io::abstract_broker | |
add_scribe(network::native_socket fd) | caf::io::abstract_broker | |
add_tcp_doorman(uint16_t port=0, const char *in=nullptr, bool reuse_addr=false) | caf::io::abstract_broker | |
add_tcp_scribe(const std::string &host, uint16_t port) | caf::io::abstract_broker | |
add_udp_datagram_servant(const std::string &host, uint16_t port) | caf::io::abstract_broker | |
add_udp_datagram_servant(uint16_t port=0, const char *in=nullptr, bool reuse_addr=false) | caf::io::abstract_broker | |
backend() | caf::io::abstract_broker | |
become(T &&arg, Ts &&... args) | caf::io::broker | |
behavior_type typedef (defined in caf::io::broker) | caf::io::broker | |
by_id(Handle hdl) -> decltype(ptr_of(hdl)) | caf::io::abstract_broker | protected |
close(Handle hdl) | caf::io::abstract_broker | |
close_all() | caf::io::abstract_broker | |
configure_read(connection_handle hdl, receive_policy::config cfg) | caf::io::abstract_broker | |
connections() const | caf::io::abstract_broker | |
datagram_hdl_by_port(uint16_t port) | caf::io::abstract_broker | |
datagram_servant_map typedef (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected |
doorman_map typedef (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected |
enqueue(mailbox_element_ptr, scheduler *) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
enqueue_datagram(datagram_handle, byte_buffer) | caf::io::abstract_broker | |
flush(connection_handle hdl) | caf::io::abstract_broker | |
flush(datagram_handle hdl) | caf::io::abstract_broker | |
fork(F fun, connection_handle hdl, Ts &&... xs) (defined in caf::io::broker) | caf::io::broker | |
halt(Handle hdl) | caf::io::abstract_broker | |
has_process_metrics() noexcept (defined in caf::detail::prometheus_broker) | caf::detail::prometheus_broker | static |
hdl_by_port(uint16_t port) | caf::io::abstract_broker | |
init_broker() (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected |
initialize() override (defined in caf::io::broker) | caf::io::broker | |
launch(scheduler *eu, bool lazy, bool hide) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
local_addr(accept_handle hdl) | caf::io::abstract_broker | |
local_port(accept_handle hdl) | caf::io::abstract_broker | |
local_port(datagram_handle hdl) | caf::io::abstract_broker | |
mail(Args &&... args) | caf::io::broker | |
make_behavior() override (defined in caf::detail::prometheus_broker) | caf::detail::prometheus_broker | virtual |
move_datagram_servant(datagram_servant_ptr ptr) | caf::io::abstract_broker | |
move_doorman(doorman_ptr ptr) | caf::io::abstract_broker | |
move_scribe(scribe_ptr ptr) | caf::io::abstract_broker | |
name() const override (defined in caf::detail::prometheus_broker) | caf::detail::prometheus_broker | |
num_connections() const noexcept | caf::io::abstract_broker | |
num_doormen() const noexcept | caf::io::abstract_broker | |
on_cleanup(const error &reason) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
operator=(abstract_broker &&)=delete (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
operator=(const abstract_broker &&)=delete (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
parent() | caf::io::abstract_broker | |
prometheus_broker(actor_config &cfg) (defined in caf::detail::prometheus_broker) | caf::detail::prometheus_broker | explicit |
prometheus_broker(actor_config &cfg, io::doorman_ptr ptr) (defined in caf::detail::prometheus_broker) | caf::detail::prometheus_broker | |
remote_addr(connection_handle hdl) | caf::io::abstract_broker | |
remote_addr(datagram_handle hdl) | caf::io::abstract_broker | |
remote_port(connection_handle hdl) | caf::io::abstract_broker | |
remote_port(datagram_handle hdl) | caf::io::abstract_broker | |
remove_endpoint(datagram_handle hdl) | caf::io::abstract_broker | |
resume(scheduler *, size_t) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
scribe_map typedef (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected |
signatures typedef (defined in caf::io::broker) | caf::io::broker | |
subtype() const noexcept override (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
super typedef (defined in caf::io::broker) | caf::io::broker | |
trigger(Handle hdl) | caf::io::abstract_broker | |
trigger(Handle hdl, size_t num_events) | caf::io::abstract_broker | |
unbecome() | caf::io::broker | |
valid(Handle hdl) | caf::io::abstract_broker | |
wr_buf(connection_handle hdl) | caf::io::abstract_broker | |
wr_buf(datagram_handle hdl) | caf::io::abstract_broker | |
write(connection_handle hdl, size_t bs, const void *buf) | caf::io::abstract_broker | |
write(connection_handle hdl, span< const std::byte > buf) | caf::io::abstract_broker | |
write(datagram_handle hdl, size_t data_size, const void *data) | caf::io::abstract_broker | |
~abstract_broker() override (defined in caf::io::abstract_broker) | caf::io::abstract_broker | |
~prometheus_broker() override (defined in caf::detail::prometheus_broker) | caf::detail::prometheus_broker | |