simple

Documentation

Index

• type Handler
  • func New(logger logger.Logger) *Handler
  • func (h *Handler) AuthConnect(c *session.Client) error
  • func (h *Handler) AuthPublish(c *session.Client, topic *string, payload *[]byte) error
  • func (h *Handler) AuthSubscribe(c *session.Client, topics *[]string) error
  • func (h *Handler) Connect(c *session.Client)
  • func (h *Handler) Disconnect(c *session.Client)
  • func (h *Handler) Publish(c *session.Client, topic *string, payload *[]byte)
  • func (h *Handler) Subscribe(c *session.Client, topics *[]string)
  • func (h *Handler) Unsubscribe(c *session.Client, topics *[]string)

Types

type Handler

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

Handler implements mqtt.Handler interface

func New

func New(logger logger.Logger) *Handler

New creates new Event entity

func (*Handler) AuthConnect

func (h *Handler) AuthConnect(c *session.Client) error

AuthConnect is called on device connection, prior forwarding to the MQTT broker

func (*Handler) AuthPublish

func (h *Handler) AuthPublish(c *session.Client, topic *string, payload *[]byte) error

AuthPublish is called on device publish, prior forwarding to the MQTT broker

func (*Handler) AuthSubscribe

func (h *Handler) AuthSubscribe(c *session.Client, topics *[]string) error

AuthSubscribe is called on device publish, prior forwarding to the MQTT broker

func (*Handler) Connect

func (h *Handler) Connect(c *session.Client)

Connect - after client successfully connected

func (*Handler) Disconnect

func (h *Handler) Disconnect(c *session.Client)

Disconnect on conection lost

func (*Handler) Publish

func (h *Handler) Publish(c *session.Client, topic *string, payload *[]byte)

Publish - after client successfully published

func (*Handler) Subscribe

func (h *Handler) Subscribe(c *session.Client, topics *[]string)

Subscribe - after client successfully subscribed

func (*Handler) Unsubscribe

func (h *Handler) Unsubscribe(c *session.Client, topics *[]string)

Unsubscribe - after client unsubscribed