runtime

package

Go to main page

Versions in this module

v0

v0.4.0

Sep 2, 2026

Changes in this version

type ArtifactResolver

+ ResolveGeneration func(context.Context, ledger.ExecutionArtifact) (*Generation, error)

type ArtifactResolverFunc

+ func (f ArtifactResolverFunc) ResolveGeneration(ctx context.Context, artifact ledger.ExecutionArtifact) (*Generation, error)

type Engine

+ func (engine *Engine) Close() error

+ func (engine *Engine) ConfigureWorkflow(store workflow.OutboxStore, provider fencing.Provider, ...) error

+ func (engine *Engine) DryRun(ctx context.Context, facts map[string]any) ([]PlanEvaluation, error)

+ func (engine *Engine) Generation() *Generation

+ func (engine *Engine) GenerationView() *GenerationView

type Generation

+ func CompileGeneration(ctx context.Context, config GenerationBuildConfig) (*Generation, error)

+ func (generation *Generation) Close() error

+ func (generation *Generation) ExecutorDescriptors() map[string]invocation.Descriptor

+ func (generation *Generation) FunctionIDs() map[string]string

+ type GenerationBuildConfig struct

+ Bundle *bundle.SourceBundle

+ CompileOptions compiler.CompileOptions

+ FunctionIDs map[string]string

+ Production bool

+ Resolvers *invocation.Registry

+ type GenerationView struct

+ Environment ir.Environment

+ GenerationDigest string

+ IRDigest string

+ Plans []PlanView

+ Ruleset string

+ SourceDigest string

+ Version string

type ManifestArtifactResolver

+ func (resolver *ManifestArtifactResolver) ResolveGeneration(ctx context.Context, artifact ledger.ExecutionArtifact) (*Generation, error)

+ type PlanEvaluation struct

+ Matched bool

+ Plan PlanView

+ type PlanView struct

+ Dialect effectusv1.SourceDialect

+ ID string

+ Predicate string

+ Priority int32

+ Verbs []string

v0.3.0

Sep 1, 2026

Changes in this version

+ var ErrBlockedDependency = errors.New("execution blocked by missing dependency")

+ var ErrDurableDisposition = errors.New("durable execution disposition failed")

+ var ErrExecutionNotFound = errors.New("engine execution not found")

+ var ErrGRPCInvalidInput = errors.New("invalid gRPC execution input")

+ var ErrGRPCResourceExhausted = errors.New("gRPC execution resource exhausted")

+ var ErrGRPCUnauthorized = errors.New("gRPC authentication failed")

+ var ErrGRPCUnavailable = errors.New("gRPC execution unavailable")

+ var ErrGenerationMismatch = errors.New("engine generation mismatch")

+ var ErrIdentityConflict = errors.New("engine admission identity conflict")

+ var ErrInvalidExecuteRequest = errors.New("invalid engine execute request")

+ var ErrRulesetActive = errors.New("ruleset is active")

+ var ErrUnsupportedDeploymentStrategy = errors.New("unsupported deployment strategy")

+ func RegisterEngineExecutionServiceWithOptions(registrar grpc.ServiceRegistrar, engine *Engine, ...) error

+ type ActivationStore interface

+ DeployRuleset func(context.Context, string, string, string, *DeploymentConfig) error

+ GetActiveVersion func(context.Context, string, string) (*RulesetVersion, error)

+ GetDeploymentStatus func(context.Context, string, string) (*DeploymentStatus, error)

+ RollbackDeployment func(context.Context, string, string, string) error

+ SetActiveVersion func(context.Context, string, string, string) error

+ type Admission struct

+ AdmissionID string

+ ExecutionID string

+ ExpectedGenerationDigest string

+ Facts map[string]any

+ MergePolicy string

+ Ruleset string

+ TenantNamespace string

+ Version string

+ type ArtifactResolver interface

+ ResolveArtifact func(context.Context, ledger.ExecutionArtifact, *ir.Checked) (*compiler.CompiledUnit, error)

