runneragent

type Config struct {
	RunnerID  string
	Substrate substrate.Substrate
	// HoldsSandbox reports whether a local ref is a sandbox this runner created
	// and durably holds. Any other ref reaches the substrate only when the
	// substrate proves it a sandbox created for this runner.
	HoldsSandbox func(string) bool
	// BeforeCreate durably establishes a unique creation intent and live lease.
	// Nil proves a NEW run; every existing or ambiguous intent must refuse.
	BeforeCreate func(context.Context, runner.SandboxSpec) error
	// Created durably binds the run to its local ref before success is reported.
	Created func(context.Context, runner.SandboxSpec, string) error
	// CreateFailed durably contains a failed NEW intent, including partial
	// provisioning. It must retain output and retry proxy containment locally.
	CreateFailed func(context.Context, runner.SandboxSpec) error
	// BeforeRefCall enforces offline/lease policy before a state-changing call.
	// The generation is the explicit Exec/Start CALL identity, zero otherwise.
	BeforeRefCall func(context.Context, string, string, uuid.UUID) error
	// AfterRefCall persists successful state changes with the same generation.
	// The exec id is populated for MethodExec, empty otherwise. Persistence
	// failures must contain the proxy before returning their error.
	AfterRefCall func(context.Context, string, string, string, uuid.UUID) error
	// MutationFinished runs after every admitted mutation, including substrate
	// failures, output rollback and detached persistence. Create supplies run ID;
	// ref calls supply the checked local ref and explicit execution generation.
	MutationFinished func(context.Context, string, string, uuid.UUID, uuid.UUID, error) error
	// ExecutionResult recovers a durable intent/handle without executing it again.
	ExecutionResult func(context.Context, string, uuid.UUID) (runnerwire.ExecutionResult, error)
	// Streams serves attach/exec/resize/wait/output, with ref validation of its own.
	Streams      func(context.Context, *runnerwire.Peer, uint32, string, json.RawMessage) (any, error)
	Output       func(uuid.UUID) (io.Writer, error)
	BindOutput   func(uuid.UUID, string) error
	ForgetOutput func(uuid.UUID) error
	// CheckSelftest admits a BYOI selftest under the task's unattempted
	// generation without spending it; nil refuses the selftest.
	CheckSelftest func(context.Context, string, uuid.UUID) error
	// Resident is the runner_resident adapter; nil refuses both verbs and any
	// create or proxy replacement that names a resident grant.
	Resident *Resident
}

type Dispatcher struct {
	// contains filtered or unexported fields
}

type Keystore struct {
	Set    func(account, value string) error
	Get    func(account string) (string, error)
	Delete func(account string) error
	// DeleteAll deletes every item under this runner's service.
	DeleteAll func() error
	// Precheck refuses a value the keystore cannot take before any entry is
	// written or any keystore call is made.
	Precheck func(account, value string) error
}

type Resident struct {
	// contains filtered or unexported fields
}