rules

type ActionFunc ¶

type ActionFunc func(ctx context.Context) (context.Context, error)

ActionFunc defines a function type for actions with support for dependencies and context

type Option ¶

type Option func(*execOptions)

Option defines a functional option for configuring rule execution

func WithAtomic(atomic bool) Option

func WithReturnErrors(returnErrors bool) Option

type Rule ¶

type Rule struct {
	ID        uuid.UUID
	Name      string
	Condition string
	Action    ActionFunc
	Next      *Rule
}

Rule defines the structure for a rule with a condition, action, and an optional next rule

type RuleEngine ¶

type RuleEngine struct {
	// contains filtered or unexported fields
}

RuleEngine manages the execution of rules

func NewRuleEngine(storage Storage, decl ...*exprpb.Decl) (*RuleEngine, error)

func (re *RuleEngine) ExecuteRules(ctx context.Context, inputData map[string]interface{}, opts ...Option) <-chan error

type Storage ¶

type Storage interface {
	LoadRules() ([]Rule, error)
}