+ type ArtifactResolverFunc func(context.Context, ledger.ExecutionArtifact, *ir.Checked) (*compiler.CompiledUnit, error)

+ func (function ArtifactResolverFunc) ResolveArtifact(ctx context.Context, artifact ledger.ExecutionArtifact, checked *ir.Checked) (*compiler.CompiledUnit, error)

+ type AuditEntry struct

+ Action string

+ Details map[string]interface{}

+ DurationMs int

+ Environment string

+ ErrorMsg string

+ ID string

+ IPAddress string

+ RequestID string

+ Resource string

+ ResourceID *uuid.UUID

+ Result string

+ SessionID string

+ Timestamp time.Time

+ TraceID string

+ UserAgent string

+ UserEmail string

+ UserID string

+ Version string

+ type AuditFilters struct

+ Actions []string

+ EndTime time.Time

+ Limit int

+ Offset int

+ Resources []string

+ Result string

+ StartTime time.Time

+ UserIDs []string

+ type AuditStore interface

+ GetAuditLog func(context.Context, *AuditFilters) ([]*AuditEntry, error)

+ RecordActivity func(context.Context, *AuditEntry) error

+ type BearerTokenAuthenticator struct

+ func NewBearerTokenAuthenticator(token string) (*BearerTokenAuthenticator, error)

+ func NewBearerTokenAuthenticatorSet(tokens []string) (*BearerTokenAuthenticator, error)

+ func (authenticator *BearerTokenAuthenticator) Authenticate(ctx context.Context, _ string) (context.Context, error)

+ type CanaryConfig struct

+ Duration time.Duration

+ ErrorThreshold float64

+ MetricsQueries []string

+ SuccessThreshold float64

+ TrafficPercent int

+ type CompileOptions struct

+ DiscardInitialData bool

+ type CompiledEffect struct

+ Args map[string]any

+ VerbName string

+ type CompiledPredicate struct

+ Operator string

+ Path string

+ Value any

+ type CompiledRule struct

+ Description string

+ Effects []CompiledEffect

+ Name string

+ Predicates []CompiledPredicate

+ Priority int

+ Type RuleType

+ type CompiledRuleset struct

+ Capabilities []string

+ Dependencies []string

+ Description string

+ EffectSchemas map[string]*Schema

+ FactSchema *Schema

+ Metadata map[string]string

+ Name string

+ Rules []CompiledRule

+ Verbs map[string]*compiler.CompiledVerbSpec

+ Version string

+ type Deployment struct

+ CanaryConfig *CanaryConfig

+ Config *DeploymentConfig

+ DeployedAt time.Time

+ DeployedBy string

+ Environment string

+ HealthCheck *HealthCheckResult

+ RollbackInfo *RollbackInfo

+ Status DeploymentStatus

+ Version string

+ type DeploymentConfig struct

+ Approvers []string

+ Environments []string

+ HealthCheckURL string

+ MaxRollbackDays int

+ Metadata map[string]string

+ RequiredTests []string

+ RollbackOnError bool

+ Strategy string

+ type DeploymentStatus string

+ const DeploymentStatusActive

+ const DeploymentStatusCanary

+ const DeploymentStatusDeploying

+ const DeploymentStatusFailed

+ const DeploymentStatusInactive

+ const DeploymentStatusPending

+ const DeploymentStatusRollingBack

+ type Engine struct

+ func NewEngine(runtime *ExecutionRuntime) (*Engine, error)

+ func (engine *Engine) ActiveGeneration() *ExecutionGeneration

+ func (engine *Engine) ActiveGenerationDigest() string

+ func (engine *Engine) ConfigureLedger(durableLedger ledger.ExecutionLedger, resolver ArtifactResolver) error

+ func (engine *Engine) Execute(ctx context.Context, request ExecuteRequest) (result ExecuteResult, resultErr error)

+ func (engine *Engine) SetObserver(observer Observer)

