logger

Sep 29, 2023

Changes in this version

+ type Logger struct

+ func New(t transport.Service, l log.Logger) *Logger

+ func (r *Logger) Broadcast(topic string, message transport.Message) error

+ func (r *Logger) Messages(topic string) <-chan transport.ReceivedMessage

+ func (r *Logger) ServiceName() string

+ func (r *Logger) Start(ctx context.Context) error

+ func (r *Logger) Wait() <-chan error