Versions in this module Expand all Collapse all v1 v1.4.0 Oct 20, 2026 Changes in this version + const CheckpointSchema + const ProviderName + type ArtifactStore interface + Open func(context.Context, string, store.ArtifactReference) (io.ReadCloser, error) + Put func(context.Context, string, string, io.Reader) (store.ArtifactReference, error) + type ExecutionWindow interface + Open func(mcp.AttemptContext) func() + type Worker struct + func NewWorker(control runtimev1.RuntimeControlServiceClient, artifacts ArtifactStore, ...) (*Worker, error) + func (w *Worker) RunOnce(ctx context.Context) (processed bool, runErr error) + func (w *Worker) WithExecutionWindow(window ExecutionWindow) *Worker + func (w *Worker) WithRuntimeBindings(bindings *bindings.RuntimeBindings) *Worker
Go to main page