+ type EngineExecutionService struct

+ Engine *Engine

+ func (service *EngineExecutionService) ExecuteRuleset(ctx context.Context, request *effectusv1.ExecutionRequest) (*effectusv1.ExecutionResponse, error)

+ type EngineExecutionServiceOptions struct

+ RulesetName string

+ Version string

+ type ExecuteRequest struct

+ Admission *Admission

+ RecoveryLease *schema.ExecutionLease

+ ResumeExecutionID string

+ WaitMode WaitMode

+ type ExecuteResult struct

+ Completed bool

+ DurablyAccepted bool

+ ExecutionID string

+ GenerationDigest string

+ State string

+ type ExecutionGeneration struct

+ GenerationDigest string

+ IRDigest string

+ PublishedAt time.Time

+ type ExecutionRuntime struct

+ func NewExecutionRuntime() *ExecutionRuntime

+ func (er *ExecutionRuntime) ActiveGeneration() *ExecutionGeneration

+ func (er *ExecutionRuntime) Close() error

+ func (er *ExecutionRuntime) CompileAndValidate(ctx context.Context) error

+ func (er *ExecutionRuntime) CompileAndValidateWithOptions(ctx context.Context, options CompileOptions) error

+ func (er *ExecutionRuntime) ConfigureDurableWorkflowExecution(store workflow.OutboxStore, provider fencing.Provider, ...) error

+ func (er *ExecutionRuntime) ConfigureExecutionLedger(durableLedger ledger.ExecutionLedger, resolver ArtifactResolver) error

+ func (er *ExecutionRuntime) ConfigureGenerationMetadata(metadata GenerationMetadata) error

+ func (er *ExecutionRuntime) EnableLegacyExecutionForCompatibility()

+ func (er *ExecutionRuntime) Engine() *Engine

+ func (er *ExecutionRuntime) ExecuteVerb(ctx context.Context, verbName string, args map[string]interface{}) (interface{}, error)

+ func (er *ExecutionRuntime) ExecuteWorkflow(ctx context.Context, facts map[string]interface{}) error

+ func (er *ExecutionRuntime) ExecuteWorkflowWithIdentity(ctx context.Context, namespace, executionID string, ...) error

+ func (er *ExecutionRuntime) GetRuntimeInfo() *RuntimeInfo

+ func (er *ExecutionRuntime) HotReload(ctx context.Context) error

+ func (er *ExecutionRuntime) RegisterExecutorFactory(executorType compiler.ExecutorType, factory ExecutorFactory)

+ func (er *ExecutionRuntime) RegisterExtensionLoader(extensionLoader loader.Loader)

+ type ExecutorDescriptor struct

+ Config map[string]string

+ Reference string

+ ResolverID string

+ Type string

+ type ExecutorFactory interface

+ CreateExecutor func(config compiler.ExecutorConfig) (VerbExecutor, error)

+ type FieldType struct

+ Description string

+ MessageType string

+ Required bool

+ Type string

+ type GRPCAuthenticator interface

+ Authenticate func(context.Context, string) (context.Context, error)

+ type GRPCAuthenticatorFunc func(context.Context, string) (context.Context, error)

+ func (function GRPCAuthenticatorFunc) Authenticate(ctx context.Context, method string) (context.Context, error)

+ type GRPCExecutor struct

+ func (ge *GRPCExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error)

+ type GRPCExecutorFactory struct

+ func (gef *GRPCExecutorFactory) Close() error

+ func (gef *GRPCExecutorFactory) CreateExecutor(config compiler.ExecutorConfig) (VerbExecutor, error)

+ type Generation struct

+ func NewGeneration(config GenerationConfig) (*Generation, error)

+ func (generation *Generation) Checked() *ir.Checked

+ func (generation *Generation) Closed() bool

+ func (generation *Generation) Digest() string

+ func (generation *Generation) Environment() ir.Environment

+ func (generation *Generation) Executor(verb string) (invocation.Executor, bool)

