autopaho

package

Go to main page

Versions in this module

v0

v0.22.0

Oct 13, 2024

Changes in this version

+ type Backoff func(attempt int) time.Duration

+ func DefaultExponentialBackoff() Backoff

+ func NewConstantBackoff(delay time.Duration) Backoff

+ func NewExponentialBackoff(minDelay time.Duration, maxDelay time.Duration, initialMaxDelay time.Duration, ...) Backoff

type ClientConfig

+ ReconnectBackoff func(int) time.Duration

v0.21.0

Feb 26, 2024

v0.20.0

Feb 3, 2024

Changes in this version

type ClientConfig

+ CleanStartOnInitialConnection bool

+ ConnectPacketBuilder func(*paho.Connect, *url.URL) *paho.Connect

+ ConnectPassword []byte

+ ConnectUsername string

+ DisconnectPacketBuilder func() *paho.Disconnect

+ Errors log.Logger

+ Queue queue.Queue

+ ServerUrls []*url.URL

+ SessionExpiryInterval uint32

+ WillMessage *paho.WillMessage

+ WillProperties *paho.WillProperties

+ func (cfg *ClientConfig) SetDisConnectPacketConfigurator(fn func() *paho.Disconnect)

type ConnectionManager

+ func (c *ConnectionManager) AddOnPublishReceived(f func(PublishReceived) (bool, error)) func()

+ func (c *ConnectionManager) Authenticate(ctx context.Context, a *paho.Auth) (*paho.AuthResponse, error)

+ func (c *ConnectionManager) PublishViaQueue(ctx context.Context, p *QueuePublish) error

+ func (c *ConnectionManager) TerminateConnectionForTest()

+ type PublishReceived struct

+ ConnectionManager *ConnectionManager

+ type QueuePublish struct

v0.12.0

Oct 15, 2023

Changes in this version

type ClientConfig

+ AttemptConnection func(context.Context, ClientConfig, *url.URL) (net.Conn, error)

+ type ConnackError struct

+ Err error

+ Reason string

+ ReasonCode byte

+ func NewConnackError(err error, connack *paho.Connack) *ConnackError

+ func (c *ConnackError) Error() string

+ func (c *ConnackError) Unwrap() error

v0.11.0

Mar 12, 2023

Changes in this version

type ClientConfig

+ PahoErrors paho.Logger

v0.10.0

Jul 20, 2021

Changes in this version

+ var ConnectionDownError = errors.New("connection with the MQTT broker is currently down")

+ type ClientConfig struct

+ BrokerUrls []*url.URL

+ ConnectRetryDelay time.Duration

+ ConnectTimeout time.Duration

+ Debug paho.Logger

+ KeepAlive uint16

+ OnConnectError func(error)

+ OnConnectionUp func(*ConnectionManager, *paho.Connack)

+ PahoDebug paho.Logger

+ TlsCfg *tls.Config

+ WebSocketCfg *WebSocketConfig

+ 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 struct

+ func NewConnection(ctx context.Context, cfg ClientConfig) (*ConnectionManager, error)

+ 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 struct

+ func (d *DisconnectError) Error() string

+ type WebSocketConfig struct

+ Dialer func(url *url.URL, tlsCfg *tls.Config) *websocket.Dialer

+ Header func(url *url.URL, tlsCfg *tls.Config) http.Header

v0.9.5

Jul 20, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL