Versions in this module Expand all Collapse all v0 v0.1.0 Jun 14, 2026 Changes in this version + const Version + func MustRegister[S, R any](reg *Registry, def loop.Definition[S, R]) + func Register[S, R any](reg *Registry, def loop.Definition[S, R]) error + func Respond(ctx context.Context, store runtime.EventStore, id event.LoopID, ...) error + type ChildResult struct + ErrDetail string + LoopID event.LoopID + OutcomeKind string + RespJSON []byte + Spend budget.Spend + type Option func(*runtime.RunnerOptions) + func WithArtifactStore(as runtime.ArtifactStore) Option + func WithBudget(b budget.Budget) Option + func WithClock(clock runtime.Clock) Option + func WithContextManager(cm runtime.ContextManager) Option + func WithConvergence(cfg *converge.Config) Option + func WithMaxIterations(n int) Option + func WithPolicy(grant *policy.Grant) Option + func WithPolicyMode(mode runtime.PolicyMode) Option + func WithPricing(table model.Table) Option + func WithProvider(provider runtime.ModelProvider) Option + func WithSeed(seed int64) Option + func WithSnapshotEvery(n int) Option + func WithSpawner(s runtime.ChildSpawner) Option + func WithStore(store runtime.EventStore) Option + func WithStreamObserver(observer runtime.StreamObserver) Option + func WithTelemetry(tel runtime.Telemetry) Option + func WithTokenEstimator(est runtime.TokenEstimator) Option + func WithTools(tools runtime.ToolExecutor) Option + type Registry struct + func NewRegistry() *Registry + func (r *Registry) Lookup(name string) (*RegistryEntry, bool) + func (r *Registry) ResumeChild(ctx context.Context, opts runtime.RunnerOptions, childID event.LoopID, ...) runtime.ChildResult + func (r *Registry) SpawnChild(ctx context.Context, opts runtime.RunnerOptions, parentID event.LoopID, ...) runtime.ChildResult + type RegistryEntry struct + Name string + ResumeChild func(ctx context.Context, opts runtime.RunnerOptions, childID event.LoopID) ChildResult + SpawnChild func(ctx context.Context, opts runtime.RunnerOptions, parentID event.LoopID, ...) ChildResult + type ReplayDivergenceError = runtime.ReplayDivergenceError + type Runner struct + func New[S, R any](def loop.Definition[S, R], opts ...Option) *Runner[S, R] + func (r *Runner[S, R]) Replay(ctx context.Context, id event.LoopID) (Trajectory[S], error) + func (r *Runner[S, R]) Resume(ctx context.Context, id event.LoopID) (outcome.Outcome[R], error) + func (r *Runner[S, R]) Start(ctx context.Context, input any) (outcome.Outcome[R], error) + type Trajectory = runtime.Trajectory[S]
Go to main page