+ func (generation *Generation) Retired() bool

+ func (generation *Generation) Ruleset() string

+ func (generation *Generation) SourceDigest() string

+ func (generation *Generation) Version() string

+ type GenerationConfig struct

+ Checked *ir.Checked

+ Closers []io.Closer

+ Environment ir.Environment

+ ExecutorDescriptors map[string]ExecutorDescriptor

+ Executors map[string]invocation.Executor

+ FunctionIDs map[string]string

+ Production bool

+ Ruleset string

+ SourceDigest string

+ Version string

+ type GenerationHandle struct

+ func (handle *GenerationHandle) Generation() *Generation

+ func (handle *GenerationHandle) Release() error

+ type GenerationManager struct

+ func (manager *GenerationManager) Acquire() (*GenerationHandle, error)

+ func (manager *GenerationManager) ActiveDigest() string

+ func (manager *GenerationManager) Publish(generation *Generation) error

+ type GenerationMetadata struct

+ BundleDigest string

+ Ruleset string

+ Version string

+ type HTTPExecutor struct

+ func (he *HTTPExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error)

+ type HTTPExecutorFactory struct

+ func (hef *HTTPExecutorFactory) CreateExecutor(config compiler.ExecutorConfig) (VerbExecutor, error)

+ type HealthCheckResult struct

+ Details map[string]string

+ Errors []string

+ LastChecked time.Time

+ Status string

+ type InMemoryRuleStorage struct

+ func NewInMemoryRuleStorage() *InMemoryRuleStorage

+ func (m *InMemoryRuleStorage) Cleanup(ctx context.Context, olderThan time.Time) error

+ func (m *InMemoryRuleStorage) DeleteRuleset(ctx context.Context, name, version string) error

+ func (m *InMemoryRuleStorage) DeployRuleset(ctx context.Context, name, version, environment string, ...) error

+ func (m *InMemoryRuleStorage) GetActiveVersion(ctx context.Context, name, environment string) (*RulesetVersion, error)

+ func (m *InMemoryRuleStorage) GetAuditLog(ctx context.Context, filters *AuditFilters) ([]*AuditEntry, error)

+ func (m *InMemoryRuleStorage) GetDeploymentStatus(ctx context.Context, name, environment string) (*DeploymentStatus, error)

+ func (m *InMemoryRuleStorage) GetRuleset(ctx context.Context, name, version string) (*StoredRuleset, error)

+ func (m *InMemoryRuleStorage) GetRulesetVersions(ctx context.Context, name string) ([]*RulesetVersion, error)

+ func (m *InMemoryRuleStorage) HealthCheck(ctx context.Context) error

+ func (m *InMemoryRuleStorage) ListRulesets(ctx context.Context, filters *RulesetFilters) ([]*RulesetMetadata, error)

+ func (m *InMemoryRuleStorage) RecordActivity(ctx context.Context, entry *AuditEntry) error

+ func (m *InMemoryRuleStorage) RollbackDeployment(ctx context.Context, name, environment, targetVersion string) error

+ func (m *InMemoryRuleStorage) SetActiveVersion(ctx context.Context, name, environment, version string) error

+ func (m *InMemoryRuleStorage) StoreRuleset(ctx context.Context, ruleset *StoredRuleset) error

+ type LocalExecutorAdapter struct

+ func (lea *LocalExecutorAdapter) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error)

+ type LocalExecutorFactory struct

+ func (lef *LocalExecutorFactory) CreateExecutor(config compiler.ExecutorConfig) (VerbExecutor, error)

+ type ManifestArtifactResolver struct

+ func NewManifestArtifactResolver() *ManifestArtifactResolver

+ func (*ManifestArtifactResolver) ResolveArtifact(_ context.Context, artifact ledger.ExecutionArtifact, checked *ir.Checked) (*compiler.CompiledUnit, error)

+ type MessageExecutor struct

+ func (me *MessageExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error)

