fluent

Documentation

Index

• type Logger
  • func NewLogger(addr string, opts ...Option) (*Logger, error)
  • func (l *Logger) Close() error
  • func (l *Logger) Log(level log.Level, keyvals ...interface{}) error
• type Option
  • func WithAsync(async bool) Option
  • func WithBufferLimit(bufferLimit int) Option
  • func WithForceStopAsyncSend(forceStopAsyncSend bool) Option
  • func WithMaxRetry(maxRetry int) Option
  • func WithMaxRetryWait(maxRetryWait int) Option
  • func WithRetryWait(retryWait int) Option
  • func WithTagPrefix(tagPrefix string) Option
  • func WithTimeout(timeout time.Duration) Option
  • func WithWriteTimeout(writeTimeout time.Duration) Option

Types

type Logger

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

Logger is fluent logger sdk.

func NewLogger

func NewLogger(addr string, opts ...Option) (*Logger, error)

NewLogger new a std logger with options. target:

tcp://127.0.0.1:24224
unix://var/run/fluent/fluent.sock

func (*Logger) Close

func (l *Logger) Close() error

Close close the logger.

func (*Logger) Log

func (l *Logger) Log(level log.Level, keyvals ...interface{}) error

Log print the kv pairs log.

type Option

type Option func(*options)

Option is fluentd logger option.

func WithAsync

func WithAsync(async bool) Option

WithAsync with config Async.

func WithBufferLimit

func WithBufferLimit(bufferLimit int) Option

WithBufferLimit with config BufferLimit.

func WithForceStopAsyncSend

func WithForceStopAsyncSend(forceStopAsyncSend bool) Option

WithForceStopAsyncSend with config ForceStopAsyncSend.

func WithMaxRetry

func WithMaxRetry(maxRetry int) Option

WithMaxRetry with config MaxRetry.

func WithMaxRetryWait

func WithMaxRetryWait(maxRetryWait int) Option

WithMaxRetryWait with config MaxRetryWait.

func WithRetryWait

func WithRetryWait(retryWait int) Option

WithRetryWait with config RetryWait.

func WithTagPrefix

func WithTagPrefix(tagPrefix string) Option

WithTagPrefix with config TagPrefix.

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout with config Timeout.

func WithWriteTimeout

func WithWriteTimeout(writeTimeout time.Duration) Option

WithWriteTimeout with config WriteTimeout.