subscriber

Documentation

Index

• type Logger
  • func NewLogger(w io.Writer, sub hub.Subscription, development bool) *Logger
  • func (l *Logger) Do()
  • func (l *Logger) Stop()

Types

type Logger

type Logger struct {
	zerolog.Logger
	// contains filtered or unexported fields
}

Logger is wrapper around the zerolog.Logger with the ability to handle messages from hub.Subscription

func NewLogger

func NewLogger(w io.Writer, sub hub.Subscription, development bool) *Logger

NewLogger create an Logger.

func (*Logger) Do

func (l *Logger) Do()

Do will start consuming messages from the subscriber and stop when the Subscription is closed

func (*Logger) Stop

func (l *Logger) Stop()

Stop close any open file and clean stuffs