Versions in this module Expand all Collapse all v1 v1.4.0 Oct 20, 2026 Changes in this version + const CheckpointSchema + const ProviderName + const RuntimeABI + const SpoolCap + 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 DirectRunscOption func(*directExecutor) + func WithRunscBinary(path string) DirectRunscOption + func WithRunscPlatform(platform string) DirectRunscOption + func WithRunscRoot(root string) DirectRunscOption + type Execution interface + ID func() string + Wait func(ctx context.Context) (RunResult, error) + type ExecutionSpec struct + AgentVersionRef string + AttemptID string + CPUQuotaMillis int64 + Command []string + ImageRef string + MemoryLimitMiB int64 + OutputSpooler OutputSpooler + RuntimeClass string + RuntimeInstanceID string + RuntimePoolID string + TenantID string + WorkloadSpecJSON []byte + WorkspaceBytes int64 + func (s ExecutionSpec) Limits() (cpuMillis, memoryMiB, workspaceBytes int64) + type Executor interface + Destroy func(ctx context.Context, execution Execution) error + Prepare func(ctx context.Context, spec ExecutionSpec) (Execution, error) + func NewRunscDirectExecutor(_ ...DirectRunscOption) (Executor, error) + func NewRunscDirectExecutor(options ...DirectRunscOption) (Executor, error) + func NewRunscExecutor(_ ...RunscOption) (Executor, error) + func NewRunscExecutor(options ...RunscOption) (Executor, error) + type OutputSpooler interface + Spool func(context.Context, string, string, string, io.Reader) (store.ArtifactReference, error) + type RunResult struct + ExitCode int + FailureCode string + Stdout *store.ArtifactReference + StdoutTruncated bool + UsageMillis int64 + type RunscOption func(*ctrExecutor) + func WithNamespace(namespace string) RunscOption + func WithRuntime(runtime string) RunscOption + func WithRuntimeConfigPath(path string) RunscOption + func WithSkipPull() RunscOption + func WithSnapshotter(snapshotter string) RunscOption + type Worker struct + func NewWorker(client runtimev1.RuntimeControlServiceClient, artifacts ArtifactStore, ...) *Worker + func (w *Worker) RunOnce(ctx context.Context) (bool, error) + func (w *Worker) Spool(ctx context.Context, tenantID, attemptID, mediaType string, reader io.Reader) (store.ArtifactReference, error) + func (w *Worker) WithResourceLimits(cpuQuotaMillis, memoryLimitMiB, workspaceBytes int64) *Worker
Go to main page