Documentation
¶
Index ¶
- type Handler
- func (h *Handler) AuthConnect(ctx context.Context) error
- func (h *Handler) AuthPublish(ctx context.Context, topic *string, payload *[]byte) error
- func (h *Handler) AuthSubscribe(ctx context.Context, topics *[]string) error
- func (h *Handler) Connect(ctx context.Context) error
- func (h *Handler) Disconnect(ctx context.Context) error
- func (h *Handler) Publish(ctx context.Context, topic *string, payload *[]byte) error
- func (h *Handler) Subscribe(ctx context.Context, topics *[]string) error
- func (h *Handler) Unsubscribe(ctx context.Context, topics *[]string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler implements mqtt.Handler interface.
func (*Handler) AuthConnect ¶
prior forwarding to the MQTT broker.
func (*Handler) AuthPublish ¶
prior forwarding to the MQTT broker.
func (*Handler) AuthSubscribe ¶
prior forwarding to the MQTT broker.
func (*Handler) Disconnect ¶
Disconnect on connection lost.
Source Files
Click to show internal directories.
Click to hide internal directories.