+ type MessageExecutorFactory struct

+ func (mef *MessageExecutorFactory) CreateExecutor(config compiler.ExecutorConfig) (VerbExecutor, error)

+ type MockExecutor struct

+ func (me *MockExecutor) Execute(ctx context.Context, args map[string]interface{}) (interface{}, error)

+ type MockExecutorFactory struct

+ func (mef *MockExecutorFactory) CreateExecutor(config compiler.ExecutorConfig) (VerbExecutor, error)

+ type Observer interface

+ ObserveExecution func(ExecuteResult, error)

+ ObserveRecovery func(RecoveryObservation)

+ type PostgresStorage struct

+ func NewPostgresStorage(config *PostgresStorageConfig) (*PostgresStorage, error)

+ func (p *PostgresStorage) Cleanup(ctx context.Context, olderThan time.Time) error

+ func (p *PostgresStorage) Close()

+ func (p *PostgresStorage) DeleteRuleset(ctx context.Context, name, version string) error

+ func (p *PostgresStorage) DeployRuleset(ctx context.Context, name, version, environment string, ...) error

+ func (p *PostgresStorage) GetActiveVersion(ctx context.Context, name, environment string) (*RulesetVersion, error)

+ func (p *PostgresStorage) GetAuditLog(ctx context.Context, filters *AuditFilters) ([]*AuditEntry, error)

+ func (p *PostgresStorage) GetDeploymentStatus(ctx context.Context, name, environment string) (*DeploymentStatus, error)

+ func (p *PostgresStorage) GetRuleset(ctx context.Context, name, version string) (*StoredRuleset, error)

+ func (p *PostgresStorage) GetRulesetVersions(ctx context.Context, name string) ([]*RulesetVersion, error)

+ func (p *PostgresStorage) HealthCheck(ctx context.Context) error

+ func (p *PostgresStorage) ListRulesets(ctx context.Context, filters *RulesetFilters) ([]*RulesetMetadata, error)

+ func (p *PostgresStorage) RecordActivity(ctx context.Context, entry *AuditEntry) error

+ func (p *PostgresStorage) RollbackDeployment(ctx context.Context, name, environment, targetVersion string) error

+ func (p *PostgresStorage) SetActiveVersion(ctx context.Context, name, environment, version string) error

+ func (p *PostgresStorage) StoreRuleset(ctx context.Context, ruleset *StoredRuleset) error

+ type PostgresStorageConfig struct

+ AutoMigrate bool

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ DSN string

+ MaxConnections int

+ MigrationsPath string

+ type RecoveryObservation struct

+ Backlog int64

+ BacklogMeasured bool

+ Blocked int64

+ Err error

+ ExecutionID string

+ OldestExecutionAge time.Duration

+ OldestOutboxAge time.Duration

+ State string

+ type RecoveryWorker struct

+ BatchSize int

+ Engine *Engine

+ LeaseDuration time.Duration

+ Observer Observer

+ Owner string

+ PollInterval time.Duration

+ Store ledger.ExecutionLedger

+ func (worker *RecoveryWorker) Run(ctx context.Context) error

+ func (worker *RecoveryWorker) RunOnce(ctx context.Context) (int, error)

+ type RollbackInfo struct

+ AutoRollback bool

+ PreviousVersion string

+ RollbackReason string

+ RolledBackAt time.Time

+ RolledBackBy string

+ type RuleStorageBackend interface

+ type RuleType string

+ const RuleTypeFlow

+ const RuleTypeList

+ type RulesetExecutionServer struct

+ func NewRulesetExecutionServer(runtime *ExecutionRuntime, addr string) (*RulesetExecutionServer, error)

+ func NewRulesetExecutionServerOnListener(runtime *ExecutionRuntime, listener net.Listener, ...) (*RulesetExecutionServer, error)

+ func NewRulesetExecutionServerWithOptions(runtime *ExecutionRuntime, addr string, options RulesetExecutionServerOptions) (*RulesetExecutionServer, error)

