recombine

Documentation

Index

• Constants
• type Config
  • func NewConfig(operatorID string) *Config
  • func (c *Config) Build(logger *zap.SugaredLogger) (operator.Operator, error)
• type Transformer
  • func (r *Transformer) Process(ctx context.Context, e *entry.Entry) error
  • func (r *Transformer) Start(_ operator.Persister) error
  • func (r *Transformer) Stop() error

Constants

const DefaultSourceIdentifier = "DefaultSourceIdentifier"

Types

type Config

type Config struct {
	helper.TransformerConfig `yaml:",inline"`
	IsFirstEntry             string        `json:"is_first_entry"     yaml:"is_first_entry"`
	IsLastEntry              string        `json:"is_last_entry"      yaml:"is_last_entry"`
	MaxBatchSize             int           `json:"max_batch_size"     yaml:"max_batch_size"`
	CombineField             entry.Field   `json:"combine_field"      yaml:"combine_field"`
	CombineWith              string        `json:"combine_with"       yaml:"combine_with"`
	SourceIdentifier         entry.Field   `json:"source_identifier"  yaml:"source_identifier"`
	OverwriteWith            string        `json:"overwrite_with"     yaml:"overwrite_with"`
	ForceFlushTimeout        time.Duration `json:"force_flush_period" yaml:"force_flush_period"`
	MaxSources               int           `json:"max_sources"        yaml:"max_sources"`
}

Config is the configuration of a recombine operator

func NewConfig

func NewConfig(operatorID string) *Config

NewConfig creates a new recombine config with default values

func (*Config) Build

func (c *Config) Build(logger *zap.SugaredLogger) (operator.Operator, error)

Build creates a new Transformer from a config

type Transformer

type Transformer struct {
	helper.TransformerOperator

	sync.Mutex
	// contains filtered or unexported fields
}

Transformer is an operator that combines a field from consecutive log entries into a single

func (*Transformer) Process

func (r *Transformer) Process(ctx context.Context, e *entry.Entry) error

func (*Transformer) Start

func (r *Transformer) Start(_ operator.Persister) error

func (*Transformer) Stop

func (r *Transformer) Stop() error