filters

Documentation

Index

• Variables
• type Filter
  • func FilterFromName(name string) (Filter, error)
  • func (filter Filter) String() string
• type FilterPlugin
• type FiltersList
  • func (filters FiltersList) Get(filter Filter) FilterPlugin
  • func (filters FiltersList) Register(filter Filter, plugin FilterPlugin)

Variables

var FilterPluginNames = []string{
	"nop",
	"sample",
}

Types

type Filter

type Filter int

const (
	NopFilter Filter = iota
	SampleFilter
)

func FilterFromName

func FilterFromName(name string) (Filter, error)

func (Filter) String

func (filter Filter) String() string

type FilterPlugin

type FilterPlugin interface {

	// New creates a new FilterPlugin instance with the
	// given name and configuration.
	New(name string, config map[string]interface{}) (FilterPlugin, error)

	// Filter executes the filter.
	Filter(event common.MapStr) (common.MapStr, error)

	// String returns the name of the filter.
	String() string

	// Type returns the type of the filter.
	Type() Filter
}

The FilterPlugin interface needs to be implemented by all the filtering plugins.

type FiltersList

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

Contains a list of the available filter plugins.

var Filters FiltersList

func (FiltersList) Get

func (filters FiltersList) Get(filter Filter) FilterPlugin

func (FiltersList) Register

func (filters FiltersList) Register(filter Filter, plugin FilterPlugin)