Versions in this module Expand all Collapse all v1 v1.1.1 Jun 21, 2020 v1.1.0 Dec 27, 2019 Changes in this version + const MessageRootMonitorFinished + const ProductVersion + const RuleKindSeparator + const RuleKindWildcard + var EventTracer = &eventTrace + func SortRuleSlice(a []*Rule) + func UnitTestResetIDs() + type ChildMonitor struct + func (mb ChildMonitor) Activate(e *Event) + func (mb ChildMonitor) Errors() *TaskError + func (mb ChildMonitor) EventPath() []*Event + func (mb ChildMonitor) EventPathString() string + func (mb ChildMonitor) Finish() + func (mb ChildMonitor) ID() uint64 + func (mb ChildMonitor) IsActivated() bool + func (mb ChildMonitor) IsFinished() bool + func (mb ChildMonitor) NewChildMonitor(priority int) Monitor + func (mb ChildMonitor) Priority() int + func (mb ChildMonitor) RootMonitor() *RootMonitor + func (mb ChildMonitor) Scope() *RuleScope + func (mb ChildMonitor) SetErrors(e *TaskError) + func (mb ChildMonitor) Skip(e *Event) + func (mb ChildMonitor) String() string + type Event struct + func NewEvent(name string, kind []string, state map[interface{}]interface{}) *Event + func (e *Event) Kind() []string + func (e *Event) Name() string + func (e *Event) State() map[interface{}]interface{} + func (e *Event) String() string + type Monitor interface + Activate func(e *Event) + Errors func() *TaskError + EventPath func() []*Event + EventPathString func() string + Finish func() + ID func() uint64 + IsActivated func() bool + NewChildMonitor func(priority int) Monitor + Priority func() int + RootMonitor func() *RootMonitor + Scope func() *RuleScope + SetErrors func(e *TaskError) + Skip func(e *Event) + String func() string + type Processor interface + AddEvent func(event *Event, parentMonitor Monitor) (Monitor, error) + AddRule func(rule *Rule) error + Finish func() + ID func() uint64 + IsTriggering func(event *Event) bool + NewRootMonitor func(context map[string]interface{}, scope *RuleScope) *RootMonitor + ProcessEvent func(event *Event, parent Monitor) map[string]error + Reset func() error + Rules func() map[string]*Rule + SetRootMonitorErrorObserver func(func(rm *RootMonitor)) + Start func() + Status func() string + Stopped func() bool + String func() string + Workers func() int + func NewProcessor(workerCount int) Processor + type RootMonitor struct + func (mb RootMonitor) Activate(e *Event) + func (mb RootMonitor) Errors() *TaskError + func (mb RootMonitor) EventPath() []*Event + func (mb RootMonitor) EventPathString() string + func (mb RootMonitor) Finish() + func (mb RootMonitor) ID() uint64 + func (mb RootMonitor) IsActivated() bool + func (mb RootMonitor) IsFinished() bool + func (mb RootMonitor) NewChildMonitor(priority int) Monitor + func (mb RootMonitor) Priority() int + func (mb RootMonitor) RootMonitor() *RootMonitor + func (mb RootMonitor) Scope() *RuleScope + func (mb RootMonitor) SetErrors(e *TaskError) + func (mb RootMonitor) Skip(e *Event) + func (mb RootMonitor) String() string + func (rm *RootMonitor) AllErrors() []*TaskError + func (rm *RootMonitor) HighestPriority() int + func (rm *RootMonitor) SetFinishHandler(fh func(Processor)) + type Rule struct + Action RuleAction + Desc string + KindMatch []string + Name string + Priority int + ScopeMatch []string + StateMatch map[string]interface{} + SuppressionList []string + func (r *Rule) CopyAs(newName string) *Rule + func (r *Rule) String() string + type RuleAction func(p Processor, m Monitor, e *Event) error + type RuleIndex interface + AddRule func(rule *Rule) error + IsTriggering func(event *Event) bool + Match func(event *Event) []*Rule + Rules func() map[string]*Rule + String func() string + func NewRuleIndex() RuleIndex + type RuleIndexAll struct + func (ri *RuleIndexAll) Type() string + type RuleIndexKind struct + func (ri *RuleIndexKind) AddRule(rule *Rule) error + func (ri *RuleIndexKind) IsTriggering(event *Event) bool + func (ri *RuleIndexKind) Match(event *Event) []*Rule + func (ri *RuleIndexKind) String() string + func (ri *RuleIndexKind) Type() string + type RuleIndexState struct + func (ri *RuleIndexState) Type() string + type RuleMatcherKey struct + func (rm *RuleMatcherKey) String() string + type RuleScope struct + func NewRuleScope(allows map[string]bool) *RuleScope + func (rs *RuleScope) Add(scopePath string, allow bool) + func (rs *RuleScope) AddAll(allows map[string]bool) + func (rs *RuleScope) IsAllowed(scopePath string) bool + func (rs *RuleScope) IsAllowedAll(scopePaths []string) bool + type RuleSlice []*Rule + func (s RuleSlice) Len() int + func (s RuleSlice) Less(i, j int) bool + func (s RuleSlice) Swap(i, j int) + type Task struct + func (t *Task) HandleError(e error) + func (t *Task) Run() error + func (t *Task) String() string + type TaskError struct + ErrorMap map[string]error + Event *Event + Monitor Monitor + func (te *TaskError) Error() string + type TaskQueue struct + func NewTaskQueue(ep *flowutil.EventPump) *TaskQueue + func (tq *TaskQueue) Clear() + func (tq *TaskQueue) Pop() pools.Task + func (tq *TaskQueue) Push(t pools.Task) + func (tq *TaskQueue) Size() int