agent

package module

Go to main page

Versions in this module

v0

v0.23.0

Sep 14, 2026

v0.22.0

Sep 14, 2026

Changes in this version

+ const MaxPayloadBytes

type ChildOutcome

+ func (c ChildOutcome) SubtreeUnresolvedEffects() ([]UnresolvedEffect, bool)

type ProcessSnapshot

+ func (p ProcessSnapshot) EffectDiagnostic(id EffectID) (Failure, bool)

type Signal

+ func (s Signal) EngineOwned() bool

+ type UnresolvedEffect struct

+ EffectID EffectID

+ ProcessID ProcessID

+ func (u UnresolvedEffect) Valid() bool

v0.21.0

Sep 12, 2026

Changes in this version

type StepFinishedFact

+ func (s StepFinishedFact) AdoptionDelay() time.Duration

+ func (s StepFinishedFact) WorkDuration() time.Duration

type StepStatus

+ const StepStatusDiscarded

v0.20.0

Sep 12, 2026

v0.19.0

Sep 11, 2026

Changes in this version

type EngineConfig

+ ProcessInitializationOutcomeAcknowledger ProcessInitializationOutcomeAcknowledger

+ type ProcessInitializationOutcome struct

+ func (p ProcessInitializationOutcome) Admission() ProcessAdmission

+ func (p ProcessInitializationOutcome) Failure() (Failure, bool)

+ func (p ProcessInitializationOutcome) StartedAt() (time.Time, bool)

+ func (p ProcessInitializationOutcome) Status() ProcessInitializationOutcomeStatus

+ func (p ProcessInitializationOutcome) Valid() bool

+ type ProcessInitializationOutcomeAcknowledger interface

+ AcknowledgeProcessInitializationOutcome func(ctx context.Context, outcome ProcessInitializationOutcome) error

+ type ProcessInitializationOutcomeAcknowledgerFunc func(ctx context.Context, outcome ProcessInitializationOutcome) error

+ func (p ProcessInitializationOutcomeAcknowledgerFunc) AcknowledgeProcessInitializationOutcome(ctx context.Context, outcome ProcessInitializationOutcome) error

+ type ProcessInitializationOutcomeStatus string

+ const ProcessInitializationOutcomeStatusFailed

+ const ProcessInitializationOutcomeStatusInitialized

+ const ProcessInitializationOutcomeStatusInvalid

+ func (p ProcessInitializationOutcomeStatus) String() string

+ func (p ProcessInitializationOutcomeStatus) Valid() bool

v0.18.0

Sep 10, 2026

Changes in this version

+ var ErrInvalidChildControl = errors.New("agent: invalid child control")

+ type ChildControlResult struct

+ func ParseChildControlResult(signal Signal) (ChildControlResult, error)

+ func (ChildControlResult) JSONSchemaAlias() any

+ func (c *ChildControlResult) UnmarshalJSON(data []byte) error

+ func (c ChildControlResult) ChildID() ProcessID

+ func (c ChildControlResult) Failure() (Failure, bool)

+ func (c ChildControlResult) MarshalJSON() ([]byte, error)

+ func (c ChildControlResult) Matches(effect Effect) bool

+ func (c ChildControlResult) SignalID() (SignalID, bool)

+ func (c ChildControlResult) Valid() bool

type Descriptor

+ func (Descriptor) JSONSchemaAlias() any

type Effect

+ func CancelChild(childID ProcessID, reason string) (Effect, error)

+ func SignalChild(childID ProcessID, signal SignalRequest) (Effect, error)

type EffectFinishedFact

+ func (e EffectFinishedFact) Failure() (FailureKind, string, bool)

+ type ListenerPanic struct

+ ListenerIndex int

+ ListenerType string

+ Message string

+ ProcessID ProcessID

+ Stack string

+ type ObservationFailures struct

+ func (o ObservationFailures) DeltaListenerPanics() uint64

+ func (o ObservationFailures) EventListenerPanics() uint64

+ func (o ObservationFailures) LastDeltaPanic() (ListenerPanic, bool)

+ func (o ObservationFailures) LastEventPanic() (ListenerPanic, bool)

type ProcessWork

+ const ProcessWorkRestore

type SignalRequest

+ func (SignalRequest) JSONSchemaAlias() any

+ func (s *SignalRequest) UnmarshalJSON(data []byte) error

+ func (s SignalRequest) MarshalJSON() ([]byte, error)

v0.17.0

Sep 10, 2026

Changes in this version

type Capability

+ func (Capability) JSONSchemaAlias() any

type CapabilitySet

+ func (CapabilitySet) JSONSchemaAlias() any

type ChildKey

+ func (ChildKey) JSONSchemaAlias() any

type ChildOutcome

+ func (ChildOutcome) JSONSchemaAlias() any

+ func (c *ChildOutcome) UnmarshalJSON(data []byte) error

+ func (c ChildOutcome) MarshalJSON() ([]byte, error)

type ChildStartResult

+ func (ChildStartResult) JSONSchemaAlias() any

+ func (c *ChildStartResult) UnmarshalJSON(data []byte) error

+ func (c ChildStartResult) MarshalJSON() ([]byte, error)

+ type ChildWaitBoundary string

+ const ChildWaitBoundaryDrained

+ const ChildWaitBoundaryResult

+ func (c ChildWaitBoundary) String() string

+ func (c ChildWaitBoundary) Valid() bool

+ type ChildWaitSatisfied struct

+ func ParseChildWaitSatisfied(signal Signal) (ChildWaitSatisfied, error)

+ func (c ChildWaitSatisfied) Boundary() ChildWaitBoundary

+ func (c ChildWaitSatisfied) Key() WaitKey

+ func (c ChildWaitSatisfied) Outcomes() []ChildOutcome

+ func (c ChildWaitSatisfied) Valid() bool

+ func (c ChildWaitSatisfied) WaitID() WaitID

