mqtt

Documentation

Index

• type MQTT
  • func NewMQTT(logger logger.Logger) *MQTT
  • func (m *MQTT) Close() error
  • func (m *MQTT) Init(metadata bindings.Metadata) error
  • func (m *MQTT) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (m *MQTT) Operations() []bindings.OperationKind
  • func (m *MQTT) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error

Types

type MQTT

type MQTT struct {
	// contains filtered or unexported fields
}

MQTT allows sending and receiving data to/from an MQTT broker

func NewMQTT

func NewMQTT(logger logger.Logger) *MQTT

NewMQTT returns a new MQTT instance

func (*MQTT) Close

func (m *MQTT) Close() error

func (*MQTT) Init

func (m *MQTT) Init(metadata bindings.Metadata) error

Init does MQTT connection parsing

func (*MQTT) Invoke

func (m *MQTT) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (*MQTT) Operations

func (m *MQTT) Operations() []bindings.OperationKind

func (*MQTT) Read

func (m *MQTT) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error