processors

package
v6.2.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MandatoryExportedFields = []string{"type"}

fields that should be always exported

Functions

func Plugin

func Plugin(name string, c Constructor) map[string][]interface{}

func RegisterPlugin

func RegisterPlugin(name string, constructor Constructor)

Types

type Condition

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

func NewCondition

func NewCondition(config *ConditionConfig) (*Condition, error)

func NewConditionList

func NewConditionList(config []ConditionConfig) ([]Condition, error)

func (*Condition) Check

func (c *Condition) Check(event ValuesMap) bool

func (Condition) String

func (c Condition) String() string

type ConditionConfig

type ConditionConfig struct {
	Equals   *ConditionFields  `config:"equals"`
	Contains *ConditionFields  `config:"contains"`
	Regexp   *ConditionFields  `config:"regexp"`
	Range    *ConditionFields  `config:"range"`
	OR       []ConditionConfig `config:"or"`
	AND      []ConditionConfig `config:"and"`
	NOT      *ConditionConfig  `config:"not"`
}

type ConditionFields

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

func (*ConditionFields) Unpack

func (f *ConditionFields) Unpack(to interface{}) error

type Constructor

type Constructor func(config *common.Config) (Processor, error)

func NewConditional

func NewConditional(
	ruleFactory Constructor,
) Constructor

type EqualsValue

type EqualsValue struct {
	Int uint64
	Str string
}

func (EqualsValue) String

func (e EqualsValue) String() string

type Namespace

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

func NewNamespace

func NewNamespace() *Namespace

func (*Namespace) Plugin

func (ns *Namespace) Plugin() Constructor

func (*Namespace) Register

func (ns *Namespace) Register(name string, factory Constructor) error