type ChildWaitSpec

+ Boundary ChildWaitBoundary

type DeploymentRef

+ func (DeploymentRef) JSONSchemaAlias() any

type Digest

+ func (Digest) JSONSchemaAlias() any

type EffectID

+ func (EffectID) JSONSchemaAlias() any

type Failure

+ func (Failure) JSONSchemaAlias() any

type Input

+ func (Input) JSONSchemaAlias() any

type Output

+ func (Output) JSONSchemaAlias() any

type Process

+ func (p *Process) Join(ctx context.Context) error

type ProcessID

+ func (ProcessID) JSONSchemaAlias() any

type ProcessSnapshot

+ func (p ProcessSnapshot) SignalReceipts() []SignalReceipt

type Signal

+ func (Signal) JSONSchemaAlias() any

type SignalID

+ func (SignalID) JSONSchemaAlias() any

+ type SignalReceipt struct

+ func (s SignalReceipt) ArrivalSequence() uint64

+ func (s SignalReceipt) Consumed() bool

+ func (s SignalReceipt) ID() SignalID

+ func (s SignalReceipt) Matches(request SignalRequest) bool

+ func (s SignalReceipt) PayloadDigest() Digest

+ func (s SignalReceipt) PendingSignal() (Signal, bool)

+ func (s SignalReceipt) WaitID() (WaitID, bool)

type Termination

+ func (Termination) JSONSchemaAlias() any

type TreeCheckpointKind

+ const TreeCheckpointProgress

type WaitID

+ func (WaitID) JSONSchemaAlias() any

type WaitKey

+ func (WaitKey) JSONSchemaAlias() any

v0.16.0

Sep 9, 2026

Changes in this version

+ const EventRuntimeStopped

+ var ErrListenerReentrancy = errors.New("agent: operation would wait for its active listener")

+ var ErrSignalConflict = errors.New("agent: signal identity conflicts with accepted content")

type EffectRequest

+ func (e EffectRequest) TreeIncarnationID() (TreeIncarnationID, bool)

type Engine

+ func (e *Engine) InspectTree(ctx context.Context, rootID ProcessID) (TreeInspection, error)

type Event

+ func (e Event) RuntimeStopped() (RuntimeStoppedFact, bool)

+ type ProcessInspection struct

+ EffectID EffectID

+ RuntimeError *RuntimeError

+ Snapshot ProcessSnapshot

+ Stale bool

+ Work ProcessWork

type ProcessSnapshot

+ func (p ProcessSnapshot) UnknownEffectIDs() []EffectID

+ func (p ProcessSnapshot) Usage() Usage

+ func (p ProcessSnapshot) WaitKind() (WaitKind, bool)

+ type ProcessWork string

+ const ProcessWorkChildStart

+ const ProcessWorkDispatch

+ const ProcessWorkIdle

+ const ProcessWorkQueued

+ const ProcessWorkStep

+ type RuntimeError struct

+ func (r *RuntimeError) Error() string

+ func (r *RuntimeError) HeadDigest() Digest

+ func (r *RuntimeError) IncarnationID() TreeIncarnationID

+ func (r *RuntimeError) ProcessID() ProcessID

+ func (r *RuntimeError) UnresolvedEffectIDs() []EffectID

+ func (r *RuntimeError) Unwrap() error

+ type RuntimeStoppedFact struct

+ func (r RuntimeStoppedFact) FailureCode() string

+ func (r RuntimeStoppedFact) FailureKind() FailureKind

+ func (r RuntimeStoppedFact) Valid() bool

type TreeCheckpointKind

+ const TreeCheckpointChild

+ const TreeCheckpointInput

+ const TreeCheckpointStart

+ type TreeFreezePhase string

+ const TreeFreezeAcquiring

+ const TreeFreezeHeld

+ const TreeFreezeNone

+ type TreeInspection struct

+ CommitPending bool

+ Freeze TreeFreezePhase

+ HeadDigest Digest

+ IncarnationID TreeIncarnationID

+ Processes []ProcessInspection

+ RootID ProcessID

+ Stopped bool

+ func (t TreeInspection) Process(processID ProcessID) (ProcessInspection, bool)

+ type WaitKind string

+ const WaitKindChildren

+ const WaitKindExternal

v0.15.0

Sep 7, 2026

Changes in this version

type Engine

+ func (e *Engine) ReleaseTree(ctx context.Context, rootID ProcessID) error

v0.14.0

Sep 1, 2026

v0.13.0

Aug 31, 2026

Changes in this version

+ type BudgetConfig struct

+ Effects uint64

+ Signals uint64

+ Steps uint64

v0.12.0

Aug 30, 2026

v0.11.0

Aug 30, 2026

v0.10.0

Aug 30, 2026

v0.2.1

Aug 30, 2026

Changes in this version

+ const EventDeltaDropped

+ const EventEffectFinished

+ const EventEffectStarted

+ const EventProcessFinished

+ const EventProcessPaused

+ const EventProcessRestored

+ const EventProcessResumed

+ const EventProcessStarted

+ const EventSignalAccepted

+ const EventStepCommitted

+ const EventStepFinished

+ const EventStepPrepared

+ const EventStepStarted

+ var ErrDurabilityConflict = errors.New("agent: durability boundary conflicts with committed content")

+ var ErrEffectNotPending = errors.New("agent: effect does not require resolution")

+ var ErrEngineClosed = errors.New("agent: engine is closed")

+ var ErrEngineHasActiveProcesses = errors.New("agent: engine has active processes")

+ var ErrEngineQuiescenceUnavailable = errors.New("agent: engine cannot become quiescent")

+ var ErrInvalidCapability = errors.New("agent: invalid capability")

+ var ErrInvalidChildStart = errors.New("agent: invalid child process start")

+ var ErrInvalidChildWait = errors.New("agent: invalid child wait")

