static

Documentation

Index

• type RulesEngine
  • func NewStaticRulesEngine(ctx context.Context) RulesEngine
  • func (engine *RulesEngine) AnalyzeFromPipeline(in chan models.Event)

Types

type RulesEngine

type RulesEngine struct {
	Out chan models.Event
	// contains filtered or unexported fields
}

RulesEngine stores engine state

func NewStaticRulesEngine

func NewStaticRulesEngine(ctx context.Context) RulesEngine

NewStaticRulesEngine returns engine with configs loaded

func (*RulesEngine) AnalyzeFromPipeline

func (engine *RulesEngine) AnalyzeFromPipeline(in chan models.Event)

AnalyzeFromPipeline initiates the engine on the pipeline