department

Sep 30, 2026

Changes in this version

+ var ErrResidencyStillHeld = errors.New(...)

Sep 30, 2026

Changes in this version

type Capabilities

+ Recovery Recovery

+ type Recovery struct

+ AttemptCloser bool

+ PersistenceFaults bool

+ func (r Recovery) Complete() bool

Sep 29, 2026

Changes in this version

+ type LiveOptions struct

+ IncludeReasoning bool

+ IncludeToolSteps bool

+ type LiveOptionsSubscriber interface

+ SubscribeLivePublicWith func(context.Context, LiveOptions) (<-chan LivePublication, error)

Sep 26, 2026

Changes in this version

+ type ReasoningPublicationSubscriber interface

+ SubscribeLivePublicWithReasoning func(context.Context) (<-chan LivePublication, error)

Sep 26, 2026

Changes in this version

+ type LivePublication struct

+ Enduring *sessionwire.EnduringPublication

+ Ephemeral *sessionwire.EphemeralPublication

+ Terminal error

+ type LivePublicationSubscriber interface

+ SubscribeLivePublic func(context.Context) (<-chan LivePublication, error)

Sep 25, 2026

Changes in this version

type RuntimeCommand

+ Metadata sessionwire.MessageMetadata

+ Principal *sessionwire.Principal

Sep 23, 2026

Changes in this version

+ var ErrNoPersistenceFaults = errors.New(...)

+ var ErrPrefixCommitted = errors.New(...)

+ type PersistenceFaults interface

+ AbandonResidency func(context.Context) error

+ PersistenceFault func() error

+ PersistenceFaulted func() <-chan struct{}

Sep 19, 2026

Changes in this version

+ var ErrRigSessionIdentity = errors.New(...)

type CreateRequest

+ RigSessionID uuid.UUID

type RigCreateRequest

+ RigSessionID uuid.UUID

Sep 13, 2026

Changes in this version

+ const MaxCompatibilityIDBytes

+ var ErrDispositionUnsupported = errors.New(...)

+ var ErrEnduringEffect = errors.New(...)

+ var ErrNoAttemptCloser = errors.New(...)

+ var ErrNoRigSession = errors.New("the rig reported success and returned no session")

+ func RigSessionID(runtime Runtime) (uuid.UUID, bool)

+ type AttemptCloser interface

+ CloseAttempt func(ctx context.Context, command sessionwire.CommandID, runtimeCommand uuid.UUID, ...) error

+ type Capabilities struct

+ AdmissionWeight uint64

+ CaptureSafety CaptureSafety

+ RequiresCheckpoint bool

+ RequiresWorkspace bool

+ SupportsDedicated bool

+ SupportsPooled bool

+ func (c Capabilities) PermittedPlacements() []sessionwire.HostPlacement

+ func (c Capabilities) PoolingPermitted() bool

+ func (c Capabilities) Validate() error

+ type CaptureSafety string

+ const CaptureSafetyBoundedMaterialized

+ const CaptureSafetyStreaming

+ const CaptureSafetyUnboundedMaterialized

+ const CaptureSafetyUnknown

+ type CommandApplier interface

+ ApplyCommand func(context.Context, RuntimeCommand) error

+ type CompatibilityID string

+ func (id CompatibilityID) Validate() error

+ type CompatibilityMismatchError struct

+ AgentID sessionwire.AgentID

+ Durable CompatibilityID

+ SessionID sessionwire.SessionID

+ Target CompatibilityID

+ func (e *CompatibilityMismatchError) Error() string

+ func (e *CompatibilityMismatchError) ErrorCode() sessionwire.ErrorCode

+ type CreateRequest struct

+ AgentID sessionwire.AgentID

+ Placement sessionwire.HostPlacement

+ SessionID sessionwire.SessionID

+ Storage StorageContext

+ TenantID sessionwire.TenantID

+ WorkspaceRoot string

+ type DefinitionErrorCode string

+ const DefinitionErrorCodeDuplicateAgent

+ const DefinitionErrorCodeInvalidAgentID

+ const DefinitionErrorCodeInvalidCompatibilityID

+ const DefinitionErrorCodeNoPlacement

+ const DefinitionErrorCodeNoRegistrations