+ var ErrInvalidDelta = errors.New("agent: invalid delta")

+ var ErrInvalidDeployment = errors.New("agent: invalid deployment")

+ var ErrInvalidDeploymentRef = errors.New("agent: invalid deployment reference")

+ var ErrInvalidDescriptor = errors.New("agent: invalid descriptor")

+ var ErrInvalidDigest = errors.New("agent: invalid digest")

+ var ErrInvalidEffect = errors.New("agent: invalid effect")

+ var ErrInvalidEngineConfig = errors.New("agent: invalid engine configuration")

+ var ErrInvalidEvent = errors.New("agent: invalid event")

+ var ErrInvalidExecutionState = errors.New("agent: invalid execution state")

+ var ErrInvalidFailure = errors.New("agent: invalid failure")

+ var ErrInvalidIdentity = errors.New("agent: invalid identity")

+ var ErrInvalidInput = errors.New("agent: invalid input")

+ var ErrInvalidOutput = errors.New("agent: invalid output")

+ var ErrInvalidPreparedWaitingSubtreeCancellation = errors.New("agent: invalid prepared waiting subtree cancellation")

+ var ErrInvalidProcessControl = errors.New("agent: invalid process control request")

+ var ErrInvalidProcessRelation = errors.New("agent: invalid process relation")

+ var ErrInvalidSchema = errors.New("agent: invalid schema")

+ var ErrInvalidSettlement = errors.New("agent: invalid effect settlement")

+ var ErrInvalidSignal = errors.New("agent: invalid signal")

+ var ErrInvalidSignalRequest = errors.New("agent: invalid signal request")

+ var ErrInvalidSnapshot = errors.New("agent: invalid process snapshot")

+ var ErrInvalidStatus = errors.New("agent: invalid status")

+ var ErrInvalidTransition = errors.New("agent: invalid transition")

+ var ErrInvalidTreeIncarnationID = errors.New("agent: invalid tree incarnation identity")

+ var ErrInvalidTreeSnapshot = errors.New("agent: invalid process tree snapshot")

+ var ErrPreparedWaitingSubtreeCancellationResolved = errors.New("agent: prepared waiting subtree cancellation is resolved")

+ var ErrProcessAdmissionRejected = errors.New("agent: process admission rejected")

+ var ErrProcessAlreadyExists = errors.New("agent: process identity already exists")

+ var ErrProcessFinished = errors.New("agent: process has finished")

+ var ErrProcessNotRunning = errors.New("agent: process is not running")

+ var ErrResourceLimitExceeded = errors.New("agent: resource limit exceeded")

+ var ErrSignalRejected = errors.New("agent: signal rejected")

+ var ErrTreeCaptureUnavailable = errors.New("agent: tree capture is unavailable in durable mode")

+ var ErrTreeDurabilityMismatch = errors.New("agent: tree durability mode mismatch")

+ var ErrTreeIncarnationConflict = errors.New("agent: tree incarnation conflict")

+ var ErrUnsupportedTreeSnapshotVersion = errors.New("agent: unsupported process tree snapshot version")

+ var ErrWaitingSubtreeCancellationUnavailable = errors.New("agent: waiting subtree cancellation is unavailable")

+ type Budget struct

+ Effects uint64

+ Signals uint64

+ Steps uint64

+ func NewBudget(steps, effects, signals uint64) (Budget, error)

+ func (b Budget) Valid() bool

+ type Capability struct

+ func ParseCapability(name string) (Capability, error)

+ func (c *Capability) UnmarshalText(text []byte) error

+ func (c Capability) MarshalText() ([]byte, error)

+ func (c Capability) String() string

+ func (c Capability) Valid() bool

+ type CapabilitySet struct

+ func NewCapabilitySet(capabilities ...Capability) (CapabilitySet, error)

+ func (c *CapabilitySet) UnmarshalJSON(data []byte) error

+ func (c CapabilitySet) Allows(requested CapabilitySet) bool

+ func (c CapabilitySet) Contains(capability Capability) bool

+ func (c CapabilitySet) MarshalJSON() ([]byte, error)

+ func (c CapabilitySet) Valid() bool

+ func (c CapabilitySet) Values() []Capability

+ type ChildKey struct

+ func ParseChildKey(value string) (ChildKey, error)

+ func (c *ChildKey) UnmarshalText(text []byte) error

+ func (c ChildKey) MarshalText() ([]byte, error)

+ func (c ChildKey) String() string

+ func (c ChildKey) Valid() bool

+ type ChildOutcome struct

+ func (c ChildOutcome) Key() ChildKey

+ func (c ChildOutcome) Result() Result

+ func (c ChildOutcome) Valid() bool

+ type ChildSpec struct

+ Budget Budget

+ Capabilities CapabilitySet

+ DeploymentRef DeploymentRef

+ Input Input

+ Key ChildKey

+ func (c ChildSpec) Valid() bool

+ type ChildStartResult struct

+ func ParseChildStartResult(signal Signal) (ChildStartResult, error)

+ func (c ChildStartResult) DeploymentRef() DeploymentRef

+ func (c ChildStartResult) Failure() (Failure, bool)

+ func (c ChildStartResult) Key() ChildKey

+ func (c ChildStartResult) ProcessID() (ProcessID, bool)

+ func (c ChildStartResult) Valid() bool

+ type ChildWaitCondition struct

+ func AllChildren() ChildWaitCondition

+ func AnyChild() ChildWaitCondition

+ func ChildQuorum(count uint32) (ChildWaitCondition, error)

+ func (c ChildWaitCondition) Valid() bool

+ type ChildWaitOpened struct

+ func ParseChildWaitOpened(signal Signal) (ChildWaitOpened, error)

+ func (c ChildWaitOpened) Spec() ChildWaitSpec

+ func (c ChildWaitOpened) Valid() bool

+ func (c ChildWaitOpened) WaitID() WaitID

