mqtt_cpp
MQTT_NS::async_client< Socket, PacketIdBytes > Member List

This is the complete list of members for MQTT_NS::async_client< Socket, PacketIdBytes >, including all inherited members.

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 typedefMQTT_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() constMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
clean_start() constMQTT_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()=deleteMQTT_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()=deleteMQTT_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() constMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
disconnect()=deleteMQTT_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 &)=deleteMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >
endpoint(this_type &&)=deleteMQTT_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() constMQTT_NS::client< Socket, 2 >inline
get_executor()MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
get_protocol_version() constMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
get_total_bytes_received() constMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
get_total_bytes_sent() constMQTT_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 overrideMQTT_NS::client< Socket, 2 >inlineprotectedvirtual
on_error(error_code ec) noexcept overrideMQTT_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 overrideMQTT_NS::client< Socket, 2 >inlineprotectedvirtual
operator=(this_type const &)=deleteMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >
operator=(this_type &&)=deleteMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >
packet_id_t typedefMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >
pingreq()MQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
pingresp()=deleteMQTT_NS::async_client< Socket, PacketIdBytes >
puback()=deleteMQTT_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()=deleteMQTT_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()=deleteMQTT_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()=deleteMQTT_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()=deleteMQTT_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() constMQTT_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()=deleteMQTT_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()=deleteMQTT_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() constMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >inline
unsuback()=deleteMQTT_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()=deleteMQTT_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()=defaultMQTT_NS::async_client< Socket, PacketIdBytes >protected
~client()=defaultMQTT_NS::client< Socket, 2 >protected
~endpoint()=defaultMQTT_NS::endpoint< std::mutex, std::lock_guard, PacketIdBytes >protected