fileconsumer

Documentation

Index

• Variables
• type Config
  • func NewConfig() *Config
  • func (c Config) Build(logger *zap.SugaredLogger, emit emit.Callback) (*Manager, error)
  • func (c Config) BuildWithSplitFunc(logger *zap.SugaredLogger, emit emit.Callback, splitFunc bufio.SplitFunc) (*Manager, error)
• type HeaderConfig
• type Manager
  • func (m *Manager) Start(persister operator.Persister) error
  • func (m *Manager) Stop() error

Variables

var AllowHeaderMetadataParsing = featuregate.GlobalRegistry().MustRegister(
	"filelog.allowHeaderMetadataParsing",
	featuregate.StageBeta,
	featuregate.WithRegisterDescription("When enabled, allows usage of the `header` setting."),
	featuregate.WithRegisterReferenceURL("https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/18198"),
)

Types

type Config

type Config struct {
	matcher.Criteria        `mapstructure:",squash"`
	IncludeFileName         bool                    `mapstructure:"include_file_name,omitempty"`
	IncludeFilePath         bool                    `mapstructure:"include_file_path,omitempty"`
	IncludeFileNameResolved bool                    `mapstructure:"include_file_name_resolved,omitempty"`
	IncludeFilePathResolved bool                    `mapstructure:"include_file_path_resolved,omitempty"`
	PollInterval            time.Duration           `mapstructure:"poll_interval,omitempty"`
	StartAt                 string                  `mapstructure:"start_at,omitempty"`
	FingerprintSize         helper.ByteSize         `mapstructure:"fingerprint_size,omitempty"`
	MaxLogSize              helper.ByteSize         `mapstructure:"max_log_size,omitempty"`
	MaxConcurrentFiles      int                     `mapstructure:"max_concurrent_files,omitempty"`
	MaxBatches              int                     `mapstructure:"max_batches,omitempty"`
	DeleteAfterRead         bool                    `mapstructure:"delete_after_read,omitempty"`
	Splitter                tokenize.SplitterConfig `mapstructure:",squash,omitempty"`
	Header                  *HeaderConfig           `mapstructure:"header,omitempty"`
}

Config is the configuration of a file input operator

func NewConfig

func NewConfig() *Config

NewConfig creates a new input config with default values

func (Config) Build

func (c Config) Build(logger *zap.SugaredLogger, emit emit.Callback) (*Manager, error)

Build will build a file input operator from the supplied configuration

func (Config) BuildWithSplitFunc

func (c Config) BuildWithSplitFunc(logger *zap.SugaredLogger, emit emit.Callback, splitFunc bufio.SplitFunc) (*Manager, error)

BuildWithSplitFunc will build a file input operator with customized splitFunc function

type HeaderConfig

type HeaderConfig struct {
	Pattern           string            `mapstructure:"pattern"`
	MetadataOperators []operator.Config `mapstructure:"metadata_operators"`
}

type Manager

type Manager struct {
	*zap.SugaredLogger
	// contains filtered or unexported fields
}

func (*Manager) Start

func (m *Manager) Start(persister operator.Persister) error

func (*Manager) Stop

func (m *Manager) Stop() error

Stop will stop the file monitoring process