+ type ChildWaitSpec struct

+ Children []ProcessID

+ Condition ChildWaitCondition

+ Key WaitKey

+ func (c ChildWaitSpec) Valid() bool

+ type ChildrenCompleted struct

+ func ParseChildrenCompleted(signal Signal) (ChildrenCompleted, error)

+ func (c ChildrenCompleted) Key() WaitKey

+ func (c ChildrenCompleted) Outcomes() []ChildOutcome

+ func (c ChildrenCompleted) Valid() bool

+ func (c ChildrenCompleted) WaitID() WaitID

+ type Definition interface

+ Descriptor func() Descriptor

+ Restore func(state ExecutionState) (Execution, error)

+ Start func(input Input) (Execution, error)

+ type Delta struct

+ func (d *Delta) UnmarshalJSON(data []byte) error

+ func (d Delta) EffectID() EffectID

+ func (d Delta) EffectSequence() uint64

+ func (d Delta) EmittedAt() time.Time

+ func (d Delta) MarshalJSON() ([]byte, error)

+ func (d Delta) Payload() json.RawMessage

+ func (d Delta) ProcessID() ProcessID

+ func (d Delta) TreeIncarnationID() (TreeIncarnationID, bool)

+ func (d Delta) Valid() bool

+ type DeltaDroppedFact struct

+ func (f DeltaDroppedFact) Count() uint64

+ func (f DeltaDroppedFact) Valid() bool

+ type DeltaEmitter func(payload json.RawMessage)

+ type DeltaListener interface

+ OnDelta func(ctx context.Context, delta Delta)

+ type DeltaListenerFunc func(ctx context.Context, delta Delta)

+ func (d DeltaListenerFunc) OnDelta(ctx context.Context, delta Delta)

+ type Deployment struct

+ func NewDeployment(config DeploymentConfig) (Deployment, error)

+ func (d Deployment) Definition() Definition

+ func (d Deployment) DeploymentRef() DeploymentRef

+ func (d Deployment) Descriptor() Descriptor

+ func (d Deployment) Valid() bool

+ type DeploymentConfig struct

+ ConfigurationDigest Digest

+ Definition Definition

+ Dispatcher Dispatcher

+ ImplementationDigest Digest

+ type DeploymentRef struct

+ func NewDeploymentRef(descriptor Descriptor, implementationDigest, configurationDigest Digest) (DeploymentRef, error)

+ func (d *DeploymentRef) UnmarshalJSON(data []byte) error

+ func (d DeploymentRef) ConfigurationDigest() Digest

+ func (d DeploymentRef) ContractDigest() Digest

+ func (d DeploymentRef) Digest() Digest

+ func (d DeploymentRef) ImplementationDigest() Digest

+ func (d DeploymentRef) MarshalJSON() ([]byte, error)

+ func (d DeploymentRef) Name() string

+ func (d DeploymentRef) String() string

+ func (d DeploymentRef) Valid() bool

+ type DeploymentResolver interface

+ Resolve func(reference DeploymentRef) (Deployment, error)

+ type Descriptor struct

+ func NewDescriptor(config DescriptorConfig) (Descriptor, error)

+ func (d *Descriptor) UnmarshalJSON(data []byte) error

+ func (d Descriptor) DecodeOutput[T any](output Output) (T, error)

+ func (d Descriptor) Description() string

+ func (d Descriptor) Digest() Digest

+ func (d Descriptor) EncodeInput[T any](value T) (Input, error)

+ func (d Descriptor) InputSchema() Schema

+ func (d Descriptor) MarshalJSON() ([]byte, error)

+ func (d Descriptor) Name() string

+ func (d Descriptor) OutputSchema() Schema

+ func (d Descriptor) Valid() bool

+ func (d Descriptor) ValidateInput(input Input) error

+ func (d Descriptor) ValidateOutput(output Output) error

+ type DescriptorConfig struct

+ Description string

+ InputSchema Schema

+ Name string

+ OutputSchema Schema

+ type Digest struct

+ func ComputeDigest(data []byte) Digest

+ func ParseDigest(value string) (Digest, error)

+ func (d *Digest) UnmarshalText(text []byte) error

+ func (d Digest) MarshalText() ([]byte, error)

+ func (d Digest) String() string

+ func (d Digest) Valid() bool

+ type Dispatcher interface

+ Dispatch func(ctx context.Context, request EffectRequest, emit DeltaEmitter) (Settlement, error)

+ ReplayPolicy func(effect Effect) ReplayPolicy

+ type Effect struct

+ func NewDispatcherEffect(payload json.RawMessage, required ...Capability) (Effect, error)

+ func RequestWait(key WaitKey, signalPayload json.RawMessage) (Effect, error)

+ func StartChild(spec ChildSpec) (Effect, error)

+ func WaitForChildren(spec ChildWaitSpec) (Effect, error)

+ func (e *Effect) UnmarshalJSON(data []byte) error

+ func (e Effect) MarshalJSON() ([]byte, error)

+ func (e Effect) Payload() json.RawMessage

+ func (e Effect) RequiredCapabilities() CapabilitySet

+ func (e Effect) Target() EffectTarget

+ func (e Effect) Valid() bool

+ type EffectBoundary struct

+ func (b EffectBoundary) Kind() EffectBoundaryKind

+ func (b EffectBoundary) PreviousTreeDigest() Digest

+ func (b EffectBoundary) Request() EffectRequest

+ func (b EffectBoundary) Settlement() (Settlement, bool)

+ func (b EffectBoundary) TreeSnapshot() TreeSnapshot

+ func (b EffectBoundary) Valid() bool

+ type EffectBoundaryKind string

+ const EffectBoundaryInvalid

+ const EffectBoundaryPending

+ const EffectBoundaryResolved

+ const EffectBoundarySettled

+ func (k EffectBoundaryKind) String() string

