listener

Documentation

Index

• type Listener
  • func NewListener(cfg config.Broker, logger *slog.Logger) (*Listener, error)
  • func (l *Listener) Handle(topic string, handler paho.MessageHandler)
  • func (l *Listener) Listen(ctx context.Context) error
• type SLogLogger
  • func NewLogger(logger *slog.Logger, level slog.Level) *SLogLogger
  • func (s *SLogLogger) Printf(format string, v ...interface{})
  • func (s *SLogLogger) Println(v ...interface{})

Types

type Listener

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

func NewListener

func NewListener(cfg config.Broker, logger *slog.Logger) (*Listener, error)

func (*Listener) Handle

func (l *Listener) Handle(topic string, handler paho.MessageHandler)

func (*Listener) Listen

func (l *Listener) Listen(ctx context.Context) error

type SLogLogger

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

func NewLogger

func NewLogger(logger *slog.Logger, level slog.Level) *SLogLogger

func (*SLogLogger) Printf

func (s *SLogLogger) Printf(format string, v ...interface{})

func (*SLogLogger) Println

func (s *SLogLogger) Println(v ...interface{})