recombine

Documentation

Index

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

Constants

const DefaultSourceIdentifier = "DefaultSourceIdentifier"

Types

type RecombineOperator

type RecombineOperator struct {
	helper.TransformerOperator

	sync.Mutex
	// contains filtered or unexported fields
}

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

func (*RecombineOperator) Process

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

func (*RecombineOperator) Start

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

func (*RecombineOperator) Stop

func (r *RecombineOperator) Stop() error

type RecombineOperatorConfig

type RecombineOperatorConfig 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"`
}

RecombineOperatorConfig is the configuration of a recombine operator

func NewRecombineOperatorConfig

func NewRecombineOperatorConfig(operatorID string) *RecombineOperatorConfig

NewRecombineOperatorConfig creates a new recombine config with default values

func (*RecombineOperatorConfig) Build

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

Build creates a new RecombineOperator from a config