+ func (k EffectBoundaryKind) Valid() bool

+ type EffectFinishedFact struct

+ func (f EffectFinishedFact) Duration() time.Duration

+ func (f EffectFinishedFact) SettlementStatus() SettlementStatus

+ func (f EffectFinishedFact) Target() EffectTarget

+ func (f EffectFinishedFact) Valid() bool

+ type EffectID struct

+ func ParseEffectID(value string) (EffectID, error)

+ func (e *EffectID) UnmarshalText(text []byte) error

+ func (e EffectID) MarshalText() ([]byte, error)

+ func (e EffectID) String() string

+ func (e EffectID) Valid() bool

+ type EffectRequest struct

+ func (e EffectRequest) BatchIndex() uint32

+ func (e EffectRequest) DeploymentRef() DeploymentRef

+ func (e EffectRequest) Effect() Effect

+ func (e EffectRequest) ID() EffectID

+ func (e EffectRequest) ProcessID() ProcessID

+ func (e EffectRequest) Relation() ProcessRelation

+ func (e EffectRequest) StepSequence() uint64

+ func (e EffectRequest) Valid() bool

+ type EffectStartedFact struct

+ func (f EffectStartedFact) Target() EffectTarget

+ func (f EffectStartedFact) Valid() bool

+ type EffectTarget string

+ const EffectTargetDispatcher

+ const EffectTargetFramework

+ const EffectTargetInvalid

+ func (e EffectTarget) String() string

+ func (e EffectTarget) Valid() bool

+ type Engine struct

+ func NewEngine(config EngineConfig) (*Engine, error)

+ func (e *Engine) CaptureTree(ctx context.Context, rootID ProcessID) (TreeSnapshot, error)

+ func (e *Engine) Close() error

+ func (e *Engine) FlushDeltas(ctx context.Context) error

+ func (e *Engine) ObservationFailures() ObservationFailureCounts

+ func (e *Engine) PrepareWaitingSubtreeCancellation(ctx context.Context, rootID ProcessID, targetID ProcessID, reason string) (*PreparedWaitingSubtreeCancellation, error)

+ func (e *Engine) Process(id ProcessID) (*Process, bool)

+ func (e *Engine) RestoreTree(ctx context.Context, rootDeployment Deployment, snapshot TreeSnapshot) (*Process, error)

+ func (e *Engine) Run(ctx context.Context, deployment Deployment, input Input) (Result, error)

+ func (e *Engine) Start(ctx context.Context, deployment Deployment, input Input) (*Process, error)

+ type EngineConfig struct

+ Capabilities CapabilitySet

+ DeltaBufferCapacity int

+ DeltaListeners []DeltaListener

+ DeploymentResolver DeploymentResolver

+ EventListeners []EventListener

+ Limits Limits

+ ProcessAdmitter ProcessAdmitter

+ ProcessStartOutcomeAcknowledger ProcessStartOutcomeAcknowledger

+ TreeDurability TreeDurability

+ TreeLimits TreeLimits

+ type Event struct

+ func (e *Event) UnmarshalJSON(data []byte) error

+ func (e Event) DeltaDropped() (DeltaDroppedFact, bool)

+ func (e Event) DeploymentRef() DeploymentRef

+ func (e Event) EffectFinished() (EffectFinishedFact, bool)

+ func (e Event) EffectID() (EffectID, bool)

+ func (e Event) EffectStarted() (EffectStartedFact, bool)

+ func (e Event) MarshalJSON() ([]byte, error)

+ func (e Event) Name() string

+ func (e Event) OccurredAt() time.Time

+ func (e Event) Payload() json.RawMessage

+ func (e Event) Phase() EventPhase

+ func (e Event) ProcessFinished() (ProcessFinishedFact, bool)

+ func (e Event) ProcessID() ProcessID

+ func (e Event) ProcessSequence() uint64

+ func (e Event) Relation() ProcessRelation

+ func (e Event) SignalAccepted() (SignalAcceptedFact, bool)

+ func (e Event) StepCommitted() (StepCommittedFact, bool)

+ func (e Event) StepFinished() (StepFinishedFact, bool)

+ func (e Event) StepSequence() (uint64, bool)

+ func (e Event) TreeIncarnationID() (TreeIncarnationID, bool)

+ func (e Event) Valid() bool

+ type EventListener interface

+ OnEvent func(ctx context.Context, event Event)

+ type EventListenerFunc func(ctx context.Context, event Event)

+ func (e EventListenerFunc) OnEvent(ctx context.Context, event Event)

+ type EventPhase string

+ const EventPhaseAttempt

+ const EventPhaseCommitted

+ const EventPhaseInvalid

+ func (e EventPhase) String() string

+ func (e EventPhase) Valid() bool

+ type Execution interface

+ Snapshot func() (ExecutionState, error)

+ Step func(ctx context.Context, signals []Signal) (Transition, error)

+ type ExecutionState struct

+ func NewExecutionState(kind string, payload json.RawMessage) (ExecutionState, error)

+ func (e *ExecutionState) UnmarshalJSON(data []byte) error

+ func (e ExecutionState) Kind() string

+ func (e ExecutionState) MarshalJSON() ([]byte, error)

+ func (e ExecutionState) Payload() json.RawMessage

+ func (e ExecutionState) Valid() bool

+ type Failure struct

+ func NewFailure(kind FailureKind, code, message string) (Failure, error)

+ func (f *Failure) UnmarshalJSON(data []byte) error

+ func (f Failure) Code() string

+ func (f Failure) Kind() FailureKind

+ func (f Failure) MarshalJSON() ([]byte, error)

+ func (f Failure) Message() string

+ func (f Failure) Valid() bool

+ type FailureKind string

+ const FailureKindContract

+ const FailureKindExecution

+ const FailureKindExternal

+ const FailureKindInvalid

+ const FailureKindPanic

