engine

package

Go to main page

Versions in this module

v0

v0.10.2

Sep 10, 2026

v0.10.1

Sep 10, 2026

v0.10.0

Sep 10, 2026

v0.9.0

Sep 9, 2026

Changes in this version

type MangleRuntime

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

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