Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Integration ¶
type Integration struct {
// contains filtered or unexported fields
}
Integration implements an Mqtt integration.
func New ¶
func New(config config.MqttConfig, opt *config.IntegrationOption) (*Integration, error)
func (*Integration) Close ¶
func (i *Integration) Close() error
func (*Integration) HandleEvent ¶
func (i *Integration) HandleEvent(ctx context.Context, ch chan integration.HandleError, vars map[string]string, data []byte) (string, error)
Click to show internal directories.
Click to hide internal directories.