+ const DefinitionErrorCodeNoTarget

+ const DefinitionErrorCodePooledUnsafeCapture

+ const DefinitionErrorCodeZeroAdmissionWeight

+ type Department struct

+ func New(registrations []Registration) (*Department, error)

+ func (d *Department) AgentIDs() []sessionwire.AgentID

+ func (d *Department) Len() int

+ func (d *Department) Target(agent sessionwire.AgentID) (LaunchTarget, error)

+ type Identity interface

+ AgentID func() sessionwire.AgentID

+ SessionID func() sessionwire.SessionID

+ type IdleWaiter interface

+ WaitIdle func(context.Context) error

+ type IncapableRuntimeError struct

+ AgentID sessionwire.AgentID

+ Missing []string

+ SessionID sessionwire.SessionID

+ func (e *IncapableRuntimeError) Error() string

+ type InvalidCapabilitiesError struct

+ Code DefinitionErrorCode

+ Reason string

+ func (e *InvalidCapabilitiesError) Error() string

+ type InvalidCompatibilityIDError struct

+ Reason string

+ func (e *InvalidCompatibilityIDError) Error() string

+ type InvalidDepartmentError struct

+ AgentID sessionwire.AgentID

+ Cause error

+ Code DefinitionErrorCode

+ Reason string

+ func (e *InvalidDepartmentError) Error() string

+ func (e *InvalidDepartmentError) Unwrap() error

+ type LaunchTarget interface

+ Capabilities func() Capabilities

+ CompatibilityID func() CompatibilityID

+ Create func(context.Context, CreateRequest) (Runtime, error)

+ Restore func(context.Context, RestoreRequest) (Runtime, error)

+ func NewRigTarget(rig Rig, compatibility CompatibilityID, capabilities Capabilities) (LaunchTarget, error)

+ type LeaseEpochReporter interface

+ LeaseEpoch func() (epoch uint64, held bool)

+ type Liveness interface

+ Done func() <-chan struct{}

+ type PublicationSubscriber interface

+ SubscribeCommitted func(context.Context, sessionwire.EventID) (<-chan sessionwire.EnduringPublication, error)

+ type Registration struct

+ AgentID sessionwire.AgentID

+ Target LaunchTarget

+ type Releaser interface

+ ReleaseResidency func(context.Context) error

+ type RestoreRequest struct

+ AgentID sessionwire.AgentID

+ CompatibilityID CompatibilityID

+ Placement sessionwire.HostPlacement

+ RigSessionID uuid.UUID

+ SessionID sessionwire.SessionID

+ Storage StorageContext

+ TenantID sessionwire.TenantID

+ WorkspaceRoot string

+ type Rig interface

+ NewSession func(context.Context, RigCreateRequest) (RigSession, error)

+ RestoreSession func(context.Context, uuid.UUID, RigRestoreRequest) (RigSession, error)

+ type RigCreateRequest struct

+ AgentID sessionwire.AgentID

+ Placement sessionwire.HostPlacement

+ SessionID sessionwire.SessionID

+ Storage StorageContext

+ TenantID sessionwire.TenantID

+ WorkspaceRoot string

+ type RigLaunchError struct

+ AgentID sessionwire.AgentID

+ Cause error

+ Operation string

+ SessionID sessionwire.SessionID

+ func (e *RigLaunchError) Error() string

+ func (e *RigLaunchError) Unwrap() error

+ type RigRestoreRequest struct

+ AgentID sessionwire.AgentID

+ Placement sessionwire.HostPlacement

+ SessionID sessionwire.SessionID

+ Storage StorageContext

+ TenantID sessionwire.TenantID

+ WorkspaceRoot string

+ type RigSession interface

+ ID func() uuid.UUID

+ type Runtime interface

+ type RuntimeCommand struct

+ AttemptID string

+ CommandID sessionwire.CommandID

+ Kind string

+ Payload []byte

+ PayloadRef sessionwire.ObjectReference

+ RuntimeCommandID uuid.UUID

+ type StorageContext struct

+ Namespace string

+ type UnknownAgentError struct

+ AgentID sessionwire.AgentID

+ func (e *UnknownAgentError) Error() string

+ func (e *UnknownAgentError) ErrorCode() sessionwire.ErrorCode