command

Documentation

Index

• type Handler
  • func New(config configuration.Config, connector *platform_connector_lib.Connector, ...) *Handler
  • func (this *Handler) Publish(clientId string, user string, topic string, payload []byte, qos int, ...) (result handler.Result, err error)
  • func (this *Handler) Subscribe(clientId string, user string, topic string) (result handler.Result, err error)

Types

type Handler

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

func New

func New(config configuration.Config, connector *platform_connector_lib.Connector, logger connectionlog.Logger) *Handler

func (*Handler) Publish

func (this *Handler) Publish(clientId string, user string, topic string, payload []byte, qos int, size float64) (result handler.Result, err error)

func (*Handler) Subscribe

func (this *Handler) Subscribe(clientId string, user string, topic string) (result handler.Result, err error)