+ func (f FailureKind) String() string

+ func (f FailureKind) Valid() bool

+ type Input struct

+ func EncodeInput[T any](value T) (Input, error)

+ func ParseInput(data json.RawMessage) (Input, error)

+ func (i *Input) UnmarshalJSON(data []byte) error

+ func (i Input) Decode[T any]() (T, error)

+ func (i Input) JSON() json.RawMessage

+ func (i Input) MarshalJSON() ([]byte, error)

+ func (i Input) Valid() bool

+ type Limits struct

+ MaxEffects uint64

+ MaxPendingSignals uint64

+ MaxSignals uint64

+ MaxSteps uint64

+ func DefaultLimits() Limits

+ func (l Limits) Valid() bool

+ type ObservationFailureCounts struct

+ func (c ObservationFailureCounts) DeltaListenerPanics() uint64

+ func (c ObservationFailureCounts) EventListenerPanics() uint64

+ type Output struct

+ func EncodeOutput[T any](value T) (Output, error)

+ func ParseOutput(data json.RawMessage) (Output, error)

+ func (o *Output) UnmarshalJSON(data []byte) error

+ func (o Output) Decode[T any]() (T, error)

+ func (o Output) JSON() json.RawMessage

+ func (o Output) MarshalJSON() ([]byte, error)

+ func (o Output) Valid() bool

+ type PreparedWaitingSubtreeCancellation struct

+ func (p *PreparedWaitingSubtreeCancellation) Apply() error

+ func (p *PreparedWaitingSubtreeCancellation) CanceledProcessIDs() []ProcessID

+ func (p *PreparedWaitingSubtreeCancellation) Discard() error

+ func (p *PreparedWaitingSubtreeCancellation) PausedProcessIDs() []ProcessID

+ func (p *PreparedWaitingSubtreeCancellation) ResultingSnapshot() TreeSnapshot

+ func (p *PreparedWaitingSubtreeCancellation) SourceTreeDigest() Digest

+ type Process struct

+ func (p *Process) Await(ctx context.Context) (Result, error)

+ func (p *Process) Budget() Budget

+ func (p *Process) Capabilities() CapabilitySet

+ func (p *Process) DeliverSignal(ctx context.Context, request SignalRequest) (accepted bool, err error)

+ func (p *Process) DeliverSignals(ctx context.Context, requests ...SignalRequest) (accepted bool, err error)

+ func (p *Process) DeploymentRef() DeploymentRef

+ func (p *Process) ID() ProcessID

+ func (p *Process) Kill(ctx context.Context, reason string) error

+ func (p *Process) Pause(ctx context.Context, reason string) error

+ func (p *Process) Relation() ProcessRelation

+ func (p *Process) RequestCancellation(ctx context.Context, reason string) error

+ func (p *Process) ResolveUnknownEffect(ctx context.Context, settlement Settlement) error

+ func (p *Process) Resume(ctx context.Context) error

+ func (p *Process) Snapshot(ctx context.Context) (ProcessSnapshot, error)

+ func (p *Process) StartedAt() time.Time

+ func (p *Process) Status() Status

+ func (p *Process) UnknownEffectIDs(ctx context.Context) ([]EffectID, error)

+ func (p *Process) Usage() Usage

+ func (p *Process) WaitID() (WaitID, bool)

+ type ProcessAdmission struct

+ func (p ProcessAdmission) Budget() Budget

+ func (p ProcessAdmission) Capabilities() CapabilitySet

+ func (p ProcessAdmission) DeploymentRef() DeploymentRef

+ func (p ProcessAdmission) Descriptor() Descriptor

+ func (p ProcessAdmission) Relation() ProcessRelation

+ func (p ProcessAdmission) Valid() bool

+ type ProcessAdmitter interface

+ Admit func(ctx context.Context, admission ProcessAdmission) error

+ type ProcessAdmitterFunc func(ctx context.Context, admission ProcessAdmission) error

+ func (p ProcessAdmitterFunc) Admit(ctx context.Context, admission ProcessAdmission) error

+ type ProcessFinishedFact struct

+ func (f ProcessFinishedFact) Cause() TerminationCause

+ func (f ProcessFinishedFact) Failure() (FailureKind, string, bool)

+ func (f ProcessFinishedFact) Status() Status

+ func (f ProcessFinishedFact) Usage() Usage

+ func (f ProcessFinishedFact) Valid() bool

+ type ProcessID struct

+ func ParseProcessID(value string) (ProcessID, error)

+ func (p *ProcessID) UnmarshalText(text []byte) error

+ func (p ProcessID) MarshalText() ([]byte, error)

+ func (p ProcessID) String() string

+ func (p ProcessID) Valid() bool

+ type ProcessRelation struct

+ func (p ProcessRelation) ChildKey() (ChildKey, bool)

+ func (p ProcessRelation) Depth() uint32

+ func (p ProcessRelation) IsRoot() bool

+ func (p ProcessRelation) ParentID() (ProcessID, bool)

+ func (p ProcessRelation) ProcessID() ProcessID

+ func (p ProcessRelation) RootID() ProcessID

+ func (p ProcessRelation) Valid() bool

+ type ProcessSnapshot struct

+ func ParseProcessSnapshot(data json.RawMessage) (ProcessSnapshot, error)

+ func (s *ProcessSnapshot) UnmarshalJSON(data []byte) error

+ func (s ProcessSnapshot) Budget() Budget

+ func (s ProcessSnapshot) Capabilities() CapabilitySet

+ func (s ProcessSnapshot) CommittedExecutionState() ExecutionState

+ func (s ProcessSnapshot) DeploymentRef() DeploymentRef

+ func (s ProcessSnapshot) JSON() json.RawMessage

+ func (s ProcessSnapshot) MarshalJSON() ([]byte, error)

+ func (s ProcessSnapshot) ProcessID() ProcessID

