agent

package module

Go to main page

Versions in this module

v0

v0.61.0

Nov 10, 2026

v0.60.0

Nov 4, 2026

v0.59.0

Nov 1, 2026

Changes in this version

+ var ErrInvalidAdapter = errors.New("agent: invalid adapter configuration")

+ var ErrInvalidDefinitionConfig = errors.New("interaction: invalid definition configuration")

+ var ErrInvalidDelegate = errors.New("interaction: invalid delegate")

+ var ErrInvalidDispatcherConfig = errors.New("interaction: invalid dispatcher configuration")

+ var ErrInvalidModelResponse = run.NewClassifiedError(run.FailureKindExternal, "interaction.model.invalid_response", ...)

+ var ErrInvalidModelSettlement = errors.New("interaction: invalid model settlement")

+ var ErrInvalidPendingToolInput = errors.New("interaction: invalid pending tool input")

+ var ErrInvalidProtocol = run.NewClassifiedError(run.FailureKindContract, "interaction.protocol.invalid", ...)

+ var ErrInvalidResult = errors.New("interaction: invalid result")

+ var ErrInvalidSteer = run.NewClassifiedError(run.FailureKindContract, "interaction.signal.invalid", ...)

+ var ErrInvalidToolAdvertisement = errors.New("interaction: invalid tool advertisement")

+ var ErrInvalidToolCallRef = errors.New("interaction: invalid tool call reference")

+ var ErrInvalidToolSet = errors.New("interaction: invalid tool set")

+ var ErrModelResponseTooLarge = errors.New("interaction: model response exceeds byte limit")

+ func Adapt[I, O any](ctx context.Context, config AdapterConfig[I, O]) (run.Program[I, O], error)

+ func Compile(ctx context.Context, cfg Config) (run.Program[Input, Output], error)

+ func DelegateChildKey(modelCallSequence uint64, toolCall chat.ToolCall) (run.ChildKey, error)

+ func NewSteerSignal(id run.SignalID, messages ...chat.Message) (run.SignalRequest, error)

+ func SettleModelResult[I, O any](p run.Program[I, O], req run.EffectRequest, response *chat.Response) (run.Settlement, error)

+ func SettlePreparedContext[I, O any](p run.Program[I, O], req run.EffectRequest, messages []chat.Message) (run.Settlement, error)

+ func ToolChildKey(modelCallSequence uint64, toolCallIndex uint32) (run.ChildKey, error)

+ type AdapterConfig struct

+ Budget run.Budget

+ BuildInput func(context.Context, I) (Input, error)

+ Capabilities run.CapabilitySet

+ ConfigurationDigest run.Digest

+ DecodeOutput func(context.Context, Output) (O, error)

+ Description string

+ ImplementationDigest run.Digest

+ Interaction run.Program[Input, Output]

+ Name string

+ type AdvertisingTool interface

+ AdvertiseDeferred func(ctx context.Context, invocation tool.Invocation, result tool.Result) ([]string, error)

+ type Artifact struct

+ func (a Artifact) DelegateName() string

+ func (a Artifact) ModelCallSequence() uint64

+ func (a Artifact) Output() run.Payload

+ func (a Artifact) ToolCallID() string

+ type CompletionCandidate struct

+ func (c CompletionCandidate) Artifacts() []Artifact

+ func (c CompletionCandidate) Output() Output

+ func (c CompletionCandidate) WorkingContext() *chat.Request

+ type CompletionDecision struct

+ Accepted bool

+ Feedback string

+ func (c CompletionDecision) Valid() bool

+ type CompletionValidator func(ctx context.Context, candidate CompletionCandidate) (CompletionDecision, error)

+ type ConcurrentTool interface

+ ConcurrencyPolicy func() func(tool.Invocation) (key string, concurrent bool)

+ type Config struct

+ BuildIdentity run.Digest

+ ContextIdentity run.Digest

