mqtt5

Documentation

Index

• Constants
• type Mqtt5Client
  • func NewMqtt5Client(config config.Mqtt5Config) Mqtt5Client
  • func (c *Mqtt5Client) Connect(ctx context.Context, logger log.Logger) error
  • func (c *Mqtt5Client) Disconnect() error
  • func (c *Mqtt5Client) SetAuthData(secretProvider interfaces.SecretProvider, logger log.Logger) error

Constants

const (
	DefaultDialTimeOut = 30
)

Types

type Mqtt5Client

type Mqtt5Client struct {
	// contains filtered or unexported fields
}

func NewMqtt5Client

func NewMqtt5Client(config config.Mqtt5Config) Mqtt5Client

NewMqtt5Client create, initializes and returns new instance of Mqtt5Client

func (*Mqtt5Client) Connect

func (c *Mqtt5Client) Connect(ctx context.Context, logger log.Logger) error

Connect establishes a connection to a MQTT server.

func (*Mqtt5Client) Disconnect

func (c *Mqtt5Client) Disconnect() error

Disconnect closes the connection to the connected MQTT server.

func (*Mqtt5Client) SetAuthData

func (c *Mqtt5Client) SetAuthData(secretProvider interfaces.SecretProvider, logger log.Logger) error

SetAuthData retrieves and sets up auth data from secret provider according to AuthMode and SecretName