Versions in this module Expand all Collapse all v1 v1.0.5 Aug 22, 2026 v1.0.4 Aug 22, 2026 Changes in this version + var ErrAdapterNotApproved = errors.New("cloud worker adapter binding is not approved") + var ErrWorkerInvalid = errors.New("cloud worker configuration or assignment is invalid") + type AdapterRegistry interface + Prepare func(controlapi.WorkerAssignment, ExecutionContext) (runtime.RunSpec, error) + type ApprovedBinding struct + Execution controlapi.WorkerExecutionBinding + Pins coreworker.ExecutionPins + type CommandReadiness struct + func NewCommandReadiness(capabilityRevisionID string, revision int, command []string, ...) (*CommandReadiness, error) + func (readiness *CommandReadiness) Recheck(ctx context.Context, assignment controlapi.WorkerAssignment) error + func (readiness *CommandReadiness) Snapshot(ctx context.Context) (ReadinessSnapshot, error) + type Control interface + AcknowledgeWorkerCancellation func(context.Context, controlapi.WorkerCancellationAckCommand) (controlapi.WorkerCancellationAck, error) + AppendWorkerArtifactChunk func(context.Context, controlapi.WorkerArtifactChunkCommand) (controlapi.WorkerArtifactChunk, error) + ClaimNextWorkerTarget func(context.Context, controlapi.WorkerClaimNextCommand) (controlapi.WorkerAssignment, error) + CommitWorkerTerminal func(context.Context, controlapi.WorkerTerminalCommand) (controlapi.WorkerTerminalResult, error) + CreateWorkerArtifact func(context.Context, controlapi.WorkerArtifactCreateCommand) (controlapi.WorkerArtifact, error) + FinalizeWorkerArtifact func(context.Context, controlapi.WorkerArtifactFinalizeCommand) (controlapi.WorkerArtifact, error) + GetWorkerArtifactStatus func(context.Context, controlapi.WorkerArtifactStatusCommand) (controlapi.WorkerArtifact, error) + HeartbeatWorkerLease func(context.Context, controlapi.WorkerLeaseHeartbeatCommand) (controlapi.WorkerLeaseHeartbeatResult, error) + ReadWorkerContextPage func(context.Context, controlapi.WorkerContextPageCommand) (controlapi.WorkerContextPage, error) + RecordWorkerReadiness func(context.Context, controlapi.WorkerReadinessCommand) (controlapi.WorkerReadinessResult, error) + type ExecutionContext struct + Items []controlapi.WorkerContextItem + ManifestDigest string + ManifestID string + type HTTPClient struct + func NewHTTPClient(config HTTPConfig) (*HTTPClient, error) + func (client *HTTPClient) AcknowledgeWorkerCancellation(ctx context.Context, command controlapi.WorkerCancellationAckCommand) (controlapi.WorkerCancellationAck, error) + func (client *HTTPClient) AppendWorkerArtifactChunk(ctx context.Context, command controlapi.WorkerArtifactChunkCommand) (controlapi.WorkerArtifactChunk, error) + func (client *HTTPClient) ClaimNextWorkerTarget(ctx context.Context, command controlapi.WorkerClaimNextCommand) (controlapi.WorkerAssignment, error) + func (client *HTTPClient) CommitWorkerTerminal(ctx context.Context, command controlapi.WorkerTerminalCommand) (controlapi.WorkerTerminalResult, error) + func (client *HTTPClient) CreateWorkerArtifact(ctx context.Context, command controlapi.WorkerArtifactCreateCommand) (controlapi.WorkerArtifact, error) + func (client *HTTPClient) FinalizeWorkerArtifact(ctx context.Context, command controlapi.WorkerArtifactFinalizeCommand) (controlapi.WorkerArtifact, error) + func (client *HTTPClient) GetWorkerArtifactStatus(ctx context.Context, command controlapi.WorkerArtifactStatusCommand) (controlapi.WorkerArtifact, error) + func (client *HTTPClient) HeartbeatWorkerLease(ctx context.Context, command controlapi.WorkerLeaseHeartbeatCommand) (controlapi.WorkerLeaseHeartbeatResult, error) + func (client *HTTPClient) ReadWorkerContextPage(ctx context.Context, command controlapi.WorkerContextPageCommand) (controlapi.WorkerContextPage, error) + func (client *HTTPClient) RecordWorkerReadiness(ctx context.Context, command controlapi.WorkerReadinessCommand) (controlapi.WorkerReadinessResult, error) + type HTTPConfig struct + Client *http.Client + Endpoint string + Identity Identity + Token string + type HeartbeatFactory func(time.Duration) (<-chan time.Time, func()) + type IDSource interface + New func(kind string) string + type Identity struct + AccountID string + MachineID string + WorkerID string + type NativeRegistry struct + func NewNativeRegistry(bindings []ApprovedBinding) (*NativeRegistry, error) + func (registry *NativeRegistry) Prepare(assignment controlapi.WorkerAssignment, executionContext ExecutionContext) (runtime.RunSpec, error) + type Readiness interface + Recheck func(context.Context, controlapi.WorkerAssignment) error + Snapshot func(context.Context) (ReadinessSnapshot, error) + type ReadinessSnapshot struct + CapabilityRevisionID string + Evidence json.RawMessage + EvidenceDigest string + Revision int + type Worker struct + Adapters AdapterRegistry + Clock func() time.Time + Control Control + Heartbeat HeartbeatFactory + HeartbeatInterval time.Duration + IDs IDSource + Identity Identity + Readiness Readiness + Runtime runtime.Runtime + func (worker *Worker) RunOne(ctx context.Context) (bool, error)
Go to main page