engine

Documentation

Index

• Constants
• type Engine
  • func NewRuleEngine(repo repo.RuleRepo, funcs rules.FuncMap, evaluator rules.Evaluator) *Engine
  • func (e *Engine) ExecRule(rule *rules.Rule, event *rules.Event) *rules.EvalResult
  • func (e *Engine) FindRules(topic string) []*rules.Rule
  • func (e *Engine) OnStats(interval time.Duration, fn func(stats *EngineStats))
  • func (e *Engine) ProcessEvents(schedulerPoolURL string) chan *rules.EvalResult
  • func (e *Engine) SetFuncs(funcs rules.FuncMap)
• type EngineStats

Constants

const (
	RULES_EXEC_ERROR = "RULES_EXEC_ERROR"
)

Types

type Engine

type Engine struct {
	sync.Mutex

	Repo     repo.RuleRepo
	Commands chan *rules.Event
	Events   chan *rules.Event
	// contains filtered or unexported fields
}

func NewRuleEngine

func NewRuleEngine(repo repo.RuleRepo, funcs rules.FuncMap, evaluator rules.Evaluator) *Engine

func (*Engine) ExecRule

func (e *Engine) ExecRule(rule *rules.Rule, event *rules.Event) *rules.EvalResult

func (*Engine) FindRules

func (e *Engine) FindRules(topic string) []*rules.Rule

func (*Engine) OnStats

func (e *Engine) OnStats(interval time.Duration, fn func(stats *EngineStats))

func (*Engine) ProcessEvents

func (e *Engine) ProcessEvents(schedulerPoolURL string) chan *rules.EvalResult

func (*Engine) SetFuncs

func (e *Engine) SetFuncs(funcs rules.FuncMap)

type EngineStats

type EngineStats struct {
	EngineEnabled     bool   `json:"engineEnabled"`
	RulesRepo         string `json:"rulesRepo"`
	ActiveRulesLoaded int    `json:"activeRulesLoaded"`
}