fluentd

Documentation

Overview

Package fluentd provides functionalities for integrating the fluentd logging driver with shim-loggers-for-containerd.

Index

• Constants
• type Args
• type LoggerArgs
  • func InitLogger(globalArgs *logger.GlobalArgs, fluentdArgs *Args) *LoggerArgs
  • func (la *LoggerArgs) RunLogDriver(ctx context.Context, config *logging.Config, ready func() error) error

Constants

const (
	// AddressKey specifies the address configuration for fluentd.
	AddressKey = "fluentd-address"
	// AsyncConnectKey specifies the async connect configuration key for fluentd.
	AsyncConnectKey = "fluentd-async-connect"
	// FluentdTagKey specifies the tag configuration key for fluentd.
	FluentdTagKey = "fluentd-tag"
	// SubsecondPrecisionKey specifies the sub-second precision configuration key for fluentd.
	SubsecondPrecisionKey = "fluentd-sub-second-precision"
	// BufferLimitKey specifies the buffer limit configuration key for fluentd.
	BufferLimitKey = "fluentd-buffer-limit"
)

Types

type Args

type Args struct {
	// Optional arguments
	Address            string
	AsyncConnect       string
	Tag                string
	SubsecondPrecision string
	BufferLimit        string
}

Args represents fluentd log driver arguments.

type LoggerArgs

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

LoggerArgs stores global logger args and fluentd specific args.

func InitLogger

func InitLogger(globalArgs *logger.GlobalArgs, fluentdArgs *Args) *LoggerArgs

InitLogger initialize the input arguments.

func (*LoggerArgs) RunLogDriver

func (la *LoggerArgs) RunLogDriver(ctx context.Context, config *logging.Config, ready func() error) error

RunLogDriver initializes and starts the fluentd logger. Errors with the log driver are logged but not returned to prevent container termination.