Connect is a convenience function which sets a broker and connects to it.

NewClient will create an MQTT v3.1.1 client with all of the options specified in the provided ClientOptions.

NewTrie creates a new subscriptions matcher using standard emitter strategy.

NewTrieMQTT creates a new subscriptions matcher using standard MQTT strategy.

WithAtLeastOnce instructs to publish at least once (MQTT QoS 1).

WithAtMostOnce instructs to publish at most once (MQTT QoS 0).

WithAutoReconnect sets whether the automatic reconnection logic should be used when the connection is lost, even if disabled the ConnectionLostHandler is still called.

WithBrokers configures broker URIs to connect to.

WithClientID will set the client id to be used by this client when connecting to the MQTT broker.

WithConnectTimeout limits how long the client will wait when trying to open a connection to an MQTT server before timeing out and erroring the attempt.

WithFrom request messages from a point in time.

WithKeepAlive will set the amount of time (in seconds) that the client should wait before sending a PING request to the broker.

WithLast constructs an option which can be used during subscribe requests to retrieve a message history.

WithMatcher If "mqtt", then topic matching would follow MQTT specification.

WithMaxReconnectInterval sets the maximum time that will be waited between reconnection attempts when connection is lost.

WithoutEcho constructs an option which disables self-receiving messages if subscribed to a channel.

WithPassword will set the password to be used by this client when connecting to the MQTT broker.

WithPingTimeout will set the amount of time (in seconds) that the client will wait after sending a PING request to the broker, before deciding that the connection has been lost.

WithRetain constructs an option which sets the message 'retain' flag to true.

WithTLSConfig will set an SSL/TLS configuration to be used when connecting to an MQTT broker.

WithTTL constructs an option which can be used during publish requests to set a Time-To-Live.

WithUntil request messages until a point in time.

WithUsername will set the username to be used by this client when connecting to the MQTT broker.

Various emitter errors.

Various emitter errors.

Client represents an emitter client which holds the connection.

Error represents an event code which provides a more details.

Link represents a response for the link creation.

PresenceEvent represents a response from emitter broker which contains presence state or a join/leave notification.

PresenceInfo represents a response from emitter broker which contains presence information.

Message defines the externals that a message implementation must support these are received messages that are passed to the callbacks, not internal messages.

Option represents a key/value pair that can be supplied to the publish/subscribe or unsubscribe methods and provide ways to configure the operation.

Response represents a generic response sent by the broker.

ConnectHandler is a callback that is called when the client state changes from unconnected/disconnected to connected.

DisconnectHandler is a callback type which can be set to be executed upon an unintended disconnection from the MQTT broker.

ErrorHandler is a callback type which can be set to be executed upon the arrival of an emitter error.

MessageHandler is a callback type which can be set to be executed upon the arrival of messages published to topics to which the client is subscribed.

PresenceHandler is a callback type which can be set to be executed upon the arrival of presence events.