Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CustomRuleHandler ¶
type CustomRuleHandler struct {
// contains filtered or unexported fields
}
func NewRuleHandler ¶
func NewRuleHandler(reqClient api.RequestClient, confManager config.ConfManager, pubSub *gochannel.GoChannel, errChan chan error) *CustomRuleHandler
func (*CustomRuleHandler) Run ¶
func (c *CustomRuleHandler) Run(ctx context.Context)
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
Engine represents the rule engine that processes messages against rules.
func (*Engine) ActiveTopics ¶
ActiveTopics returns all the active topics in the rule engine.
func (*Engine) ConsumeNext ¶
func (e *Engine) ConsumeNext(item rule_engine.RuleItem)
ConsumeNext shows how to process a message through the rule engine.
func (*Engine) UpdateRules ¶
func (e *Engine) UpdateRules(apiRules []*resources.DiagnosisRule, configTopics []string)
UpdateRules updates the rules in the rule engine.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.