+ func (server *RulesetExecutionServer) Address() net.Addr

+ func (server *RulesetExecutionServer) Ready() error

+ func (server *RulesetExecutionServer) Start() error

+ func (server *RulesetExecutionServer) Stop()

+ type RulesetExecutionServerOptions struct

+ AllowInsecureTransport bool

+ AllowUnauthenticated bool

+ Authenticator GRPCAuthenticator

+ MaxConcurrentRPCs int

+ MaxExecutionDuration time.Duration

+ MaxReceiveBytes int

+ MaxSendBytes int

+ RulesetName string

+ TLSConfig *tls.Config

+ Version string

+ type RulesetFilters struct

+ CreatedAfter *time.Time

+ CreatedBy string

+ Environments []string

+ GitCommit string

+ Limit int

+ Metadata map[string]string

+ Names []string

+ Offset int

+ Owner string

+ Status []RulesetStatus

+ Tags []string

+ Team string

+ Versions []string

+ type RulesetMetadata struct

+ CreatedAt time.Time

+ CreatedBy string

+ DeploymentCount int

+ Description string

+ Environment string

+ ID string

+ Name string

+ Owner string

+ RuleCount int

+ SchemaVersion string

+ Status RulesetStatus

+ Tags []string

+ Team string

+ UpdatedAt time.Time

+ ValidationHash string

+ Version string

+ type RulesetStatus string

+ const RulesetStatusDeployed

+ const RulesetStatusDeprecated

+ const RulesetStatusDraft

+ const RulesetStatusFailed

+ const RulesetStatusReady

+ const RulesetStatusValidating

+ type RulesetStore interface

+ DeleteRuleset func(context.Context, string, string) error

+ GetRuleset func(context.Context, string, string) (*StoredRuleset, error)

+ GetRulesetVersions func(context.Context, string) ([]*RulesetVersion, error)

+ ListRulesets func(context.Context, *RulesetFilters) ([]*RulesetMetadata, error)

+ StoreRuleset func(context.Context, *StoredRuleset) error

+ type RulesetVersion struct

+ ChangeMessage string

+ CreatedAt time.Time

+ CreatedBy string

+ DeployedEnvs []string

+ GitCommit string

+ IsActive bool

+ Version string

+ type RuntimeInfo struct

+ BundleDigest string

+ Capabilities []string

+ Dependencies []string

+ FunctionCount int

+ GenerationDigest string

+ IRDigest string

+ LoaderCount int

+ PlanCount int

+ PublishedAt time.Time

+ Ruleset string

+ State RuntimeState

+ VerbCount int

+ Version string

+ type RuntimeState string

+ const StateClosed

+ const StateClosing

+ const StateCompiling

+ const StateExecuting

+ const StateFailed

+ const StateInitializing

+ const StateLoading

+ const StateReady

+ type Schema struct

+ Description string

+ Fields map[string]*FieldType

+ Name string

+ Required []string

+ type StorageMaintenance interface

+ Cleanup func(context.Context, time.Time) error

+ HealthCheck func(context.Context) error

+ type StoredRuleset struct

+ CompiledAt time.Time

+ CompilerVersion string

+ CreatedAt time.Time

+ CreatedBy string

+ Deployments map[string]*Deployment

+ Description string

+ Environment string

+ GitAuthor string

+ GitBranch string

+ GitCommit string

+ GitTag string

+ ID string

+ Metadata map[string]string

+ Name string

+ Owner string

+ PullRequest string

+ Ruleset *CompiledRuleset

+ SchemaVersion string

+ Status RulesetStatus

+ Tags []string

+ Team string

+ UpdatedAt time.Time

+ UpdatedBy string

+ ValidationHash string

+ Version string

+ type VerbExecutor interface

+ Execute func(ctx context.Context, args map[string]interface{}) (interface{}, error)

+ type WaitMode string

+ const WaitAccepted

+ const WaitTerminal

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