executor

Documentation

Index

• type Executor
  • func (e *Executor) Do(content map[string]interface{}, config *RuleConfig) string
  • func (e *Executor) Fire(req *pb.FireRequest) ([]bool, error)
• type ExprExecutor
  • func (e *ExprExecutor) AddExecutionRecords(r *RecordConfig) error
  • func (e *ExprExecutor) BuildRuleEnv(req *rulepb.FireRequest) (*RuleEnv, error)
  • func (e *ExprExecutor) Exec(r *RuleConfig, env map[string]interface{}) (bool, error)
• type RecordConfig
• type RuleConfig
• type RuleEnv
• type RuleExecutor

Types

type Executor

type Executor struct {
	RuleExecutor
	API      api.Interface
	Pipeline pipeline.Interface
	DingTalk dingtalkworknotice.Interface
}

func (*Executor) Do

func (e *Executor) Do(content map[string]interface{}, config *RuleConfig) string

func (*Executor) Fire

func (e *Executor) Fire(req *pb.FireRequest) ([]bool, error)

type ExprExecutor

type ExprExecutor struct {
	DB *db.DBClient
}

func (*ExprExecutor) AddExecutionRecords

func (e *ExprExecutor) AddExecutionRecords(r *RecordConfig) error

func (*ExprExecutor) BuildRuleEnv

func (e *ExprExecutor) BuildRuleEnv(req *rulepb.FireRequest) (*RuleEnv, error)

func (*ExprExecutor) Exec

func (e *ExprExecutor) Exec(r *RuleConfig, env map[string]interface{}) (bool, error)

type RecordConfig

type RecordConfig struct {
	Scope         string
	ScopeID       string
	Env           map[string]interface{}
	Results       []bool
	RuleConfigs   []*RuleConfig
	ActionOutputs []string
	Actors        []string
}

type RuleConfig

type RuleConfig struct {
	RuleID string
	Code   string
	Action db.ActionParams
	Actor  string
}

type RuleEnv

type RuleEnv struct {
	Configs []*RuleConfig
	Env     map[string]interface{}
}

type RuleExecutor

type RuleExecutor interface {
	Exec(r *RuleConfig, env map[string]interface{}) (bool, error)
	BuildRuleEnv(req *rulepb.FireRequest) (*RuleEnv, error)
	AddExecutionRecords(c *RecordConfig) error
}