agenttest

Sep 12, 2026

Changes in this version

type DefinitionConformanceConfig

+ FollowingSignals [][]agent.Signal

type ExecutionConformanceCase

+ FollowingSignals [][]agent.Signal

Aug 30, 2026

Changes in this version

+ var ErrEffectMismatch = errors.New("agenttest: effect does not match script")

+ var ErrInvalidDispatchScript = errors.New("agenttest: invalid dispatch script")

+ var ErrInvalidEventPredicate = errors.New("agenttest: invalid event predicate")

+ var ErrUnexpectedDispatch = errors.New("agenttest: unexpected dispatch")

+ func RunDefinitionConformance(t *testing.T, config DefinitionConformanceConfig)

+ func RunTreeDurabilityConformance(t *testing.T, factory func() TreeDurabilityConformanceDriver)

+ type DefinitionConformanceConfig struct

+ Definition agent.Definition

+ InitialSignals []agent.Signal

+ Input agent.Input

+ RestoredCases []ExecutionConformanceCase

+ type DispatchStep struct

+ Deltas []json.RawMessage

+ Error error

+ ExpectedEffect *agent.Effect

+ SettlementPayload json.RawMessage

+ SettlementStatus agent.SettlementStatus

+ type ExecutionConformanceCase struct

+ Name string

+ Signals []agent.Signal

+ State agent.ExecutionState

+ type MemoryTreeDurability struct

+ func NewMemoryTreeDurability() *MemoryTreeDurability

+ func (m *MemoryTreeDurability) AcknowledgeProcessStartOutcome(_ context.Context, outcome agent.ProcessStartOutcome) error

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

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

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

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

+ func (m *MemoryTreeDurability) TreeDurability() agent.TreeDurability

+ type ObservationRecorder struct

+ func (o *ObservationRecorder) AwaitEvent(ctx context.Context, predicate func(agent.Event) bool) (agent.Event, error)

+ func (o *ObservationRecorder) Deltas() []agent.Delta

+ func (o *ObservationRecorder) Events() []agent.Event

+ func (o *ObservationRecorder) OnDelta(_ context.Context, delta agent.Delta)

+ func (o *ObservationRecorder) OnEvent(_ context.Context, event agent.Event)

+ type ScriptedDispatcher struct

+ func NewScriptedDispatcher(config ScriptedDispatcherConfig) (*ScriptedDispatcher, error)

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

+ func (s *ScriptedDispatcher) Remaining() int

+ func (s *ScriptedDispatcher) ReplayPolicy(effect agent.Effect) agent.ReplayPolicy

+ func (s *ScriptedDispatcher) Requests() []agent.EffectRequest

+ type ScriptedDispatcherConfig struct

+ ReplayPolicy agent.ReplayPolicy

+ Steps []DispatchStep

+ type TreeDurabilityConformanceDriver interface

+ LoadTree func(ctx context.Context, rootID agent.ProcessID) (agent.TreeSnapshot, bool, error)

+ TreeDurability func() agent.TreeDurability