Documentation
¶
Index ¶
- type MQTTHandler
- type Option
- func WithAllowUnauthenticated(a []string) Option
- func WithAuthenticator(a apis.UserPasswordAuthenticator) Option
- func WithIgnoreUnsupported(a []string) Option
- func WithPublishAsyncAtLeastOnce(b bool) Option
- func WithPublishAsyncAtMostOnce(b bool) Option
- func WithPublishAsyncExactlyOnce(b bool) Option
- func WithPublishTimeout(d time.Duration) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTHandler ¶
type MQTTHandler struct {
// contains filtered or unexported fields
}
func New ¶
func New(logger log.Logger, registry *prometheus.Registry, publisher apis.Publisher, opts ...Option) *MQTTHandler
func (*MQTTHandler) HandleFunc ¶
func (h *MQTTHandler) HandleFunc(messageType byte, handlerFunc mqttserver.HandlerFunc)
func (*MQTTHandler) ServeMQTT ¶
func (h *MQTTHandler) ServeMQTT(c mqttserver.Conn, p mqttcodec.ControlPacket)
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
func WithAuthenticator ¶
func WithAuthenticator(a apis.UserPasswordAuthenticator) Option
func WithIgnoreUnsupported ¶
func WithPublishTimeout ¶
Source Files
Click to show internal directories.
Click to hide internal directories.