AWS IoT Device SDK C++ v2
1.34.0
AWS IoT Device SDK C++ v2
|
Go to the documentation of this file.
18 class DisconnectPacket;
20 class Mqtt5ClientOptions;
21 class NegotiatedSettings;
25 class SubscribePacket;
27 class UnsubscribePacket;
29 class Mqtt5ClientCore;
31 class Mqtt5to3AdapterOptions;
46 Default = AWS_MQTT5_COTABT_DEFAULT,
56 Manual = AWS_MQTT5_COTABT_MANUAL,
62 LRU = AWS_MQTT5_COTABT_LRU,
67 Disabled = AWS_MQTT5_COTABT_DISABLED,
84 Default = AWS_MQTT5_CITABT_DEFAULT,
89 Enabled = AWS_MQTT5_CITABT_ENABLED,
94 Disabled = AWS_MQTT5_CITABT_DISABLED,
315 std::function<void(
const std::shared_ptr<Http::HttpRequest> &,
int)>;
343 static std::shared_ptr<Mqtt5Client> NewMqtt5Client(
358 operator bool() const noexcept;
372 bool Start() const noexcept;
380 bool Stop() noexcept;
442 std::shared_ptr<Mqtt5ClientCore> m_client_core;
452 friend class Mqtt5ClientCore;
453 friend class Mqtt5to3AdapterOptions;
505 Mqtt5ClientOptions &WithTlsConnectionOptions(const Io::TlsConnectionOptions &tslOptions) noexcept;
515 const Crt::Http::HttpClientConnectionProxyOptions &proxyOptions) noexcept;
695 bool initializeRawOptions(aws_mqtt5_client_options &raw_options) const noexcept;
762 Io::ClientBootstrap *m_bootstrap;
768 Crt::Io::SocketOptions m_socketOptions;
774 Crt::
Optional<Crt::Io::TlsConnectionOptions> m_tlsConnectionOptions;
779 Crt::
Optional<Crt::Http::HttpClientConnectionProxyOptions> m_proxyOptions;
814 aws_mqtt5_client_topic_alias_options m_topicAliasingOptions;
820 uint32_t m_pingTimeoutMs;
826 uint32_t m_connackTimeoutMs;
832 uint32_t m_ackTimeoutSec;
836 aws_http_proxy_options m_httpProxyOptionsStorage;
837 aws_mqtt5_packet_connect_view m_packetConnectViewStorage;
std::function< void(const std::shared_ptr< Http::HttpRequest > &, int)> OnWebSocketHandshakeInterceptComplete
Definition: Mqtt5Client.h:315
InboundTopicAliasBehaviorType
Definition: Mqtt5Client.h:78
uint64_t incompleteOperationSize
Definition: Mqtt5Client.h:187
int errorCode
Definition: Mqtt5Client.h:218
AWS_CRT_CPP_API Allocator * ApiAllocator() noexcept
Definition: Allocator.cpp:24
std::shared_ptr< NegotiatedSettings > negotiatedSettings
Definition: Mqtt5Client.h:230
OnStoppedEventData()
Definition: Mqtt5Client.h:250
uint64_t m_minConnectedTimeToResetReconnectDelayMs
Definition: Mqtt5Client.h:169
uint64_t incompleteOperationCount
Definition: Mqtt5Client.h:181
Definition: Mqtt5Packets.h:53
PublishReceivedEventData()
Definition: Mqtt5Client.h:258
OnDisconnectionEventData()
Definition: Mqtt5Client.h:238
Definition: Mqtt5Client.h:176
Definition: Mqtt5Packets.h:1551
Definition: Mqtt5Client.h:451
OnConnectionFailureEventData()
Definition: Mqtt5Client.h:216
AWS_CRT_CPP_API int LastError() noexcept
Definition: Api.cpp:422
ExponentialBackoffJitterMode m_reconnectMode
Definition: Mqtt5Client.h:150
Crt::Optional< OutboundTopicAliasBehaviorType > m_outboundBehavior
Definition: Mqtt5Client.h:111
Definition: Mqtt5Client.h:207
Definition: Mqtt5Client.h:226
Definition: MqttConnection.h:158
Definition: Mqtt5Client.h:332
aws_mqtt5_extended_validation_and_flow_control_options ClientExtendedValidationAndFlowControl
Definition: Mqtt5Types.h:200
OnAttemptingConnectEventData()
Definition: Mqtt5Client.h:208
OnConnectionSuccessEventData()
Definition: Mqtt5Client.h:227
uint64_t unackedOperationSize
Definition: Mqtt5Client.h:199
int errorCode
Definition: Mqtt5Client.h:240
std::function< void(const PublishReceivedEventData &)> OnPublishReceivedHandler
Definition: Mqtt5Client.h:308
std::shared_ptr< ConnAckPacket > connAckPacket
Definition: Mqtt5Client.h:219
Definition: Mqtt5Client.h:237
std::function< void(std::shared_ptr< Http::HttpRequest >, const OnWebSocketHandshakeInterceptComplete &)> OnWebSocketHandshakeIntercept
Definition: Mqtt5Client.h:324
Definition: Mqtt5Packets.h:2029
Crt::Optional< InboundTopicAliasBehaviorType > m_inboundBehavior
Definition: Mqtt5Client.h:131
Definition: Mqtt5Client.h:215
Definition: Mqtt5Client.h:257
std::shared_ptr< ConnAckPacket > connAckPacket
Definition: Mqtt5Client.h:229
Crt::Optional< uint16_t > m_inboundCacheMaxSize
Definition: Mqtt5Client.h:141
std::function< void(const OnAttemptingConnectEventData &)> OnAttemptingConnectHandler
Definition: Mqtt5Client.h:282
uint64_t unackedOperationCount
Definition: Mqtt5Client.h:193
Definition: Mqtt5Client.h:101
Definition: Mqtt5Packets.h:663
std::function< void(const OnConnectionFailureEventData &)> OnConnectionFailureHandler
Definition: Mqtt5Client.h:271
std::function< void(const OnDisconnectionEventData &)> OnDisconnectionHandler
Definition: Mqtt5Client.h:276
std::shared_ptr< PublishPacket > publishPacket
Definition: Mqtt5Client.h:259
Definition: StringView.h:852
std::function< void(int, std::shared_ptr< PublishResult >)> OnPublishCompletionHandler
Definition: Mqtt5Client.h:293
#define AWS_CRT_CPP_API
Definition: Exports.h:37
Definition: Allocator.h:11
Definition: Mqtt5Client.h:145
Definition: Mqtt5Packets.h:2235
std::shared_ptr< DisconnectPacket > disconnectPacket
Definition: Mqtt5Client.h:241
aws_allocator Allocator
Definition: Allocator.h:14
Definition: Mqtt5Client.h:249
Crt::Optional< uint16_t > m_outboundCacheMaxSize
Definition: Mqtt5Client.h:123
std::function< void(int, std::shared_ptr< SubAckPacket >)> OnSubscribeCompletionHandler
Definition: Mqtt5Client.h:298
uint64_t m_maxReconnectDelayMs
Definition: Mqtt5Client.h:162
aws_mqtt5_client_session_behavior_type ClientSessionBehaviorType
Definition: Mqtt5Types.h:186
std::function< void(const OnConnectionSuccessEventData &)> OnConnectionSuccessHandler
Definition: Mqtt5Client.h:266
uint64_t m_minReconnectDelayMs
Definition: Mqtt5Client.h:156
std::function< void(const OnStoppedEventData &)> OnStoppedHandler
Definition: Mqtt5Client.h:288
std::basic_string< char, std::char_traits< char >, StlAllocator< char > > String
Definition: Types.h:45
OutboundTopicAliasBehaviorType
Definition: Mqtt5Client.h:40
aws_exponential_backoff_jitter_mode ExponentialBackoffJitterMode
Definition: Mqtt5Types.h:242
aws_mqtt5_client_operation_queue_behavior_type ClientOperationQueueBehaviorType
Definition: Mqtt5Types.h:223
std::function< void(int, std::shared_ptr< UnSubAckPacket >)> OnUnsubscribeCompletionHandler
Definition: Mqtt5Client.h:303