loggerimpl

Documentation

Index

• func NewDevelopment() (log.Logger, error)
• func NewLogger(zapLogger *zap.Logger, opts ...Option) log.Logger
• func NewNopLogger() log.Logger
• func NewReplayLogger(logger log.Logger, ctx workflow.Context, enableLogInReplay bool) log.Logger
• func NewThrottledLogger(logger log.Logger, rps dynamicconfig.IntPropertyFn) log.Logger
• type Option
  • func WithSampleFunc(fn func(int) bool) Option

Functions

func NewDevelopment

func NewDevelopment() (log.Logger, error)

NewDevelopment returns a logger at debug level and log into STDERR

func NewLogger

func NewLogger(zapLogger *zap.Logger, opts ...Option) log.Logger

NewLogger returns a new logger

func NewNopLogger

func NewNopLogger() log.Logger

NewNopLogger returns a no-op logger

func NewReplayLogger

func NewReplayLogger(logger log.Logger, ctx workflow.Context, enableLogInReplay bool) log.Logger

NewReplayLogger creates a logger which is aware of cadence's replay mode

func NewThrottledLogger

func NewThrottledLogger(logger log.Logger, rps dynamicconfig.IntPropertyFn) log.Logger

NewThrottledLogger returns an implementation of logger that throttles the log messages being emitted. The underlying implementation uses a token bucket ratelimiter and stops emitting logs once the bucket runs out of tokens

Fatal/Panic logs are always emitted without any throttling

Types

type Option

type Option func(impl *loggerImpl)

Option is used to set options for the logger.

func WithSampleFunc

func WithSampleFunc(fn func(int) bool) Option

WithSampleFunc sets the sampling function for the logger.