evalengine

package module

Go to main page

Versions in this module

v0

v0.5.0

Mar 23, 2026

Changes in this version

+ func Validate(cfg *EvalConfig, input proto.Message) error

+ func ValidateConfig(cfg *EvalConfig) error

+ type ValidationError struct

+ Errors []string

+ func (e *ValidationError) Error() string

v0.4.0

Mar 19, 2026

Changes in this version

type CELEvaluator

+ func (e *CELEvaluator) Category() string

+ func (e *CELEvaluator) DisplayName() string

+ func (e *CELEvaluator) EvaluatePreconditions(activation map[string]any) []string

+ func (e *CELEvaluator) FailureMode() string

+ func (e *CELEvaluator) HasPreconditions() bool

+ func (e *CELEvaluator) Resolution() string

+ func (e *CELEvaluator) Severity() string

type Engine

+ func (e *Engine) InputFields(name string) []string

type EvalDefinition

+ FailureMode string

+ Preconditions []Precondition

type EvalGraph

+ func (g *EvalGraph) Blocks(name string) []string

type Evaluator

+ Category func() string

+ DisplayName func() string

+ EvaluatePreconditions func(activation map[string]any) []string

+ FailureMode func() string

+ HasPreconditions func() bool

+ Resolution func() string

+ Severity func() string

+ type Precondition struct

+ Description string

+ Expression string

type Result

+ DisplayName string

+ FailureMode string

+ Pending bool

+ PendingPreconditions []string

type Status

+ const StatusPending

v0.3.0

Mar 16, 2026

v0.2.0

Mar 16, 2026

Changes in this version

+ func ToCachedResults(results []Result, evaluatedAt time.Time) map[string]CachedResult

+ type CachedResult struct

+ EvaluatedAt time.Time

+ Fingerprint string

+ Result Result

type Engine

+ func (e *Engine) RunWithCache(input proto.Message, cache map[string]CachedResult, now time.Time) ([]Result, map[string]bool)

+ func (e *Engine) RunWithCacheMap(input proto.Message, cache map[string]CachedResult, now time.Time) (map[string]Result, map[string]bool)

+ func (e *Engine) ToCachedResults(results []Result, input proto.Message, evaluatedAt time.Time) map[string]CachedResult

type EvalDefinition

+ CacheTTLDuration time.Duration

v0.1.0

Mar 16, 2026

Changes in this version

+ func ComputeFingerprint(reads []FieldRef, msg proto.Message) string

+ type CELEvaluator struct

+ func NewCELEvaluator(env *cel.Env, def EvalDefinition) (*CELEvaluator, error)

+ func (e *CELEvaluator) CacheTTL() time.Duration

+ func (e *CELEvaluator) Evaluate(activation map[string]any) Result

+ func (e *CELEvaluator) Name() string

+ func (e *CELEvaluator) Reads() []FieldRef

+ func (e *CELEvaluator) ResolutionWorkflow() string

+ func (e *CELEvaluator) Writes() FieldRef

+ type Engine struct

+ func NewEngine(cfg *EvalConfig, input proto.Message, opts ...cel.EnvOption) (*Engine, error)

+ func NewEngineFromBytes(data []byte, input proto.Message, opts ...cel.EnvOption) (*Engine, error)

+ func NewEngineFromFile(path string, input proto.Message, opts ...cel.EnvOption) (*Engine, error)

+ func (e *Engine) DeriveStatus(results []Result) Status

+ func (e *Engine) Evaluators() []Evaluator

+ func (e *Engine) Graph() *EvalGraph

+ func (e *Engine) Run(input proto.Message) []Result

+ func (e *Engine) RunMap(input proto.Message) map[string]Result

+ type EvalConfig struct

+ Evaluations []EvalDefinition

+ func LoadDefinitions(r io.Reader) (*EvalConfig, error)

+ func LoadDefinitionsFromFile(path string) (*EvalConfig, error)

+ type EvalDefinition struct

+ CacheTTL string

+ Category string

+ Description string

+ Expression string

+ Name string

+ ParsedCacheTTL time.Duration

+ Reads []FieldRef

+ Resolution string

+ ResolutionWorkflow string

+ Severity string

+ Writes FieldRef

+ type EvalGraph struct

+ func BuildGraph(evaluators []Evaluator) (*EvalGraph, error)

+ func (g *EvalGraph) BlockedBy(name string, results map[string]Result) []string

+ func (g *EvalGraph) DependenciesMet(name string, results map[string]Result) bool

+ func (g *EvalGraph) ExecutionOrder() []string

+ func (g *EvalGraph) Issues() []Issue

+ func (g *EvalGraph) MaxDepth() int

+ type Evaluator interface

+ CacheTTL func() time.Duration

+ Evaluate func(activation map[string]any) Result

+ Name func() string

+ Reads func() []FieldRef

+ ResolutionWorkflow func() string

+ Writes func() FieldRef

+ type FieldRef string

+ func (f FieldRef) String() string

+ type Issue struct

+ Message string

+ Severity string

+ Type string

+ type Result struct

+ Category string

+ Error string

+ Name string

+ Passed bool

+ Resolution string

+ ResolutionWorkflow string

+ Severity string

+ type Status int

+ const StatusActionRequired

+ const StatusAllPassed

+ const StatusBlocked

+ const StatusWorkflowActive

+ func DeriveStatus(results []Result, graph *EvalGraph) Status

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL