Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Command ¶
type Command struct {
Name string
Arguments []string
Interval time.Duration
MessageStore store.Store
// contains filtered or unexported fields
}
func (*Command) AddCallback ¶
func (c *Command) AddCallback(clbId interface{}, clb Callback)
func (*Command) LastMessage ¶
func (*Command) RemoveCallback ¶
func (c *Command) RemoveCallback(clbId interface{})
type MQTT ¶
type MQTT struct {
Client MQTTSubscriber
Topic string
QOS byte
MessageStore store.Store
// contains filtered or unexported fields
}
func (*MQTT) AddCallback ¶
func (c *MQTT) AddCallback(clbId interface{}, clb Callback)
func (*MQTT) LastMessage ¶
func (*MQTT) Purge ¶
func (m *MQTT) Purge()
when the mqtt connection is lost, you have to call this function
func (*MQTT) Reinitialise ¶
func (m *MQTT) Reinitialise()
after the mqtt connection is reestablished, you have to call this function
func (*MQTT) RemoveCallback ¶
func (c *MQTT) RemoveCallback(clbId interface{})
type MQTTSubscriber ¶
type Rest ¶
type Rest struct {
HttpClient *http.Client
Method string
Url string
Header map[string][]string
Body func() io.Reader
Interval time.Duration
MessageStore store.Store
// contains filtered or unexported fields
}
func (*Rest) AddCallback ¶
func (c *Rest) AddCallback(clbId interface{}, clb Callback)
func (*Rest) LastMessage ¶
func (*Rest) RemoveCallback ¶
func (c *Rest) RemoveCallback(clbId interface{})
type Static ¶
func (*Static) AddCallback ¶
func (c *Static) AddCallback(clbId interface{}, clb Callback)
func (*Static) LastMessage ¶
func (*Static) RemoveCallback ¶
func (c *Static) RemoveCallback(clbId interface{})
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.