+ ContextPolicy ContextPolicy

+ ContextProcessor ContextProcessor

+ DeferredTools []tool.Tool

+ Delegates []Delegate

+ Description string

+ MaxConcurrentToolCalls int

+ MaxModelCalls run.Quota

+ MaxResponseBytes int

+ Model chat.Model

+ ModelIdentity run.Digest

+ Name string

+ Streamer chat.Streamer

+ ToolBudget run.Budget

+ ToolCapabilities run.CapabilitySet

+ ToolIdentity run.Digest

+ Tools []tool.Tool

+ type ContextFailure struct

+ Cause error

+ func (c *ContextFailure) Error() string

+ func (c *ContextFailure) Unwrap() error

+ type ContextInvocation struct

+ Effect run.EffectRequest

+ Sequence uint64

+ type ContextPolicy func(ctx context.Context, input Input) ([]chat.Message, error)

+ type ContextProcessor interface

+ PrepareContext func(ctx context.Context, invocation ContextInvocation, request *chat.Request) ([]chat.Message, error)

type Definition

+ func NewDefinition(config DefinitionConfig) (*Definition, error)

+ type DefinitionConfig struct

+ CompletionValidator CompletionValidator

+ ContextPolicy ContextPolicy

+ Delegates []Delegate

+ Description string

+ MaxConcurrentToolCalls int

+ MaxModelCalls run.Quota

+ MaxResponseBytes int

+ Name string

+ PrepareContext bool

+ ToolBudget run.Budget

+ ToolCapabilities run.CapabilitySet

+ Tools ToolSet

+ type Delegate struct

+ func NewDelegate(config DelegateConfig) (Delegate, error)

+ func (d Delegate) Valid() bool

+ type DelegateAttribution struct

+ func DelegateAttributions(snapshot run.ProcessSnapshot) (attributions []DelegateAttribution, found bool, err error)

+ func (d DelegateAttribution) ChildKey() run.ChildKey

+ func (d DelegateAttribution) ModelCallSequence() uint64

+ func (d DelegateAttribution) ProcessID() run.ProcessID

+ func (d DelegateAttribution) Reference() (ToolCallRef, bool)

+ func (d DelegateAttribution) ToolCall() chat.ToolCall

+ func (d DelegateAttribution) ToolCallIndex() uint32

+ func (d DelegateAttribution) Valid() bool

+ type DelegateConfig struct

+ Budget run.Budget

+ Capabilities run.CapabilitySet

+ Deployment run.Program[run.Payload, run.Payload]

+ Description string

+ Name string

+ type DirectResultTool interface

+ ReturnsDirectResult func() bool

type Dispatcher

+ func NewDispatcher(definition *Definition, config DispatcherConfig) (*Dispatcher, error)

+ func (d *Dispatcher) ObservationFailures() ObservationFailures

+ type DispatcherConfig struct

+ ContextProcessor ContextProcessor

+ Model chat.Model

+ Observer ModelObserver

+ Streamer chat.Streamer

type Input

+ Messages []chat.Message

+ Options chat.Options

+ func (i Input) Validate() error

+ type ModelInvocation struct

+ func ModelInvocationFromContext(ctx context.Context) (ModelInvocation, bool)

+ func (m ModelInvocation) AppliedSteerSignalIDs() []run.SignalID

+ func (m ModelInvocation) AttemptID() (run.EffectAttemptID, bool)

+ func (m ModelInvocation) EffectID() run.EffectID

+ func (m ModelInvocation) ModelCallSequence() uint64

+ func (m ModelInvocation) ProgramRef() run.ProgramRef

+ func (m ModelInvocation) Relation() run.ProcessRelation

+ func (m ModelInvocation) StepSequence() uint64

+ func (m ModelInvocation) TreeIncarnationID() (run.TreeIncarnationID, bool)

+ func (m ModelInvocation) Valid() bool

+ type ModelObserver interface

