pm_logrus

Documentation

Index

• func DefaultMessageProducer(ctx context.Context, msg string, err error, duration time.Duration)
• func SubscriptionInterceptor(logger *logrus.Logger, opt ...Option) pm.SubscriptionInterceptor
• type MessageProducer
• type Option
  • func WithLogDecider(f pm_logging.LogDecider) Option
  • func WithMessageProducer(f MessageProducer) Option
• type OptionFunc

Functions

func DefaultMessageProducer

func DefaultMessageProducer(ctx context.Context, msg string, err error, duration time.Duration)

DefaultMessageProducer writes the default message

func SubscriptionInterceptor

func SubscriptionInterceptor(logger *logrus.Logger, opt ...Option) pm.SubscriptionInterceptor

SubscriptionInterceptor returns a subscription interceptor that optionally logs the subscription process.

Types

type MessageProducer

type MessageProducer func(ctx context.Context, msg string, err error, duration time.Duration)

MessageProducer produces a user defined log message

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option is a option to change configuration.

func WithLogDecider

func WithLogDecider(f pm_logging.LogDecider) Option

WithLogDecider customizes the function for deciding if the pm interceptor should log.

func WithMessageProducer

func WithMessageProducer(f MessageProducer) Option

WithMessageProducer customizes the function for logging.

type OptionFunc

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