Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultMessageProducer ¶
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 ¶
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
}
Click to show internal directories.
Click to hide internal directories.