+ func (s ProcessSnapshot) Relation() ProcessRelation

+ func (s ProcessSnapshot) Status() Status

+ func (s ProcessSnapshot) Valid() bool

+ func (s ProcessSnapshot) WaitID() (WaitID, bool)

+ type ProcessStartOutcome struct

+ func (p ProcessStartOutcome) Admission() ProcessAdmission

+ func (p ProcessStartOutcome) Failure() (Failure, bool)

+ func (p ProcessStartOutcome) PreviousTreeDigest() (Digest, bool)

+ func (p ProcessStartOutcome) StartedAt() (time.Time, bool)

+ func (p ProcessStartOutcome) Status() ProcessStartOutcomeStatus

+ func (p ProcessStartOutcome) TreeSnapshot() (TreeSnapshot, bool)

+ func (p ProcessStartOutcome) Valid() bool

+ type ProcessStartOutcomeAcknowledger interface

+ AcknowledgeProcessStartOutcome func(ctx context.Context, outcome ProcessStartOutcome) error

+ type ProcessStartOutcomeAcknowledgerFunc func(ctx context.Context, outcome ProcessStartOutcome) error

+ func (p ProcessStartOutcomeAcknowledgerFunc) AcknowledgeProcessStartOutcome(ctx context.Context, outcome ProcessStartOutcome) error

+ type ProcessStartOutcomeStatus string

+ const ProcessStartOutcomeStatusAborted

+ const ProcessStartOutcomeStatusInvalid

+ const ProcessStartOutcomeStatusStarted

+ func (p ProcessStartOutcomeStatus) String() string

+ func (p ProcessStartOutcomeStatus) Valid() bool

+ type ReplayPolicy string

+ const ReplayPolicyInvalid

+ const ReplayPolicyNever

+ const ReplayPolicySameIdentity

+ func (r ReplayPolicy) String() string

+ func (r ReplayPolicy) Valid() bool

+ type Result struct

+ func (r Result) FinishedAt() time.Time

+ func (r Result) Output() (Output, bool)

+ func (r Result) ProcessID() ProcessID

+ func (r Result) StartedAt() time.Time

+ func (r Result) Status() Status

+ func (r Result) Termination() Termination

+ func (r Result) Usage() Usage

+ func (r Result) Valid() bool

+ type Schema struct

+ func ParseSchema(data json.RawMessage) (Schema, error)

+ func SchemaFor[T any]() (Schema, error)

+ func (s *Schema) UnmarshalJSON(data []byte) error

+ func (s Schema) JSON() json.RawMessage

+ func (s Schema) MarshalJSON() ([]byte, error)

+ func (s Schema) Valid() bool

+ func (s Schema) ValidateInput(input Input) error

+ func (s Schema) ValidateOutput(output Output) error

+ type Settlement struct

+ func NewSettlement(effectID EffectID, status SettlementStatus, payload json.RawMessage) (Settlement, error)

+ func (s *Settlement) UnmarshalJSON(data []byte) error

+ func (s Settlement) EffectID() EffectID

+ func (s Settlement) MarshalJSON() ([]byte, error)

+ func (s Settlement) Payload() json.RawMessage

+ func (s Settlement) Status() SettlementStatus

+ func (s Settlement) Valid() bool

+ type SettlementStatus string

+ const SettlementStatusFailed

+ const SettlementStatusInvalid

+ const SettlementStatusSucceeded

+ const SettlementStatusUnknown

+ func (s SettlementStatus) String() string

+ func (s SettlementStatus) Valid() bool

+ type Signal struct

+ func (s *Signal) UnmarshalJSON(data []byte) error

+ func (s Signal) ID() SignalID

+ func (s Signal) MarshalJSON() ([]byte, error)

+ func (s Signal) Payload() json.RawMessage

+ func (s Signal) Valid() bool

+ func (s Signal) WaitID() (WaitID, bool)

+ type SignalAcceptedFact struct

+ func (f SignalAcceptedFact) SignalID() SignalID

+ func (f SignalAcceptedFact) Valid() bool

+ func (f SignalAcceptedFact) WaitID() (WaitID, bool)

+ type SignalID struct

+ func ParseSignalID(value string) (SignalID, error)

+ func (s *SignalID) UnmarshalText(text []byte) error

+ func (s SignalID) MarshalText() ([]byte, error)

+ func (s SignalID) String() string

+ func (s SignalID) Valid() bool

+ type SignalRequest struct

+ func NewSignalRequest(id SignalID, waitID WaitID, payload json.RawMessage) (SignalRequest, error)

+ func (s SignalRequest) ID() SignalID

+ func (s SignalRequest) Payload() json.RawMessage

+ func (s SignalRequest) Valid() bool

+ func (s SignalRequest) WaitID() (WaitID, bool)

+ type Status string

+ const StatusCanceled

+ const StatusCompleted

+ const StatusFailed

+ const StatusInvalid

+ const StatusKilled

+ const StatusNotStarted

+ const StatusPaused

+ const StatusRunning

+ const StatusTimedOut

+ const StatusWaiting

+ func (s *Status) UnmarshalText(text []byte) error

+ func (s Status) MarshalText() ([]byte, error)

+ func (s Status) String() string

+ func (s Status) Terminal() bool

+ func (s Status) Valid() bool

+ type StepCommittedFact struct

+ func (f StepCommittedFact) Status() Status

+ func (f StepCommittedFact) Valid() bool

+ type StepFinishedFact struct

+ func (f StepFinishedFact) Duration() time.Duration

+ func (f StepFinishedFact) Status() StepStatus

+ func (f StepFinishedFact) Valid() bool

+ type StepStatus string

+ const StepStatusFailed

+ const StepStatusSucceeded

+ func (s StepStatus) String() string

+ func (s StepStatus) Valid() bool

+ type Termination struct

+ func (t *Termination) UnmarshalJSON(data []byte) error

