pubsub

Documentation

Index

• Constants
• func NewLogger(z *zap.Logger) watermill.LoggerAdapter
• func PublishMessage[P any](ctx context.Context, publisher message.Publisher, topic string, payload P) error
• type Logger
  • func (l *Logger) Debug(msg string, fields watermill.LogFields)
  • func (l *Logger) Error(msg string, err error, fields watermill.LogFields)
  • func (l *Logger) Info(msg string, fields watermill.LogFields)
  • func (l *Logger) Trace(msg string, fields watermill.LogFields)
  • func (l *Logger) With(fields watermill.LogFields) watermill.LoggerAdapter

Constants

const (
	PubSubTraceID = "trace-id"
	PubSubSpanID  = "span-id"
)

const (
	// IRC
	Topic_IRC_CONNECTION_STATE_UPDATE           = "ANIME_PACK/IRC.CONNECTION_STATE_UPDATE"
	Topic_IRC_NOTICE_PENDING_TRANSFER           = "ANIME_PACK/IRC.NOTICE_PENDING_TRANSFER"
	Topic_IRC_PRIVATE_ANNOUNCE_PACK             = "ANIME_PACK/IRC.PRIVMSG_ANNOUNCE_PACK"
	Topic_IRC_PRIVATE_MESSAGE_TRANSFER_IN_QUEUE = "ANIME_PACK/IRC.PRIVMSG_TRANSFER_IN_QUEUE"
	Topic_IRC_BOT_STATE_UPDATE                  = "ANIME_PACK/IRC.BOT_STATE_UPDATE"
	Topic_IRC_CTCP_DCC                          = "ANIME_PACK/IRC.CTCP_DCC"

	// Job
	Topic_JOB_STATE_UPDATE = "ANIME_PACK/JOB.STATE_UPDATE"
)

Functions

func NewLogger

func NewLogger(z *zap.Logger) watermill.LoggerAdapter

NewLogger returns new watermill.LoggerAdapter using passed *zap.Logger as backend.

func PublishMessage

func PublishMessage[P any](
	ctx context.Context,
	publisher message.Publisher,
	topic string,
	payload P,
) error

Types

type Logger

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

Logger implements watermill.LoggerAdapter with *zap.Logger.

func (*Logger) Debug

func (l *Logger) Debug(msg string, fields watermill.LogFields)

Debug writes debug log with message and some fields.

func (*Logger) Error

func (l *Logger) Error(msg string, err error, fields watermill.LogFields)

Error writes error log with message, error and some fields.

func (*Logger) Info

func (l *Logger) Info(msg string, fields watermill.LogFields)

Info writes info log with message and some fields.

func (*Logger) Trace

func (l *Logger) Trace(msg string, fields watermill.LogFields)

Trace writes debug log instead of trace log because zap does not support trace level logging.

func (*Logger) With

func (l *Logger) With(fields watermill.LogFields) watermill.LoggerAdapter

With returns new LoggerAdapter with passed fields.