+ OnModelSettled func(ctx context.Context, invocation ModelInvocation, settlement ModelSettlement)

+ OnModelStarted func(ctx context.Context, invocation ModelInvocation, request *chat.Request)

+ type ModelOutcome string

+ const ModelOutcomeFailed

+ const ModelOutcomeInvalid

+ const ModelOutcomeNotExecuted

+ const ModelOutcomeSucceeded

+ const ModelOutcomeUnknown

+ const ModelOutcomeUnobserved

+ func (m ModelOutcome) Valid() bool

+ type ModelResponseDelta struct

+ func ParseModelResponseDelta(payload json.RawMessage) (ModelResponseDelta, error)

+ func (m ModelResponseDelta) ResponseDelta() *chat.ResponseDelta

+ type ModelSettlement struct

+ Failure string

+ Outcome ModelOutcome

+ Response *chat.Response

+ func (m ModelSettlement) Validate() error

type ObservationFailures

+ func (o ObservationFailures) LastModelSettledPanic() (ObserverPanic, bool)

+ func (o ObservationFailures) LastModelStartedPanic() (ObserverPanic, bool)

+ func (o ObservationFailures) LastToolSettledPanic() (ObserverPanic, bool)

+ func (o ObservationFailures) LastToolStartedPanic() (ObserverPanic, bool)

+ func (o ObservationFailures) ModelSettledPanics() uint64

+ func (o ObservationFailures) ModelStartedPanics() uint64

+ func (o ObservationFailures) ToolSettledPanics() uint64

+ func (o ObservationFailures) ToolStartedPanics() uint64

+ type ObserverPanic struct

+ AttemptID run.EffectAttemptID

+ EffectID run.EffectID

+ Message string

+ ObserverType string

+ ProcessID run.ProcessID

+ Stack string

type Output

+ DirectToolResults []chat.ToolResult

+ ModelCalls uint64

+ ModelResponse *chat.Response

+ func (o Output) Validate() error

+ type PendingToolInput struct

+ func PendingToolInputs(snapshot run.TreeSnapshot) ([]PendingToolInput, error)

+ func (p PendingToolInput) ProcessID() run.ProcessID

+ func (p PendingToolInput) Prompt() json.RawMessage

+ func (p PendingToolInput) ResponseSchema() json.RawMessage

+ func (p PendingToolInput) ResponseSignal(id run.SignalID, response json.RawMessage) (run.SignalRequest, error)

+ func (p PendingToolInput) Valid() bool

+ func (p PendingToolInput) WaitID() run.WaitID

+ type ResultDisposition string

+ const ResultFailed

+ const ResultInvalid

+ const ResultRejected

+ const ResultSucceeded

+ func (r ResultDisposition) String() string

+ func (r ResultDisposition) Valid() bool

+ type ResultEntry struct

+ Call chat.ToolCall

+ Disposition ResultDisposition

+ Result chat.ToolResult

+ ToolCallIndex uint32

+ type RoundResults struct

+ func SettledResults(snapshot run.TreeSnapshot) ([]RoundResults, error)

+ func (r RoundResults) CallCount() uint32

+ func (r RoundResults) Complete() bool

+ func (r RoundResults) Digest() run.Digest

+ func (r RoundResults) Entries() []ResultEntry

+ func (r RoundResults) JSON() json.RawMessage

+ func (r RoundResults) ModelCallSequence() uint64

+ func (r RoundResults) Reference(toolCallIndex uint32) (ToolCallRef, bool)

+ func (r RoundResults) Relation() run.ProcessRelation

+ type ToolCallRef struct

+ func ParseToolCallRef(value string) (ToolCallRef, error)

+ func (ToolCallRef) JSONSchemaModel() any

+ func (t *ToolCallRef) UnmarshalText(text []byte) error

+ func (t ToolCallRef) MarshalText() ([]byte, error)

