beanstalk

Documentation

Index

• func NewPool(config *config.Config, logger *LoggerAdapter) beanstalk.Pool
• func RegisterHooks(lifecycle fx.Lifecycle, pool beanstalk.Pool)
• type LoggerAdapter
  • func NewLoggerAdapter(logger *zap.Logger) *LoggerAdapter
  • func (l *LoggerAdapter) Log(level beanstalk.LogLevel, msg string, args map[string]interface{})

Functions

func NewPool

func NewPool(config *config.Config, logger *LoggerAdapter) beanstalk.Pool

func RegisterHooks

func RegisterHooks(lifecycle fx.Lifecycle, pool beanstalk.Pool)

Types

type LoggerAdapter

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

func NewLoggerAdapter

func NewLoggerAdapter(logger *zap.Logger) *LoggerAdapter

func (*LoggerAdapter) Log

func (l *LoggerAdapter) Log(level beanstalk.LogLevel, msg string, args map[string]interface{})