Function newSequenceState

pkg/rules/sequence.go:126–146

(f filter.Filter, c *config.FilterConfig, psnap ps.Snapshotter)

}

func newSequenceState(f filter.Filter, c *config.FilterConfig, psnap ps.Snapshotter) *sequenceState {
	ss := &sequenceState{
		filter:        f,
		seq:           f.GetSequence(),
		name:          c.Name,
		maxSpan:       f.GetSequence().MaxSpan,
		partials:      make(map[int][]*event.Event),
		states:        make(map[fsm.State]bool),
		matches:       make(map[int]*event.Event),
		exprs:         make(map[int]string),
		spanDeadlines: make(map[fsm.State]*time.Timer),
		initialState:  sequenceInitialState,
		psnap:         psnap,
	}

	ss.initFSM()

	ss.configureFSM()

	return ss
}

func (s *sequenceState) events() []*event.Event {
	s.mmu.RLock()