+ func (t ToolCallRef) ModelCallSequence() uint64

+ func (t ToolCallRef) ProcessID() run.ProcessID

+ func (t ToolCallRef) String() string

+ func (t ToolCallRef) ToolCallIndex() uint32

+ func (t ToolCallRef) Valid() bool

+ type ToolInvocation struct

+ func ToolInvocationFromContext(ctx context.Context) (ToolInvocation, bool)

+ func ToolInvocationFromRequest(request run.EffectRequest) (ToolInvocation, error)

+ func (t ToolInvocation) AttemptID() (run.EffectAttemptID, bool)

+ func (t ToolInvocation) EffectID() run.EffectID

+ func (t ToolInvocation) ProgramRef() run.ProgramRef

+ func (t ToolInvocation) Reference() (ToolCallRef, bool)

+ func (t ToolInvocation) Relation() run.ProcessRelation

+ func (t ToolInvocation) StepSequence() uint64

+ func (t ToolInvocation) ToolCall() chat.ToolCall

+ func (t ToolInvocation) TreeIncarnationID() (run.TreeIncarnationID, bool)

+ func (t ToolInvocation) Valid() bool

+ type ToolObserver interface

+ OnToolSettled func(ctx context.Context, invocation ToolInvocation, settlement ToolSettlement)

+ OnToolStarted func(ctx context.Context, invocation ToolInvocation)

+ type ToolSet struct

+ func NewToolSet(config ToolSetConfig) (ToolSet, error)

+ func (t ToolSet) Configured() bool

+ func (t ToolSet) ObservationFailures() ObservationFailures

+ func (t ToolSet) Program() run.Program[run.Payload, run.Payload]

+ func (t ToolSet) SettleToolResult(request run.EffectRequest, output tool.Output, disposition ResultDisposition, ...) (run.Settlement, error)

+ type ToolSetConfig struct

+ ConfigurationDigest run.Digest

+ DecorateDispatcher func(run.Dispatcher) (run.Dispatcher, error)

+ DeferredTools []tool.Tool

+ Description string

+ ImplementationDigest run.Digest

+ Name string

+ Observer ToolObserver

+ Tools []tool.Tool

+ type ToolSettlement struct

+ Evidence *toolcontract.Output

+ Failure string

+ InputRequired bool

+ Result *chat.ToolResult

+ func (t ToolSettlement) Unknown() bool

v0.58.0

Oct 26, 2026

v0.57.1

Oct 25, 2026

v0.57.0

Oct 25, 2026

Changes in this version

type Capability

+ func (Capability) JSONSchemaModel() any

type CapabilitySet

+ func (CapabilitySet) JSONSchemaModel() any

type ChildControlResult

+ func (ChildControlResult) JSONSchemaModel() any

type ChildKey

+ func (ChildKey) JSONSchemaModel() any

type ChildOutcome

+ func (ChildOutcome) JSONSchemaModel() any

type ChildStartResult

+ func (ChildStartResult) JSONSchemaModel() any

type DeploymentRef

+ func (DeploymentRef) JSONSchemaModel() any

type Descriptor

+ func (Descriptor) JSONSchemaModel() any

type Digest

+ func (Digest) JSONSchemaModel() any

type EffectAttemptID

+ func (EffectAttemptID) JSONSchemaModel() any

type EffectID

+ func (EffectID) JSONSchemaModel() any

type ExternalWaitSpecConfig

+ MaxAnswerBytes int

type Failure

+ func (Failure) JSONSchemaModel() any

type Payload

+ func (Payload) JSONSchemaModel() any

type ProcessID

+ func (ProcessID) JSONSchemaModel() any

type Quota

+ func (Quota) JSONSchemaModel() any

type Signal

+ func (Signal) JSONSchemaModel() any

type SignalID

+ func (SignalID) JSONSchemaModel() any

type SignalRequest

+ func (SignalRequest) JSONSchemaModel() any

