logger

Documentation

Index

• type Logger
  • 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

Types

type Logger

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

Logger logs all messages sent and received by the transport.

func New

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

New creates a new Logger transport.

func (*Logger) Broadcast

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

Broadcast implements the transport.Transport interface.

func (*Logger) Messages

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

Messages implements the transport.Transport interface.

func (*Logger) ServiceName

func (r *Logger) ServiceName() string

ServiceName implements the supervisor.WithName interface.

func (*Logger) Start

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

Start implements the transport.Transport interface.

func (*Logger) Wait

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

Wait implements the transport.Transport interface.