+ func (t Termination) Cause() TerminationCause

+ func (t Termination) Failure() (Failure, bool)

+ func (t Termination) MarshalJSON() ([]byte, error)

+ func (t Termination) Reason() string

+ func (t Termination) Status() Status

+ func (t Termination) UnresolvedEffectIDs() []EffectID

+ func (t Termination) Valid() bool

+ type TerminationCause string

+ const TerminationCauseCompletion

+ const TerminationCauseContractFailure

+ const TerminationCauseEngineKill

+ const TerminationCauseExecutionFailure

+ const TerminationCauseExternalFailure

+ const TerminationCauseHostCancellation

+ const TerminationCauseHostDeadline

+ const TerminationCauseInvalid

+ const TerminationCausePanic

+ const TerminationCauseParentCancellation

+ const TerminationCauseParentDeadline

+ const TerminationCauseProcessDeadline

+ func (t TerminationCause) String() string

+ func (t TerminationCause) Valid() bool

+ type Transition struct

+ func Complete(consumedSignals uint32, output Output) (Transition, error)

+ func Continue(consumedSignals uint32, effects ...Effect) (Transition, error)

+ func Fail(consumedSignals uint32, failure Failure) (Transition, error)

+ func Pause(consumedSignals uint32, reason string) (Transition, error)

+ func Wait(consumedSignals uint32, waitID WaitID) (Transition, error)

+ func (t *Transition) UnmarshalJSON(data []byte) error

+ func (t Transition) ConsumedSignals() uint32

+ func (t Transition) Effects() []Effect

+ func (t Transition) Failure() (Failure, bool)

+ func (t Transition) Kind() TransitionKind

+ func (t Transition) MarshalJSON() ([]byte, error)

+ func (t Transition) Output() (Output, bool)

+ func (t Transition) Reason() (string, bool)

+ func (t Transition) Valid() bool

+ func (t Transition) WaitID() (WaitID, bool)

+ type TransitionKind string

+ const TransitionKindComplete

+ const TransitionKindContinue

+ const TransitionKindFail

+ const TransitionKindInvalid

+ const TransitionKindPause

+ const TransitionKindWait

+ func (t TransitionKind) String() string

+ func (t TransitionKind) Valid() bool

+ type TreeActivation struct

+ func (a TreeActivation) IncarnationID() TreeIncarnationID

+ func (a TreeActivation) PreviousIncarnationID() TreeIncarnationID

+ func (a TreeActivation) PreviousTreeDigest() Digest

+ func (a TreeActivation) TreeSnapshot() TreeSnapshot

+ func (a TreeActivation) Valid() bool

+ type TreeCheckpoint struct

+ func (c TreeCheckpoint) Kind() TreeCheckpointKind

+ func (c TreeCheckpoint) PreviousTreeDigest() Digest

+ func (c TreeCheckpoint) TreeSnapshot() TreeSnapshot

+ func (c TreeCheckpoint) Valid() bool

+ type TreeCheckpointKind string

+ const TreeCheckpointInvalid

+ const TreeCheckpointParked

+ const TreeCheckpointTerminal

+ func (k TreeCheckpointKind) String() string

+ func (k TreeCheckpointKind) Valid() bool

+ type TreeDurability interface

+ ActivateTree func(ctx context.Context, activation TreeActivation) error

+ CommitCheckpoint func(ctx context.Context, checkpoint TreeCheckpoint) error

+ CommitEffect func(ctx context.Context, boundary EffectBoundary) error

+ type TreeIncarnationID struct

+ func ParseTreeIncarnationID(value string) (TreeIncarnationID, error)

+ func (i *TreeIncarnationID) UnmarshalText(text []byte) error

+ func (i TreeIncarnationID) MarshalText() ([]byte, error)

+ func (i TreeIncarnationID) String() string

+ func (i TreeIncarnationID) Valid() bool

+ type TreeLimits struct

+ MaxActiveChildren uint32

+ MaxChildren uint32

+ MaxDepth uint32

+ MaxTreeProcesses uint32

+ func DefaultTreeLimits() TreeLimits

+ func (t TreeLimits) Valid() bool

+ type TreeSnapshot struct

+ func ParseTreeSnapshot(data json.RawMessage) (TreeSnapshot, error)

+ func (t *TreeSnapshot) UnmarshalJSON(data []byte) error

+ func (t TreeSnapshot) Digest() Digest

+ func (t TreeSnapshot) IncarnationID() (TreeIncarnationID, bool)

+ func (t TreeSnapshot) JSON() json.RawMessage

+ func (t TreeSnapshot) MarshalJSON() ([]byte, error)

+ func (t TreeSnapshot) ProcessSnapshots() []ProcessSnapshot

+ func (t TreeSnapshot) RootID() ProcessID

+ func (t TreeSnapshot) Valid() bool

+ func (t TreeSnapshot) Version() TreeSnapshotVersion

+ type TreeSnapshotVersion uint16

+ const CurrentTreeSnapshotVersion

+ type Usage struct

+ AcceptedSignals uint64

+ CommittedSteps uint64

+ DroppedDeltas uint64

+ PreparedEffects uint64

+ type WaitID struct

+ func ParseWaitID(value string) (WaitID, error)

+ func (w *WaitID) UnmarshalText(text []byte) error

+ func (w WaitID) MarshalText() ([]byte, error)

+ func (w WaitID) String() string

+ func (w WaitID) Valid() bool

+ type WaitKey struct

+ func ParseWaitKey(value string) (WaitKey, error)

+ func (w *WaitKey) UnmarshalText(text []byte) error

+ func (w WaitKey) MarshalText() ([]byte, error)

+ func (w WaitKey) String() string

+ func (w WaitKey) Valid() bool

v0.2.0

Aug 27, 2026

v0.1.0

Aug 27, 2026

v0.0.1

Aug 27, 2026

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