acquire_unique_packet_id() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
acquire_unique_packet_id_no_except() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_auth(v5::auth_reason_code reason_code=v5::auth_reason_code::success, v5::properties props={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_client(constructor_access, Args &&... args) | MQTT_NS::async_client< Socket, PacketIdBytes > | inline |
async_client(as::io_context &ioc, std::string host, std::string port, protocol_version version=protocol_version::v3_1_1) | MQTT_NS::async_client< Socket, PacketIdBytes > | inlineprotected |
async_connack(bool session_present, variant< connect_return_code, v5::connect_reason_code > reason_code, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_connack(bool session_present, variant< connect_return_code, v5::connect_reason_code > reason_code, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_connect() | MQTT_NS::client< Socket, 2 > | inline |
async_connect(T session_life_keeper) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(any session_life_keeper, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(v5::properties props, T session_life_keeper) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(v5::properties props, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(v5::properties props, any session_life_keeper, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, T session_life_keeper) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, any session_life_keeper, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, v5::properties props) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, v5::properties props, T session_life_keeper) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, v5::properties props, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
async_connect(std::shared_ptr< Socket > &&socket, v5::properties props, any session_life_keeper, async_handler_t func) | MQTT_NS::client< Socket, 2 > | inline |
endpoint< std::mutex, std::lock_guard, PacketIdBytes >::async_connect(buffer client_id, optional< buffer > user_name, optional< buffer > password, optional< will > w, std::uint16_t keep_alive_sec, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
endpoint< std::mutex, std::lock_guard, PacketIdBytes >::async_connect(buffer client_id, optional< buffer > user_name, optional< buffer > password, optional< will > w, std::uint16_t keep_alive_sec, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_disconnect(std::chrono::steady_clock::duration timeout, async_handler_t func=async_handler_t()) | MQTT_NS::client< Socket, 2 > | inline |
async_disconnect(std::chrono::steady_clock::duration timeout, v5::disconnect_reason_code reason_code, v5::properties props, async_handler_t func=async_handler_t()) | MQTT_NS::client< Socket, 2 > | inline |
async_disconnect(async_handler_t func=async_handler_t()) | MQTT_NS::client< Socket, 2 > | inline |
async_disconnect(v5::disconnect_reason_code reason_code, v5::properties props, async_handler_t func=async_handler_t()) | MQTT_NS::client< Socket, 2 > | inline |
async_handler_t typedef | MQTT_NS::client< Socket, 2 > | |
async_pingreq(async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pingresp(async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_puback(packet_id_t packet_id, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_puback(packet_id_t packet_id, v5::puback_reason_code reason_code, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pubcomp(packet_id_t packet_id, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pubcomp(packet_id_t packet_id, v5::pubcomp_reason_code reason_code, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(T &&t, Params &&... params) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(packet_id_t packet_id, std::string topic_name, std::string contents, publish_options pubopts={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(packet_id_t packet_id, std::string topic_name, std::string contents, publish_options pubopts, v5::properties props, any life_keeper={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(packet_id_t packet_id, as::const_buffer topic_name, ConstBufferSequence contents, publish_options pubopts={}, any life_keeper={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(packet_id_t packet_id, as::const_buffer topic_name, ConstBufferSequence contents, publish_options pubopts, v5::properties props, any life_keeper={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(packet_id_t packet_id, buffer topic_name, BufferSequence contents, publish_options pubopts={}, any life_keeper={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_publish(packet_id_t packet_id, buffer topic_name, BufferSequence contents, publish_options pubopts, v5::properties props, any life_keeper={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pubrec(packet_id_t packet_id, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pubrec(packet_id_t packet_id, v5::pubrec_reason_code reason_code, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pubrel(packet_id_t packet_id, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_pubrel(packet_id_t packet_id, v5::pubrel_reason_code reason_code, v5::properties props={}, any life_keeper={}, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_read_control_packet_type(any session_life_keeper) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotected |
async_read_next_message(any session_life_keeper) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_send_store_message(basic_store_message_variant< PacketIdBytes > msg, any life_keeper, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_suback(packet_id_t packet_id, variant< suback_return_code, v5::suback_reason_code > reason, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_suback(packet_id_t packet_id, variant< suback_return_code, v5::suback_reason_code > reason, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_suback(packet_id_t packet_id, variant< std::vector< suback_return_code >, std::vector< v5::suback_reason_code >> reasons, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_suback(packet_id_t packet_id, variant< std::vector< suback_return_code >, std::vector< v5::suback_reason_code >> reasons, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(T &&t, Params &&... params) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::string topic_filter, subscribe_options option, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::string topic_filter, subscribe_options option, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, as::const_buffer topic_filter, subscribe_options option, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, as::const_buffer topic_filter, subscribe_options option, v5::properties props, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, buffer topic_filter, subscribe_options option, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, buffer topic_filter, subscribe_options option, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::vector< std::tuple< std::string, subscribe_options >> params, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::vector< std::tuple< std::string, subscribe_options >> params, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::vector< std::tuple< as::const_buffer, subscribe_options >> params, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::vector< std::tuple< as::const_buffer, subscribe_options >> params, v5::properties props, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::vector< std::tuple< buffer, subscribe_options >> params, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_subscribe(packet_id_t packet_id, std::vector< std::tuple< buffer, subscribe_options >> params, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsuback(packet_id_t packet_id, v5::unsuback_reason_code reason, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsuback(packet_id_t packet_id, v5::unsuback_reason_code reason, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsuback(packet_id_t packet_id, std::vector< v5::unsuback_reason_code > reasons, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsuback(packet_id_t packet_id, std::vector< v5::unsuback_reason_code > reasons, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsuback(packet_id_t packet_id, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(T &&t, Params &&... params) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::string topic_filter, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, as::const_buffer topic_filter, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, buffer topic_filter, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, buffer topic_filter, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::vector< std::string > params, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::vector< std::string > params, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::vector< as::const_buffer > params, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::vector< as::const_buffer > params, v5::properties props, async_handler_t func) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::vector< buffer > params, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
async_unsubscribe(packet_id_t packet_id, std::vector< buffer > params, v5::properties props, async_handler_t func={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
auth(v5::auth_reason_code reason_code=v5::auth_reason_code::success, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
clean_session() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
clean_start() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
clean_start_ | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | protected |
clear_session_data() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotected |
clear_stored_publish(packet_id_t packet_id) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client(constructor_access, Args &&... args) | MQTT_NS::client< Socket, 2 > | inline |
client(as::io_context &ioc, std::string host, std::string port, protocol_version version=protocol_version::v3_1_1, bool async_store_send=false) | MQTT_NS::client< Socket, 2 > | inlineprotected |
connack()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::connack(bool session_present, variant< connect_return_code, v5::connect_reason_code > reason_code, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
connect()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::connect(any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(boost::system::error_code &ec, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(v5::properties props, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(v5::properties props, boost::system::error_code &ec, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(std::shared_ptr< Socket > &&socket, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(std::shared_ptr< Socket > &&socket, boost::system::error_code &ec, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(std::shared_ptr< Socket > &&socket, v5::properties props, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::connect(std::shared_ptr< Socket > &&socket, v5::properties props, boost::system::error_code &ec, any session_life_keeper=any()) | MQTT_NS::client< Socket, 2 > | inline |
endpoint< std::mutex, std::lock_guard, PacketIdBytes >::connect(std::string const &client_id, optional< std::string > const &user_name, optional< std::string > const &password, optional< will > w, std::uint16_t keep_alive_sec, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
endpoint< std::mutex, std::lock_guard, PacketIdBytes >::connect(buffer client_id, optional< buffer > user_name, optional< buffer > password, optional< will > w, std::uint16_t keep_alive_sec, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
connected() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
disconnect()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::disconnect(std::chrono::steady_clock::duration timeout, v5::disconnect_reason_code reason_code=v5::disconnect_reason_code::normal_disconnection, v5::properties props={}) | MQTT_NS::client< Socket, 2 > | inline |
client< Socket, 2 >::disconnect(v5::disconnect_reason_code reason_code=v5::disconnect_reason_code::normal_disconnection, v5::properties props={}) | MQTT_NS::client< Socket, 2 > | inline |
endpoint(as::io_context &ioc, protocol_version version=protocol_version::undetermined, bool async_send_store=false) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
endpoint(as::io_context &ioc, std::shared_ptr< MQTT_NS::socket > socket, protocol_version version=protocol_version::undetermined, bool async_send_store=false) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineexplicit |
endpoint(this_type const &)=delete | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | |
endpoint(this_type &&)=delete | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | |
for_each_store(std::function< void(char const *, std::size_t)> const &f) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
for_each_store(std::function< void(basic_store_message_variant< PacketIdBytes >)> const &f) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
for_each_store_with_life_keeper(std::function< void(basic_store_message_variant< PacketIdBytes >, any)> const &f) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
force_disconnect() | MQTT_NS::client< Socket, 2 > | inline |
get_client_id() const | MQTT_NS::client< Socket, 2 > | inline |
get_executor() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
get_protocol_version() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
get_total_bytes_received() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
get_total_bytes_sent() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
handle_close_or_error(error_code ec) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotected |
make_async_client(as::io_context &ioc, std::string host, std::string port, protocol_version version) | MQTT_NS::async_client< Socket, PacketIdBytes > | friend |
make_async_client_32(as::io_context &ioc, std::string host, std::string port, protocol_version version) | MQTT_NS::async_client< Socket, PacketIdBytes > | friend |
make_async_client_no_strand(as::io_context &ioc, std::string host, std::string port, protocol_version version) | MQTT_NS::async_client< Socket, PacketIdBytes > | friend |
make_async_client_no_strand_32(as::io_context &ioc, std::string host, std::string port, protocol_version version) | MQTT_NS::async_client< Socket, PacketIdBytes > | friend |
on_close() noexcept override | MQTT_NS::client< Socket, 2 > | inlineprotectedvirtual |
on_error(error_code ec) noexcept override | MQTT_NS::client< Socket, 2 > | inlineprotectedvirtual |
on_mqtt_message_processed(any session_life_keeper) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotectedvirtual |
on_pre_send() noexcept override | MQTT_NS::client< Socket, 2 > | inlineprotectedvirtual |
operator=(this_type const &)=delete | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | |
operator=(this_type &&)=delete | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | |
packet_id_t typedef | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | |
pingreq() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
pingresp()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
puback()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::puback(packet_id_t packet_id, v5::puback_reason_code reason_code=v5::puback_reason_code::success, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
pubcomp()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::pubcomp(packet_id_t packet_id, v5::pubcomp_reason_code reason_code=v5::pubcomp_reason_code::success, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
publish()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::publish(T &&t, Params &&... params) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::publish(packet_id_t packet_id, std::string topic_name, std::string contents, publish_options pubopts={}, v5::properties props={}, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::publish(packet_id_t packet_id, as::const_buffer topic_name, ConstBufferSequence contents, publish_options pubopts, v5::properties props, any life_keeper) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::publish(packet_id_t packet_id, as::const_buffer topic_name, ConstBufferSequence contents, publish_options pubopts, any life_keeper) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::publish(packet_id_t packet_id, buffer topic_name, BufferSequence contents, publish_options pubopts={}, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::publish(packet_id_t packet_id, buffer topic_name, BufferSequence contents, publish_options pubopts, v5::properties props, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
pubrec()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::pubrec(packet_id_t packet_id, v5::pubrec_reason_code reason_code=v5::pubrec_reason_code::success, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
pubrel()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::pubrel(packet_id_t packet_id, v5::pubrel_reason_code reason_code=v5::pubrel_reason_code::success, v5::properties props={}, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
register_packet_id(packet_id_t packet_id) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
release_packet_id(packet_id_t packet_id) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_serialized_message(Iterator b, Iterator e) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_serialized_message(basic_publish_message< PacketIdBytes > msg, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_serialized_message(basic_pubrel_message< PacketIdBytes > msg, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_serialized_message(basic_store_message_variant< PacketIdBytes > msg, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_v5_serialized_message(Iterator b, Iterator e) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_v5_serialized_message(v5::basic_publish_message< PacketIdBytes > msg, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
restore_v5_serialized_message(v5::basic_pubrel_message< PacketIdBytes > msg, any life_keeper={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
send_store_message(basic_store_message_variant< PacketIdBytes > msg, any life_keeper) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_async_pingreq(bool b) | MQTT_NS::client< Socket, 2 > | inline |
set_auto_map_topic_alias_send(bool b=true) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_auto_pub_response(bool b=true) | MQTT_NS::async_client< Socket, PacketIdBytes > | inline |
client< Socket, 2 >::set_auto_pub_response(bool b=true, bool async=true) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_auto_replace_topic_alias_send(bool b=true) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_clean_session(bool cs) | MQTT_NS::client< Socket, 2 > | inline |
set_clean_start(bool cs) | MQTT_NS::client< Socket, 2 > | inline |
set_client_id(std::string id) | MQTT_NS::client< Socket, 2 > | inline |
set_connect() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotected |
set_host(std::string host) | MQTT_NS::client< Socket, 2 > | inline |
set_keep_alive_sec(std::uint16_t keep_alive_sec, std::chrono::steady_clock::duration ping) | MQTT_NS::client< Socket, 2 > | inline |
set_keep_alive_sec(std::uint16_t keep_alive_sec) | MQTT_NS::client< Socket, 2 > | inline |
set_keep_alive_sec_ping_ms(std::uint16_t keep_alive_sec, std::size_t ping_ms) | MQTT_NS::client< Socket, 2 > | inline |
set_max_queue_send_count(std::size_t count) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_max_queue_send_size(std::size_t size) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_packet_bulk_read_limit(std::size_t size) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_password(std::string password) | MQTT_NS::client< Socket, 2 > | inline |
set_pingresp_timeout(std::chrono::steady_clock::duration tim) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_port(std::string port) | MQTT_NS::client< Socket, 2 > | inline |
set_props_bulk_read_limit(std::size_t size) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_protocol_version(protocol_version version) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotected |
set_topic_alias_maximum(topic_alias_t max) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
set_user_name(std::string name) | MQTT_NS::client< Socket, 2 > | inline |
set_will(will w) | MQTT_NS::client< Socket, 2 > | inline |
set_will(Args &&... args) | MQTT_NS::client< Socket, 2 > | inline |
socket() const | MQTT_NS::client< Socket, 2 > | inline |
socket() | MQTT_NS::client< Socket, 2 > | inline |
socket_sp_ref() | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inlineprotected |
endpoint< std::mutex, std::lock_guard, PacketIdBytes >::start_session(any session_life_keeper=any()) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
suback()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::suback(packet_id_t packet_id, variant< suback_return_code, v5::suback_reason_code > reason, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::suback(packet_id_t packet_id, variant< std::vector< suback_return_code >, std::vector< v5::suback_reason_code >> reasons, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
subscribe()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::subscribe(T &&t, Params &&... params) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::subscribe(packet_id_t packet_id, string_view topic_filter, subscribe_options option, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::subscribe(packet_id_t packet_id, as::const_buffer topic_filter, subscribe_options option, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::subscribe(packet_id_t packet_id, std::vector< std::tuple< string_view, subscribe_options >> params, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::subscribe(packet_id_t packet_id, std::vector< std::tuple< buffer, subscribe_options >> params, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
underlying_connected() const | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
unsuback()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::unsuback(packet_id_t packet_id) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsuback(packet_id_t packet_id, v5::unsuback_reason_code reason, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsuback(packet_id_t packet_id, std::vector< v5::unsuback_reason_code > reasons, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
unsubscribe()=delete | MQTT_NS::async_client< Socket, PacketIdBytes > | |
client< Socket, 2 >::unsubscribe(T &&t, Params &&... params) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsubscribe(packet_id_t packet_id, string_view topic_filter, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsubscribe(packet_id_t packet_id, as::const_buffer topic_filter, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsubscribe(packet_id_t packet_id, std::vector< string_view > params, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsubscribe(packet_id_t packet_id, std::vector< as::const_buffer > params, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
client< Socket, 2 >::unsubscribe(packet_id_t packet_id, std::vector< buffer > params, v5::properties props={}) | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | inline |
~async_client()=default | MQTT_NS::async_client< Socket, PacketIdBytes > | protected |
~client()=default | MQTT_NS::client< Socket, 2 > | protected |
~endpoint()=default | MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes > | protected |