container

package
v0.116.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	helper.ParserConfig `mapstructure:",squash"`

	Format                  string          `mapstructure:"format"`
	AddMetadataFromFilePath bool            `mapstructure:"add_metadata_from_filepath"`
	MaxLogSize              helper.ByteSize `mapstructure:"max_log_size,omitempty"`
}

Config is the configuration of a Container parser operator.

func NewConfig

func NewConfig() *Config

NewConfig creates a new JSON parser config with default values

func NewConfigWithID

func NewConfigWithID(operatorID string) *Config

NewConfigWithID creates a new JSON parser config with default values

func (Config) Build

Build will build a Container parser operator.

type Parser

type Parser struct {
	helper.ParserOperator
	// contains filtered or unexported fields
}

Parser is an operator that parses Container logs.

func (*Parser) Process

func (p *Parser) Process(ctx context.Context, entry *entry.Entry) (err error)

Process will parse an entry of Container logs

func (*Parser) Stop

func (p *Parser) Stop() error

Stop ensures that the internal recombineParser, the internal criLogEmitter and the crioConsumer are stopped in the proper order without being affected by any possible race conditions

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL