engine

package

Go to main page

Versions in this module

v0

v0.8.0

Aug 17, 2026

Changes in this version

type PolicyEngine

+ func (e *PolicyEngine) AddEternalFact(factString string) error

+ func (e *PolicyEngine) AddTemporalFact(factString string, start, end time.Time) error

+ func (e *PolicyEngine) AddTemporalFactAt(factString string, at time.Time) error

+ func (e *PolicyEngine) AddTemporalFactInFuture(factString string, duration time.Duration) error

+ func (e *PolicyEngine) AddTemporalFactInPast(factString string, duration time.Duration) error

+ func (e *PolicyEngine) ContainsTemporalFact(factString string) (bool, error)

+ func (e *PolicyEngine) EnableTemporal()

+ func (e *PolicyEngine) GetEvaluationTime() time.Time

+ func (e *PolicyEngine) IsTemporalEnabled() bool

+ func (e *PolicyEngine) QueryTemporalFactsAt(factPattern string, at time.Time) ([]string, error)

+ func (e *PolicyEngine) QueryTemporalFactsDuring(factPattern string, start, end time.Time) ([]string, error)

+ func (e *PolicyEngine) SetEvaluationTime(t time.Time)

v0.7.0

Aug 17, 2026

Changes in this version

type MangleRuntime

+ func (r *MangleRuntime) Explain(ctx context.Context, facts []ast.Atom, queryStr string) (*core.Explanation, error)

+ func (r *MangleRuntime) IsReady() bool

+ func (r *MangleRuntime) ReloadFromSource(ctx context.Context, source string) error

type PolicyEngine

+ func (e *PolicyEngine) Explain(ctx context.Context, facts []string, queryStr string) (*core.Explanation, error)

+ func (e *PolicyEngine) RegisterActions(metas []core.ActionMetadata) error

+ func (e *PolicyEngine) ReloadPolicySource(ctx context.Context, source string) error

v0.6.0

Aug 4, 2026

v0.5.0

Jul 28, 2026

v0.4.0

Jul 16, 2026

Changes in this version

+ func EscapeString(s string) string

type MangleRuntime

+ func (r *MangleRuntime) WithEvalTimeout(d time.Duration) *MangleRuntime

+ func (r *MangleRuntime) WithMaxCreatedFacts(n int) *MangleRuntime

v0.3.0

Jun 11, 2026

Changes in this version

+ var ErrSolutionFound = errors.New("solution found")

+ var TierMapping = map[string]core.Tier

+ var TierSourceFiles = map[core.Tier]string

+ func Flatten(rootID string, input any) ([]string, error)

+ func FromFacts[T any](rootID string, facts []string) (*T, error)

+ func LabelsToFacts(entityID string, labels []string) ([]string, error)

+ func ToFacts(id string, input any) ([]string, error)

+ type EvaluateResult struct

+ EntityID string

+ Matched bool

+ RuleHead string

+ type Evaluator struct

+ func NewEvaluator(rule string) (*Evaluator, error)

+ func (e *Evaluator) Evaluate(entityID string, entity any) (EvaluateResult, error)

+ type ExternalPredicate func(ctx context.Context, inputs []any) ([][]any, error)

+ type ExternalPredicateRegistry struct

+ func NewExternalPredicateRegistry() *ExternalPredicateRegistry

+ func (r *ExternalPredicateRegistry) Count() int

+ func (r *ExternalPredicateRegistry) Get(name string) (ExternalPredicate, bool)

+ func (r *ExternalPredicateRegistry) List() map[string]ExternalPredicate

+ func (r *ExternalPredicateRegistry) Register(name string, fn ExternalPredicate) error

+ type FactIndex map[string]map[string][]string

+ type GherkinCompiler struct

+ func NewGherkinCompiler() *GherkinCompiler

+ func NewGherkinCompilerWithRegistry(registry *StepRegistry) *GherkinCompiler

+ func (c *GherkinCompiler) Compile(feature *parse.Feature) (string, error)

+ func (c *GherkinCompiler) CompileFromString(content string) (string, error)

+ type MangleRuntime struct

+ func NewMangleRuntime() *MangleRuntime

+ func (r *MangleRuntime) AddEternalFact(factString string) error

+ func (r *MangleRuntime) AddPolicy(source string) error

+ func (r *MangleRuntime) AddTemporalFact(factString string, start, end time.Time) error

+ func (r *MangleRuntime) AddTemporalFactAt(factString string, at time.Time) error

+ func (r *MangleRuntime) AddTemporalFactInFuture(factString string, duration time.Duration) error

+ func (r *MangleRuntime) AddTemporalFactInPast(factString string, duration time.Duration) error

+ func (r *MangleRuntime) ContainsTemporalFact(factString string) (bool, error)