type Termination

+ func (Termination) JSONSchemaModel() any

type TreeIncarnationID

+ func (TreeIncarnationID) JSONSchemaModel() any

type WaitID

+ func (WaitID) JSONSchemaModel() any

type WaitKey

+ func (WaitKey) JSONSchemaModel() any

v0.56.0

Oct 24, 2026

Changes in this version

+ var ErrInvalidExternalWait = errors.New("agent: invalid external wait")

+ type ExternalWaitSpec struct

+ func NewExternalWaitSpec(config ExternalWaitSpecConfig) (ExternalWaitSpec, error)

+ func (e ExternalWaitSpec) Key() WaitKey

+ func (e ExternalWaitSpec) Valid() bool

+ type ExternalWaitSpecConfig struct

+ AnswerIsOutput bool

+ AnswerSchema jsonschema.Schema

+ Key WaitKey

+ type StartError struct

+ func (s *StartError) Digest() Digest

+ func (s *StartError) Error() string

+ func (s *StartError) Incarnation() TreeIncarnationID

+ func (s *StartError) RootID() ProcessID

+ func (s *StartError) Sequence() uint64

+ func (s *StartError) Unwrap() error

v0.55.0

Oct 22, 2026

v0.54.1

Oct 20, 2026

v0.54.0

Oct 20, 2026

Changes in this version

type Process

+ func (p *Process) TreeIncarnationID() TreeIncarnationID

v0.53.0

Oct 19, 2026

Changes in this version

+ var ErrPayloadTooLarge = errors.New("agent: payload exceeds the maximum encoded size")

v0.52.0

Oct 16, 2026

v0.51.1

Oct 15, 2026

v0.50.0

Oct 12, 2026

v0.49.0

Oct 12, 2026

v0.48.0

Oct 12, 2026

v0.47.0

Oct 12, 2026

Changes in this version

+ type QualifiedName string

+ func (QualifiedName) JSONSchemaPattern() string

v0.46.0

Oct 11, 2026

Changes in this version

type ChildSpec

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

type ProcessInitializationOutcome

+ func (p ProcessInitializationOutcome) Incarnation() TreeIncarnationID

v0.45.0

Oct 8, 2026

Changes in this version

type Termination

+ func (t Termination) Output() (Payload, bool)

v0.44.0

Oct 7, 2026

Changes in this version

type Dispatcher

+ Policy func(effect Effect) EffectPolicy

+ type EffectPolicy struct

+ Replay ReplayPolicy

+ RequiredCapabilities CapabilitySet

+ func (e EffectPolicy) Valid() bool

type Schema

+ func (s Schema) Equal(other Schema) bool

type Settlement

+ func ParseSettlement(signal Signal) (Settlement, error)

type Signal

+ func NewSettlementSignal(id SignalID, settlement Settlement) (Signal, error)

v0.43.0

Oct 5, 2026

Changes in this version

type ChildSpec

+ func ParseChildStartEffect(effect Effect) (ChildSpec, error)

type WaitID

+ func ParseWaitOpened(signal Signal) (WaitID, error)

v0.42.0

Oct 3, 2026

Changes in this version

type Usage

+ func (u *Usage) UnmarshalJSON(data []byte) error

v0.41.0

Oct 1, 2026

Changes in this version

+ var ErrTreeNotFound = errors.New("agent: tree not found")

type ChildOutcome

+ func (c ChildOutcome) SubtreeResolved() bool

type Definition

+ ChildDeployments func() []Deployment

+ type DeltaDropped struct

+ func (d DeltaDropped) AttemptID() EffectAttemptID

+ func (d DeltaDropped) Count() uint64

+ func (d DeltaDropped) Valid() bool

type DeploymentRef

+ func (d DeploymentRef) BindingsDigest() Digest

+ type EffectFinished struct

+ func (e EffectFinished) AttemptID() EffectAttemptID

