filter

Documentation

Index

• type FilterOperator
  • func (f *FilterOperator) Process(ctx context.Context, entry *entry.Entry) error
• type FilterOperatorConfig
  • func NewFilterOperatorConfig(operatorID string) *FilterOperatorConfig
  • func (c FilterOperatorConfig) Build(logger *zap.SugaredLogger) (operator.Operator, error)

Types

type FilterOperator

type FilterOperator struct {
	helper.TransformerOperator
	// contains filtered or unexported fields
}

FilterOperator is an operator that filters entries based on matching expressions

func (*FilterOperator) Process

func (f *FilterOperator) Process(ctx context.Context, entry *entry.Entry) error

Process will drop incoming entries that match the filter expression

type FilterOperatorConfig

type FilterOperatorConfig struct {
	helper.TransformerConfig `yaml:",inline"`
	Expression               string  `json:"expr"   yaml:"expr"`
	DropRatio                float64 `json:"drop_ratio"   yaml:"drop_ratio"`
}

FilterOperatorConfig is the configuration of a filter operator

func NewFilterOperatorConfig

func NewFilterOperatorConfig(operatorID string) *FilterOperatorConfig

NewFilterOperatorConfig creates a filter operator config with default values

func (FilterOperatorConfig) Build

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

Build will build a filter operator from the supplied configuration