mqtt

Documentation

Index

• func NewDesiredStateClient(domain string, updateAgent api.UpdateAgentClient) (api.DesiredStateClient, error)
• func NewOwnerConsentAgentClient(domain string, config *ConnectionConfig) (api.OwnerConsentAgentClient, error)
• func NewOwnerConsentClient(domain string, updateAgent api.UpdateAgentClient) (api.OwnerConsentClient, error)
• func NewUpdateAgentClient(domain string, config *ConnectionConfig) (api.UpdateAgentClient, error)
• func NewUpdateAgentThingsClient(domain string, config *ConnectionConfig) (api.UpdateAgentClient, error)
• type ConnectionConfig
  • func NewDefaultConfig() *ConnectionConfig

Functions

func NewDesiredStateClient

func NewDesiredStateClient(domain string, updateAgent api.UpdateAgentClient) (api.DesiredStateClient, error)

NewDesiredStateClient instantiates a new client for triggering MQTT requests.

func NewOwnerConsentAgentClient

func NewOwnerConsentAgentClient(domain string, config *ConnectionConfig) (api.OwnerConsentAgentClient, error)

NewOwnerConsentAgentClient instantiates a new client for triggering MQTT requests.

func NewOwnerConsentClient

func NewOwnerConsentClient(domain string, updateAgent api.UpdateAgentClient) (api.OwnerConsentClient, error)

NewOwnerConsentClient instantiates a new client for triggering MQTT requests.

func NewUpdateAgentClient

func NewUpdateAgentClient(domain string, config *ConnectionConfig) (api.UpdateAgentClient, error)

NewUpdateAgentClient instantiates a new UpdateAgentClient instance using the provided configuration options.

func NewUpdateAgentThingsClient

func NewUpdateAgentThingsClient(domain string, config *ConnectionConfig) (api.UpdateAgentClient, error)

NewUpdateAgentThingsClient instantiates a new UpdateAgentClient instance using the provided configuration options.

Types

type ConnectionConfig

type ConnectionConfig struct {
	Broker             string `json:"broker,omitempty"`
	KeepAlive          string `json:"keepAlive,omitempty"`
	DisconnectTimeout  string `json:"disconnectTimeout,omitempty"`
	Username           string `json:"username,omitempty"`
	Password           string `json:"password,omitempty"`
	ConnectTimeout     string `json:"connectTimeout,omitempty"`
	AcknowledgeTimeout string `json:"acknowledgeTimeout,omitempty"`
	SubscribeTimeout   string `json:"subscribeTimeout,omitempty"`
	UnsubscribeTimeout string `json:"unsubscribeTimeout,omitempty"`
	CACert             string `json:"caCert,omitempty"`
	Cert               string `json:"cert,omitempty"`
	Key                string `json:"key,omitempty"`
}

ConnectionConfig represents the mqtt client connection config

func NewDefaultConfig

func NewDefaultConfig() *ConnectionConfig

NewDefaultConfig returns a default mqtt client connection config instance