mqtt_api

Dec 20, 2024

Changes in this version

+ func Destroy(api *MqttApi)

+ func DestroyRouter(router *Router)

+ type Context struct

+ Data []byte

+ Topic string

+ func (c *Context) Next()

+ func (c *Context) Response(responseIdentifier string, data []byte) error

+ type Handler func(c *Context)

+ type MqttApi struct

+ func New(opts ...Option) (*MqttApi, error)

+ func (api *MqttApi) Finish()

+ func (api *MqttApi) Options() Options

+ func (api *MqttApi) Router() *Router

+ func (api *MqttApi) Start() error

+ type MqttClient struct

+ type MqttClientOptions struct

+ Address string

+ ClientID string

+ KeepAliveSec int64

+ Password string

+ PingTimeoutSec int64

+ UserName string

+ WriteTimeoutSec int64

+ type Option func(options *Options)

+ func WithLogSkipPaths(logSkipPaths ...string) Option

+ func WithMqttOptions(mqttOptions *MqttClientOptions) Option

+ func WithTopicPrefix(topicPrefix string) Option

+ type Options struct

+ func (options Options) GetTopicPrefix() string

+ type Router struct

+ Group string

+ func NewRouter(group string, globalHandlers []Handler) *Router

+ func (router *Router) AddGlobalHandlers(handlers ...Handler)

+ func (router *Router) AddTopic(topic string, handlers ...Handler) error

+ func (router *Router) Finish()

+ func (router *Router) Start(mqttOptions *MqttClientOptions) error