Documentation ¶
Index ¶
Constants ¶
View Source
const DefaultSourceIdentifier = "DefaultSourceIdentifier"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶ added in v0.53.0
type Config struct { helper.TransformerConfig `mapstructure:",squash"` IsFirstEntry string `mapstructure:"is_first_entry"` IsLastEntry string `mapstructure:"is_last_entry"` MaxBatchSize int `mapstructure:"max_batch_size"` CombineField entry.Field `mapstructure:"combine_field"` CombineWith string `mapstructure:"combine_with"` SourceIdentifier entry.Field `mapstructure:"source_identifier"` OverwriteWith string `mapstructure:"overwrite_with"` ForceFlushTimeout time.Duration `mapstructure:"force_flush_period"` MaxSources int `mapstructure:"max_sources"` MaxLogSize helper.ByteSize `mapstructure:"max_log_size,omitempty"` }
Config is the configuration of a recombine operator
func NewConfig ¶ added in v0.53.0
func NewConfig() *Config
NewConfig creates a new recombine config with default values
func NewConfigWithID ¶ added in v0.59.0
NewConfigWithID creates a new recombine config with default values
type Transformer ¶ added in v0.53.0
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) Start ¶ added in v0.53.0
func (r *Transformer) Start(_ operator.Persister) error
func (*Transformer) Stop ¶ added in v0.53.0
func (r *Transformer) Stop() error
Click to show internal directories.
Click to hide internal directories.