Documentation ¶
Index ¶
- Variables
- type ClientConfig
- func (cfg *ClientConfig) ResetUsernamePassword()
- func (cfg *ClientConfig) SetConnectPacketConfigurator(fn func(*paho.Connect) *paho.Connect) bool
- func (cfg *ClientConfig) SetUsernamePassword(username string, password []byte)
- func (cfg *ClientConfig) SetWillMessage(topic string, payload []byte, qos byte, retain bool)
- type ConnectionManager
- func (c *ConnectionManager) AwaitConnection(ctx context.Context) error
- func (c *ConnectionManager) Disconnect(ctx context.Context) error
- func (c *ConnectionManager) Done() <-chan struct{}
- func (c *ConnectionManager) Publish(ctx context.Context, p *paho.Publish) (*paho.PublishResponse, error)
- func (c *ConnectionManager) Subscribe(ctx context.Context, s *paho.Subscribe) (*paho.Suback, error)
- func (c *ConnectionManager) Unsubscribe(ctx context.Context, u *paho.Unsubscribe) (*paho.Unsuback, error)
- type DisconnectError
- type WebSocketConfig
Constants ¶
This section is empty.
Variables ¶
var ConnectionDownError = errors.New("connection with the MQTT broker is currently down")
ConnectionDownError Down will be returned when a request is made but the connection to the broker is down Note: It is possible that the connection will drop between the request being made and a response being received in which case a different error will be received (this is only returned if the connection is down at the time the request is made).
Functions ¶
This section is empty.
Types ¶
type ClientConfig ¶
type ClientConfig struct { BrokerUrls []*url.URL // URL(s) for the broker (schemes supported include 'mqtt' and 'tls') TlsCfg *tls.Config // Configuration used when connecting using TLS KeepAlive uint16 // Keepalive period in seconds (the maximum time interval that is permitted to elapse between the point at which the Client finishes transmitting one MQTT Control Packet and the point it starts sending the next) ConnectRetryDelay time.Duration // How long to wait between connection attempts (defaults to 10s) ConnectTimeout time.Duration // How long to wait for the connection process to complete (defaults to 10s) WebSocketCfg *WebSocketConfig // Enables customisation of the websocket connection OnConnectionUp func(*ConnectionManager, *paho.Connack) // Called (within a goroutine) when a connection is made (including reconnection). Connection Manager passed to simplify subscriptions. OnConnectError func(error) // Called (within a goroutine) whenever a connection attempt fails Debug paho.Logger // By default set to NOOPLogger{},set to a logger for debugging info PahoDebug paho.Logger // debugger passed to the paho package (will default to NOOPLogger{}) // We include the full paho.ClientConfig in order to simplify moving between the two packages. // Note that that Conn will be ignored. paho.ClientConfig // contains filtered or unexported fields }
ClientConfig adds a few values, required to manage the connection, to the standard paho.ClientConfig (note that conn will be ignored)
func (*ClientConfig) ResetUsernamePassword ¶
func (cfg *ClientConfig) ResetUsernamePassword()
ResetUsernamePassword clears any configured username and password on the client configuration
func (*ClientConfig) SetConnectPacketConfigurator ¶
SetConnectPacketConfigurator assigns a callback for modification of the Connect packet, called before the connection is opened, allowing the application to adjust its configuration before establishing a connection. This function should be treated as asynchronous, and expected to have no side effects.
func (*ClientConfig) SetUsernamePassword ¶
func (cfg *ClientConfig) SetUsernamePassword(username string, password []byte)
SetUsernamePassword configures username and password properties for the Connect packets These values are staged in the ClientConfig, and preparation of the Connect packet is deferred.
func (*ClientConfig) SetWillMessage ¶
func (cfg *ClientConfig) SetWillMessage(topic string, payload []byte, qos byte, retain bool)
SetWillMessage configures the Will topic, payload, QOS and Retain facets of the client connection These values are staged in the ClientConfig, for later preparation of the Connect packet.
type ConnectionManager ¶
type ConnectionManager struct {
// contains filtered or unexported fields
}
ConnectionManager manages the connection with the broker and provides thew ability to publish messages
func NewConnection ¶
func NewConnection(ctx context.Context, cfg ClientConfig) (*ConnectionManager, error)
NewConnection creates a connection manager and begins the connection process (will retry until the context is cancelled)
func (*ConnectionManager) AwaitConnection ¶
func (c *ConnectionManager) AwaitConnection(ctx context.Context) error
AwaitConnection will return when the connection comes up or the context is cancelled (only returns an error if context is cancelled). If you require more complex connection management then consider using the OnConnectionUp callback.
func (*ConnectionManager) Disconnect ¶
func (c *ConnectionManager) Disconnect(ctx context.Context) error
Disconnect closes the connection (if one is up) and shuts down any active processes before returning Note: We cannot currently tell when the mqtt has fully shutdown (so it may still be in the process of closing down)
func (*ConnectionManager) Done ¶
func (c *ConnectionManager) Done() <-chan struct{}
Done returns a channel that will be closed when the connection handler has shutdown cleanly Note: We cannot currently tell when the mqtt has fully shutdown (so it may still be in the process of closing down)
func (*ConnectionManager) Publish ¶
func (c *ConnectionManager) Publish(ctx context.Context, p *paho.Publish) (*paho.PublishResponse, error)
Publish is used to send a publication to the MQTT server. It is passed a pre-prepared Publish packet and blocks waiting for the appropriate response, or for the timeout to fire. Any response message is returned from the function, along with any errors.
func (*ConnectionManager) Subscribe ¶
Subscribe is used to send a Subscription request to the MQTT server. It is passed a pre-prepared Subscribe packet and blocks waiting for a response Suback, or for the timeout to fire. Any response Suback is returned from the function, along with any errors.
func (*ConnectionManager) Unsubscribe ¶
func (c *ConnectionManager) Unsubscribe(ctx context.Context, u *paho.Unsubscribe) (*paho.Unsuback, error)
Unsubscribe is used to send an Unsubscribe request to the MQTT server. It is passed a pre-prepared Unsubscribe packet and blocks waiting for a response Unsuback, or for the timeout to fire. Any response Unsuback is returned from the function, along with any errors.
type DisconnectError ¶
type DisconnectError struct {
// contains filtered or unexported fields
}
DisconnectError will be passed when the server requests disconnection (allows this error type to be detected)
func (*DisconnectError) Error ¶
func (d *DisconnectError) Error() string
type WebSocketConfig ¶
type WebSocketConfig struct { Dialer func(url *url.URL, tlsCfg *tls.Config) *websocket.Dialer // If non-nil this will be called before each websocket connection (allows full configuration of the dialer used) Header func(url *url.URL, tlsCfg *tls.Config) http.Header // If non-nil this will be called before each connection attempt to get headers to include with request }
WebSocketConfig enables customisation of the websocket connection