Method RunSequence

pkg/filter/filter.go:383–411

(e *event.Event, seqID int, partials map[int][]*event.Event, rawMatch bool)

}

func (f *filter) RunSequence(e *event.Event, seqID int, partials map[int][]*event.Event, rawMatch bool) bool {
	if f.seq == nil {
		return false
	}
	nseqs := len(f.seq.Expressions)
	if seqID > nseqs-1 {
		return false
	}
	valuer := f.mapValuer(e)
	defer valuerPool.Put(valuer)
	expr := f.seq.Expressions[seqID]

	if rawMatch {
		// only check if the condition matches
		// without evaluating joins/bound fields
		return ql.Eval(expr.Expr, valuer, f.hasFunctions)
	}

	var match bool
	if seqID >= 1 && expr.HasBoundFields() {
		// evaluate bound field driven sequences
		match = f.evalBoundSequence(e, seqID, &expr, partials, valuer)
	} else {
		// evaluate constrained/unconstrained sequences
		match = f.evalSequence(e, seqID, &expr, partials, valuer)
	}

	return match
}

func (f *filter) GetStringFields() map[fields.Field][]string { return f.stringFields }
func (f *filter) GetFields() []Field                         { return f.fields }