+ func (r *MangleRuntime) EnableTemporal()

+ func (r *MangleRuntime) ExecuteQuery(ctx context.Context, facts []ast.Atom, queryStr string) (bool, error)

+ func (r *MangleRuntime) ExternalPredicates() *ExternalPredicateRegistry

+ func (r *MangleRuntime) GetEvaluationTime() time.Time

+ func (r *MangleRuntime) GetTemporalStore() *factstore.TemporalStore

+ func (r *MangleRuntime) IsTemporalEnabled() bool

+ func (r *MangleRuntime) Load(path string) error

+ func (r *MangleRuntime) LoadFacts(facts []string) error

+ func (r *MangleRuntime) LoadFromSource(source string) error

+ func (r *MangleRuntime) LoadFromString(rule string) error

+ func (r *MangleRuntime) QueryTemporalFactsAt(factPattern string, at time.Time) ([]string, error)

+ func (r *MangleRuntime) QueryTemporalFactsDuring(factPattern string, start, end time.Time) ([]string, error)

+ func (r *MangleRuntime) QueryWithSolutions(ctx context.Context, facts []ast.Atom, queryStr string, ...) error

+ func (r *MangleRuntime) RegisterExternalPredicate(name string, fn ExternalPredicate) error

+ func (r *MangleRuntime) SetEvaluationTime(t time.Time)

+ type PolicyEngine struct

+ func New() (*PolicyEngine, error)

+ func NewWithObservability(tracer core.Tracer, logger core.Logger) (*PolicyEngine, error)

+ func NewWithTracer(tracer core.Tracer) *PolicyEngine

+ func (e *PolicyEngine) Assess(ctx context.Context, actionMeta core.ActionMetadata, input core.Envelope) error

+ func (e *PolicyEngine) AssessPlan(ctx context.Context, input core.Envelope) (core.Decision, error)

+ func (e *PolicyEngine) CheckRequirement(ctx context.Context, input core.Envelope, reqName string) (bool, error)

+ func (e *PolicyEngine) EvaluateSteering(ctx context.Context, input core.Envelope) (string, map[string]string, error)

+ func (e *PolicyEngine) ExecuteQuery(ctx context.Context, facts []ast.Atom, queryStr string) (bool, error)

+ func (e *PolicyEngine) ExternalPredicateRegistry() *ExternalPredicateRegistry

+ func (e *PolicyEngine) ExtractActionArguments(ctx context.Context, input core.Envelope, actionName string) (map[string]interface{}, error)

+ func (e *PolicyEngine) GetActionConfig(ctx context.Context, input core.Envelope) (map[string]string, error)

+ func (e *PolicyEngine) LoadFacts(facts []string) error

+ func (e *PolicyEngine) LoadFromSource(ctx context.Context, source string) error

+ func (e *PolicyEngine) LoadGherkinPolicy(ctx context.Context, featureContent string) error

+ func (e *PolicyEngine) LoadPolicy(ctx context.Context, policy string) error

+ func (e *PolicyEngine) Logger() core.Logger

+ func (e *PolicyEngine) Query(ctx context.Context, facts []string, queryStr string) ([]map[string]string, error)

+ func (e *PolicyEngine) QueryWithAudit(ctx context.Context, facts []string, queryStr string) (*QueryWithAuditResult, error)

+ func (e *PolicyEngine) RecordLineage(ctx context.Context, childID, parentID string)

+ func (e *PolicyEngine) Reflect(ctx context.Context, actionMeta core.ActionMetadata, output core.Envelope) (core.Envelope, error)

+ func (e *PolicyEngine) RegisterAction(meta core.ActionMetadata) error

+ func (e *PolicyEngine) RegisterExternalPredicate(name string, fn func(ctx context.Context, inputs []any) ([][]any, error)) error

+ func (e *PolicyEngine) Runtime() *MangleRuntime

+ func (e *PolicyEngine) WithQueryTimeout(timeout time.Duration) *PolicyEngine

+ type QueryWithAuditResult struct

+ AuditTrail *core.AuditTrail

+ Results []map[string]string

+ type StepDefinition struct

+ Pattern *regexp.Regexp

+ StepType parse.StepType

+ Template string

+ type StepRegistry struct

+ func NewStepRegistry() *StepRegistry

+ func (r *StepRegistry) GenerateDatalog(step parse.Step, expectedType parse.StepType) (string, error)

+ func (r *StepRegistry) Match(step parse.Step, expectedType parse.StepType) (*StepDefinition, map[string]string, error)

+ func (r *StepRegistry) Register(pattern, template string, stepType parse.StepType) error

+ func (r *StepRegistry) Substitute(template string, params map[string]string) string

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