mqtt

Documentation

Index

• type ListenHandler
• type Listener
  • func NewListener(addr string, hdl ListenHandler, opts ...ListenerOption) (Listener, error)
• type ListenerOption
  • func WithLogLevel(level zerolog.Level) ListenerOption
  • func WithLogger(logger zerolog.Logger) ListenerOption

Types

type ListenHandler

type ListenHandler interface {
	Handle(context.Context, notification.ExecutionMessage)
}

type Listener

type Listener interface {
	Subscribe(context.Context, string) error
}

func NewListener

func NewListener(addr string, hdl ListenHandler, opts ...ListenerOption) (Listener, error)

type ListenerOption

type ListenerOption func(*listener)

func WithLogLevel

func WithLogLevel(level zerolog.Level) ListenerOption

func WithLogger

func WithLogger(logger zerolog.Logger) ListenerOption