+ func (e EffectFinished) Duration() time.Duration

+ func (e EffectFinished) Failure() (FailureClassification, bool)

+ func (e EffectFinished) SettlementStatus() SettlementStatus

+ func (e EffectFinished) Target() EffectTarget

+ func (e EffectFinished) Valid() bool

+ type EffectResolved struct

+ func (e EffectResolved) SettlementStatus() SettlementStatus

+ func (e EffectResolved) Target() EffectTarget

+ func (e EffectResolved) Valid() bool

+ type EffectStarted struct

+ func (e EffectStarted) AttemptID() EffectAttemptID

+ func (e EffectStarted) Target() EffectTarget

+ func (e EffectStarted) Valid() bool

type EngineConfig

+ Budget Budget

+ ProcessInitializationAcknowledger ProcessInitializationAcknowledger

type Failure

+ func StepFailure(err error) (Failure, bool)

+ func (f Failure) Classification() FailureClassification

+ type FailureClassification struct

+ func (f FailureClassification) Code() string

+ func (f FailureClassification) Kind() FailureKind

+ func (f FailureClassification) Valid() bool

+ type ProcessFinished struct

+ func (p ProcessFinished) Cause() TerminationCause

+ func (p ProcessFinished) Failure() (FailureClassification, bool)

+ func (p ProcessFinished) Status() Status

+ func (p ProcessFinished) Usage() Usage

+ func (p ProcessFinished) Valid() bool

+ type ProcessInitializationAcknowledger interface

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

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

+ func (p ProcessInitializationAcknowledgerFunc) Acknowledge(ctx context.Context, outcome ProcessInitializationOutcome) error

+ type RuntimeStopped struct

+ func (r RuntimeStopped) Failure() FailureClassification

+ func (r RuntimeStopped) Valid() bool

+ type SignalAccepted struct

+ func (s SignalAccepted) SignalID() SignalID

+ func (s SignalAccepted) Valid() bool

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

+ type StepCommitted struct

+ func (s StepCommitted) Status() Status

+ func (s StepCommitted) Valid() bool

+ type StepFinished struct

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

+ func (s StepFinished) Status() StepStatus

+ func (s StepFinished) Valid() bool

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

type TreeLimits

+ MaxPendingSignals uint64

+ MaxProcessSnapshotBytes Quota

v0.40.0

Sep 29, 2026

Changes in this version

type EffectBoundary

+ func (e EffectBoundary) ContentDigest() (Digest, error)

+ func (e EffectBoundary) Identity() string

type TreeActivation

+ func (t TreeActivation) ContentDigest() (Digest, error)

+ func (t TreeActivation) Identity() string

type TreeCheckpoint

+ func (t TreeCheckpoint) ContentDigest() (Digest, error)

+ func (t TreeCheckpoint) Identity() string

v0.39.0

Sep 28, 2026

v0.38.0

Sep 28, 2026

Changes in this version

type EffectRequest

+ func (e EffectRequest) AttemptID() (EffectAttemptID, bool)

v0.37.0

Sep 25, 2026

Changes in this version

type TreeSnapshot

+ func (t TreeSnapshot) EncodedSize() int

v0.36.0

Sep 23, 2026

Changes in this version

+ func ClassifyStepError(err error) error

+ type ClassifiedError struct

+ func NewClassifiedError(kind FailureKind, code, message string) *ClassifiedError

+ func (c *ClassifiedError) Error() string

type Engine

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

type ExecutionState

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

type Signal

+ func NewSignal(id SignalID, waitID WaitID, payload json.RawMessage) (Signal, error)

v0.33.0

Sep 22, 2026

v0.32.0

Sep 21, 2026

Changes in this version

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

+ var ErrInvalidEffectAttemptID = errors.New("agent: invalid Effect attempt identity")

type Delta

+ func (d Delta) AttemptID() EffectAttemptID

type DeltaDroppedFact

