mqtt

Documentation

Index

• type Handle
• type MQTTMsgServer
  • func NewMQTTMsgServer(client pmqtt.Client) *MQTTMsgServer
  • func (s *MQTTMsgServer) Subscribe(topic string, qos byte, h Handle) error

Types

type Handle

type Handle func(ctx context.Context, client pmqtt.Client, msg pmqtt.Message, ps crouter.Params)

type MQTTMsgServer

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

func NewMQTTMsgServer

func NewMQTTMsgServer(client pmqtt.Client) *MQTTMsgServer

func (*MQTTMsgServer) Subscribe

func (s *MQTTMsgServer) Subscribe(topic string, qos byte, h Handle) error