filter

Documentation

Index

• Variables
• func AllFluentConfig(tag string, filters map[string]*Filter) ([]fluentbit.Component, string)
• func FluentBitSpecialFields() map[string]string
• type Filter
  • func MatchesAny(filters []*Filter) *Filter
  • func NewFilter(f string) (*Filter, error)
  • func (f Filter) OTTLExpression() (ottl.Value, error)
  • func (f Filter) String() string
• type Member
  • func NewMember(m string) (*Member, error)
  • func NewMemberLegacy(m string) (*Member, error)
  • func (m Member) Equals(m2 Member) bool

Variables

var LuaQuote = ast.LuaQuote

Functions

func AllFluentConfig

func AllFluentConfig(tag string, filters map[string]*Filter) ([]fluentbit.Component, string)

AllFluentConfig returns components (if any) and Lua code that sets a Boolean local variable for each filter to indicate if that filter matched.

func FluentBitSpecialFields

func FluentBitSpecialFields() map[string]string

Types

type Filter

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

func MatchesAny

func MatchesAny(filters []*Filter) *Filter

MatchesAny returns a single Filter that matches if any of the child filters match.

func NewFilter

func NewFilter(f string) (*Filter, error)

func (Filter) OTTLExpression

func (f Filter) OTTLExpression() (ottl.Value, error)

func (Filter) String

func (f Filter) String() string

type Member

type Member struct {
	ast.Target
}

func NewMember

func NewMember(m string) (*Member, error)

func NewMemberLegacy

func NewMemberLegacy(m string) (*Member, error)

NewMemberLegacy attempts to parse m as a filter member. If it fails, it prepends `jsonPayload.` and tries again. This is used by legacy config options that allowed bare body field names.

func (Member) Equals

func (m Member) Equals(m2 Member) bool

Equals checks if two valid members are equal. Invalid members are never equal.