Documentation
¶
Index ¶
- func NewDesiredStateClient(domain string, updateAgent api.UpdateAgentClient) (api.DesiredStateClient, error)
- func NewUpdateAgentClient(domain string, config *ConnectionConfig) api.UpdateAgentClient
- func NewUpdateAgentThingsClient(domain string, config *ConnectionConfig) api.UpdateAgentClient
- type ConnectionConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDesiredStateClient ¶
func NewDesiredStateClient(domain string, updateAgent api.UpdateAgentClient) (api.DesiredStateClient, error)
NewDesiredStateClient instantiates a new client for triggering MQTT requests.
func NewUpdateAgentClient ¶
func NewUpdateAgentClient(domain string, config *ConnectionConfig) api.UpdateAgentClient
NewUpdateAgentClient instantiates a new UpdateAgentClient instance using the provided configuration options.
func NewUpdateAgentThingsClient ¶
func NewUpdateAgentThingsClient(domain string, config *ConnectionConfig) api.UpdateAgentClient
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"`
}
ConnectionConfig represents the mqtt client connection config
func NewDefaultConfig ¶
func NewDefaultConfig() *ConnectionConfig
NewDefaultConfig returns a default mqtt client connection config instance
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.