+ func (d DeltaDroppedFact) AttemptID() EffectAttemptID

+ type EffectAttemptID struct

+ func ParseEffectAttemptID(value string) (EffectAttemptID, error)

+ func (EffectAttemptID) JSONSchemaAlias() any

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

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

+ func (i EffectAttemptID) String() string

+ func (i EffectAttemptID) Valid() bool

type EffectBoundary

+ func (e EffectBoundary) Sequence() uint64

type EffectFinishedFact

+ func (e EffectFinishedFact) AttemptID() EffectAttemptID

type EffectStartedFact

+ func (e EffectStartedFact) AttemptID() EffectAttemptID

type EngineConfig

+ TreeCommitter TreeCommitter

+ type MemoryTreeCommitter struct

+ func NewMemoryTreeCommitter() *MemoryTreeCommitter

+ func (m *MemoryTreeCommitter) ActivateTree(_ context.Context, activation TreeActivation) error

+ func (m *MemoryTreeCommitter) CommitCheckpoint(_ context.Context, checkpoint TreeCheckpoint) error

+ func (m *MemoryTreeCommitter) CommitEffect(_ context.Context, boundary EffectBoundary) error

+ func (m *MemoryTreeCommitter) LoadTree(_ context.Context, rootID ProcessID) (TreeSnapshot, bool, error)

type Payload

+ func (p Payload) IsZero() bool

type TreeCheckpoint

+ func (t TreeCheckpoint) Sequence() uint64

+ type TreeCommitter 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 TreeSnapshot

+ func (t TreeSnapshot) EffectRequest(processID ProcessID, id EffectID) (EffectRequest, bool)

v0.31.0

Sep 19, 2026

v0.30.0

Sep 19, 2026

v0.29.0

Sep 19, 2026

Changes in this version

type Descriptor

+ func (d Descriptor) SignalSchema() Schema

+ func (d Descriptor) ValidateSignal(input Payload) error

type DescriptorConfig

+ SignalSchema Schema

+ type StepError struct

+ Cause error

+ Failure Failure

+ func (s *StepError) Error() string

+ func (s *StepError) Unwrap() error

v0.28.0

Sep 17, 2026

Changes in this version

+ type CallbackPanicError struct

+ Operation string

+ Value any

+ func (c *CallbackPanicError) Error() string

+ func (c *CallbackPanicError) Unwrap() error

type Limits

+ Budget Budget

+ func (l *Limits) UnmarshalJSON(data []byte) error

type ProcessSnapshot

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

+ func (p ProcessSnapshot) Settlements() []Settlement

type Transition

+ func Checkpoint(consumedSignals uint32) (Transition, error)

type TransitionKind

+ const TransitionKindCheckpoint

v0.27.0

Sep 17, 2026

Changes in this version

+ var ErrCounterExhausted = errors.New("agent: counter exhausted")

type Budget

+ func (b *Budget) UnmarshalJSON(data []byte) error

type Limits

+ MaxSnapshotBytes Quota

+ type Quota struct

+ func NewQuota(maximum uint64) Quota

+ func (Quota) JSONSchemaAlias() any

+ func (q *Quota) UnmarshalJSON(data []byte) error

+ func (q Quota) Allows(quantities ...uint64) bool

+ func (q Quota) MarshalJSON() ([]byte, error)

+ func (q Quota) Maximum() (uint64, bool)

type TreeLimits

+ MaxSnapshotBytes Quota

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

v0.26.0

Sep 16, 2026

Changes in this version

+ const EventEffectResolved

+ const MaxDescriptionBytes

+ const MaxDiagnosticBytes

+ var ErrInvalidPayload = errors.New("agent: invalid payload")

+ var ErrNilContext = errors.New("agent: nil Context")

+ var ErrSchemaValidation = errors.New("agent: schema validation failed")

+ func NormalizeDiagnostic(message string) string

+ func RequireContext(ctx context.Context) context.Context

