filter

Documentation

Index

• Variables
• type DropFields
  • func NewDropFields(fields []string) *DropFields
  • func (f *DropFields) Filter(event common.MapStr) (common.MapStr, error)
  • func (f *DropFields) String() string
• type DropFieldsConfig
• type FilterCondition
• type FilterConfig
• type FilterList
  • func New(config []FilterConfig) (*FilterList, error)
  • func (filters *FilterList) Filter(event common.MapStr) common.MapStr
  • func (filters *FilterList) Get(index int) FilterRule
  • func (filters *FilterList) Register(filter FilterRule)
  • func (filters *FilterList) String() string
• type FilterRule
• type IncludeFields
  • func NewIncludeFields(fields []string) *IncludeFields
  • func (f *IncludeFields) Filter(event common.MapStr) (common.MapStr, error)
  • func (f *IncludeFields) String() string
• type IncludeFieldsConfig

Variables

var MandatoryExportedFields = []string{"@timestamp", "type"}

fields that should be always exported

Types

type DropFields

type DropFields struct {
	Fields []string
}

extend FilterRule

func NewDropFields

func NewDropFields(fields []string) *DropFields

DropFields methods

func (*DropFields) Filter

func (f *DropFields) Filter(event common.MapStr) (common.MapStr, error)

func (*DropFields) String

func (f *DropFields) String() string

type DropFieldsConfig

type DropFieldsConfig struct {
	Fields []string `config:"fields"`
}

type FilterCondition

type FilterCondition struct {
}

type FilterConfig

type FilterConfig struct {
	DropFields    *DropFieldsConfig    `config:"drop_fields"`
	IncludeFields *IncludeFieldsConfig `config:"include_fields"`
}

type FilterList

type FilterList struct {
	// contains filtered or unexported fields
}

func New

func New(config []FilterConfig) (*FilterList, error)

FilterList methods

func (*FilterList) Filter

func (filters *FilterList) Filter(event common.MapStr) common.MapStr

Applies a sequence of filtering rules and returns the filtered event

func (*FilterList) Get

func (filters *FilterList) Get(index int) FilterRule

func (*FilterList) Register

func (filters *FilterList) Register(filter FilterRule)

func (*FilterList) String

func (filters *FilterList) String() string

type FilterRule

type FilterRule interface {
	Filter(event common.MapStr) (common.MapStr, error)
	String() string
}

type IncludeFields

type IncludeFields struct {
	Fields []string
}

extends FilterRule

func NewIncludeFields

func NewIncludeFields(fields []string) *IncludeFields

IncludeFields methods

func (*IncludeFields) Filter

func (f *IncludeFields) Filter(event common.MapStr) (common.MapStr, error)

func (*IncludeFields) String

func (f *IncludeFields) String() string

type IncludeFieldsConfig

type IncludeFieldsConfig struct {
	Fields []string `config:"fields"`
}