Documentation
¶
Index ¶
- type DryRunClient
- func (d *DryRunClient) Close()
- func (d *DryRunClient) Connect(timeout time.Duration) error
- func (d *DryRunClient) Publish(topic string, qos byte, retain bool, payload []byte) error
- func (d *DryRunClient) SetAvailability(topic string, onlinePayload []byte)
- func (d *DryRunClient) Subscribe(topic string, qos byte, handler func(topic string, payload []byte)) error
- type MQTTClient
- func (m *MQTTClient) Close()
- func (m *MQTTClient) Connect(timeout time.Duration) error
- func (m *MQTTClient) Publish(topic string, qos byte, retain bool, payload []byte) error
- func (m *MQTTClient) SetAvailability(topic string, onlinePayload []byte)
- func (m *MQTTClient) Subscribe(topic string, qos byte, handler func(topic string, payload []byte)) error
- type Publisher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DryRunClient ¶ added in v1.2.0
type DryRunClient struct {
// contains filtered or unexported fields
}
func NewDryRun ¶ added in v1.2.0
func NewDryRun() *DryRunClient
func (*DryRunClient) Close ¶ added in v1.2.0
func (d *DryRunClient) Close()
func (*DryRunClient) Connect ¶ added in v1.2.0
func (d *DryRunClient) Connect(timeout time.Duration) error
func (*DryRunClient) SetAvailability ¶ added in v1.2.0
func (d *DryRunClient) SetAvailability(topic string, onlinePayload []byte)
type MQTTClient ¶
type MQTTClient struct {
// contains filtered or unexported fields
}
func New ¶
func New(o *MQTT.ClientOptions) *MQTTClient
func (*MQTTClient) Close ¶
func (m *MQTTClient) Close()
func (*MQTTClient) SetAvailability ¶
func (m *MQTTClient) SetAvailability(topic string, onlinePayload []byte)
Source Files
Click to show internal directories.
Click to hide internal directories.