+ func ValidDescription(description string) bool

+ func ValidDiagnostic(message string) bool

+ func ValidQualifiedName(name string) bool

type ChildOutcome

+ func (c ChildOutcome) Boundary() ChildWaitBoundary

+ func (c ChildOutcome) Matches(key ChildKey, processID ProcessID) bool

type ChildStartResult

+ func (c ChildStartResult) Matches(key ChildKey, deployment DeploymentRef) bool

type ChildWaitBoundary

+ const ChildWaitBoundaryInvalid

type ChildWaitOpened

+ func (c ChildWaitOpened) Matches(spec ChildWaitSpec) bool

type ChildWaitSatisfied

+ func (c ChildWaitSatisfied) Matches(id WaitID, spec ChildWaitSpec) bool

type Effect

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

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

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

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

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

type EffectBoundaryKind

+ const EffectBoundaryKindInvalid

+ const EffectBoundaryKindPending

+ const EffectBoundaryKindResolved

+ const EffectBoundaryKindSettled

type EffectFinishedFact

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

+ type EffectResolvedFact struct

+ func (e EffectResolvedFact) SettlementStatus() SettlementStatus

+ func (e EffectResolvedFact) Target() EffectTarget

+ func (e EffectResolvedFact) Valid() bool

type Event

+ func (e Event) EffectResolved() (EffectResolvedFact, bool)

type ExecutionState

+ func EncodeExecutionState[T any](kind string, value T) (ExecutionState, error)

+ func (e ExecutionState) Decode[T any](kind string) (T, error)

type ObservationFailures

+ func (o ObservationFailures) DroppedEvents() uint64

+ type Payload struct

+ func EncodePayload[T any](value T) (Payload, error)

+ func ParsePayload(data json.RawMessage) (Payload, error)

+ func (Payload) JSONSchemaAlias() any

+ func (p *Payload) UnmarshalJSON(data []byte) error

+ func (p Payload) Decode[T any]() (T, error)

+ func (p Payload) JSON() json.RawMessage

+ func (p Payload) MarshalJSON() ([]byte, error)

+ func (p Payload) Valid() bool

type ProcessFinishedFact

+ func (p ProcessFinishedFact) FailureClassification() (FailureKind, string, bool)

type ProcessWork

+ const ProcessWorkInvalid

+ func (p ProcessWork) String() string

+ func (p ProcessWork) Valid() bool

type Schema

+ func (s Schema) Validate(value json.RawMessage) error

type StepStatus

+ const StepStatusInvalid

type TreeCheckpointKind

+ const TreeCheckpointKindChildStart

+ const TreeCheckpointKindInvalid

+ const TreeCheckpointKindParked

+ const TreeCheckpointKindProgress

+ const TreeCheckpointKindSignals

+ const TreeCheckpointKindStart

+ const TreeCheckpointKindTerminal

type TreeFreezePhase

+ const TreeFreezePhaseAcquiring

+ const TreeFreezePhaseHeld

+ const TreeFreezePhaseInvalid

+ const TreeFreezePhaseNone

+ func (t TreeFreezePhase) String() string

+ func (t TreeFreezePhase) Valid() bool

type TreeIncarnationID

+ func (TreeIncarnationID) JSONSchemaAlias() any

type WaitKind

+ const WaitKindInvalid

+ func (w WaitKind) String() string

+ func (w WaitKind) Valid() bool

v0.25.0

Sep 15, 2026

v0.24.0

Sep 14, 2026

Changes in this version

+ var ErrEffectOutcomeUnknown = errors.New("agent: effect outcome remains unknown")

+ var ErrEffectReplayForbidden = errors.New("agent: effect cannot be replayed under the same identity")

type Process

+ func (p *Process) ReplayUnknownEffect(ctx context.Context, effectID EffectID) error

type Signal

+ func (s Signal) Settles(effectID EffectID) bool

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