ClientCreatorWithCertLoader creates a ClientCreator which leverages the specified cert creator and loader when creating an MQTT client.

CreateMQTTClientConfiguration constructs a MQTTClientConfig based on the provided MessageBusConfig.

CreateMQTTClientOptionsWithDefaults constructs MQTTClientOptions instance with defaults.

DefaultClientCreator returns a default function for creating MQTT clients.

NewMQTTClient constructs a new MQTT client based on the options provided.

NewMQTTClientWithCreator constructs a new MQTT client based on the options and ClientCreator provided.

NewOperationErr creates a new OperationErr.

NewTimeoutError creates a new TimeoutErr.

Different Client operations.

Client facilitates communication to an MQTT server and provides functionality needed to send and receive MQTT messages.

ConnectionOptions contains the connection configurations for the MQTT client.

MQTTClientConfig contains all the configurations for the MQTT client.

MQTTClientOptions contains the client options which are loaded via reflection.

OperationErr defines an error representing operations which have failed.

TimeoutErr defines an error representing operations which have not completed and surpassed the allowed wait time.

ClientCreator defines the function signature for creating an MQTT client.

MessageMarshaller defines the function signature for marshaling structs into []byte.

MessageUnmarshaller defines the function signature for unmarshaling []byte into structs.