controlapp

Sep 9, 2026

Changes in this version

+ const EcosystemGitHubAPI

+ const EcosystemGitHubContent

+ const EcosystemGitHubGit

+ const EcosystemGo

+ const EcosystemNPM

+ const EcosystemPyPI

+ func DefaultDeveloperEgressHosts() []string

+ func GitHubGitEgressHosts() []string

type AgentCredentialStore

+ ConditionalRevokeAgentCredentials func(ctx context.Context, user control.ActorID, provider string, expected uint64) (uint64, error)

+ type EgressHost struct

+ Ecosystem string

+ Host string

+ Reason string

+ func DefaultDeveloperEgress() []EgressHost

type FleetOptions

+ DefaultEgress *[]string

Sep 8, 2026

Changes in this version

+ var ErrAgentCredentialStale error = &agentRefusal

+ type AgentHomeSeedFile struct

+ Contents string

+ Name string

type AgentProvider

+ SeedFiles []AgentHomeSeedFile

Sep 5, 2026

Changes in this version

+ const AgentCredentialSetMaxBytes

+ const HomeMountPath

+ var EnableTestAgentProvider bool

+ var ErrAgentCredentialNotYours error = &agentRefusal

+ var ErrAgentCredentialTooLarge error = &agentRefusal

+ var ErrAgentCredentialUnreadable error = &agentRefusal

+ var ErrAgentCredentialUnwritable error = &agentRefusal

+ var ErrAgentFileNotAllowed error = &agentRefusal

+ var ErrAgentMembershipGone error = &agentRefusal

+ var ErrAgentSessionHasNoCreator error = &agentRefusal

+ var ErrUnknownAgentProvider error = &agentRefusal

+ func AgentHomeVolume(ws control.WorkspaceID, creator control.ActorID) string

+ func AgentRefusalSentence(err error) (string, bool)

+ func AgentsEnv(providers []AgentProvider) map[string]string

+ type AgentCredentialOption func(*AgentCredentialService)

+ func WithAgentPlacement(p control.PlacementScope) AgentCredentialOption

+ func WithAgentWorkspaces(l AgentWorkspaceLister) AgentCredentialOption

+ type AgentCredentialService struct

+ func NewAgentCredentialService(store AgentCredentialStore, authz control.Authorizer, ...) *AgentCredentialService

+ func (s *AgentCredentialService) AnswerFetch(ctx context.Context, row control.Session, provider string) (AgentCredentialSet, error)

+ func (s *AgentCredentialService) AnswerPut(ctx context.Context, row control.Session, provider string, ...) (uint64, error)

+ func (s *AgentCredentialService) List(ctx context.Context, sc control.Scope) ([]AgentCredentialStatus, error)

+ func (s *AgentCredentialService) Logout(ctx context.Context, sc control.Scope, provider string) error

+ func (s *AgentCredentialService) Withdraw(ctx context.Context, ws control.WorkspaceID, user control.ActorID) error

+ type AgentCredentialSet struct

+ Files map[string][]byte

+ Version uint64

+ type AgentCredentialStatus struct

+ Provider string

+ UpdatedAt time.Time

+ Version uint64

+ type AgentCredentialStore interface

+ FetchAgentCredentials func(ctx context.Context, user control.ActorID, provider string) (AgentCredentialSet, error)

+ ListAgentCredentials func(ctx context.Context, user control.ActorID) ([]AgentCredentialStatus, error)

+ PutAgentCredentials func(ctx context.Context, user control.ActorID, provider string, ...) (uint64, error)

+ RevokeAgentCredentials func(ctx context.Context, user control.ActorID, provider string) error

+ type AgentProvider struct

+ Egress []string

+ Files []string

+ HomeEnv string

+ HomeVar string

+ LoginCmd []string

+ Name string

+ func AgentProviders() []AgentProvider

+ type AgentWorkspaceLister interface

+ AgentWorkspaces func(ctx context.Context, user control.ActorID) ([]control.WorkspaceID, error)

Sep 3, 2026

Changes in this version

+ var ErrRunnerRefused = fmt.Errorf("controlapp: runner refused the command: %w", control.ErrUnavailable)

+ type AttachmentOptions struct

+ Authorizer control.Authorizer

+ Broker control.AttachmentBroker

+ Clock control.Clock

+ Events control.EventRecorder

+ IDs control.IDGenerator

+ MaxTransferBytes int64

+ Policy AttachmentPolicy

+ Sessions control.SessionRepository

+ Transport control.RunnerTransport

+ UnitOfWork control.UnitOfWork

+ type AttachmentPolicy interface

+ AuthorizeAttachment func(context.Context, control.Scope, control.Resource, control.AttachmentMode) error

+ type AttachmentService struct

+ func NewAttachmentService(opts AttachmentOptions) (*AttachmentService, error)

+ func (s *AttachmentService) AttachTerminal(ctx context.Context, scope control.Scope, cmd control.AttachTerminal, ...) error

+ func (s *AttachmentService) PullWorkspace(ctx context.Context, scope control.Scope, cmd control.PullWorkspace) error

+ func (s *AttachmentService) PushWorkspace(ctx context.Context, scope control.Scope, cmd control.PushWorkspace) error

+ func (s *AttachmentService) WorkspaceDiff(ctx context.Context, scope control.Scope, cmd control.WorkspaceDiff) (workspace.DiffAnswer, error)

+ type EnvironmentOptions struct

+ Authorizer control.Authorizer

+ Clock control.Clock

+ Environments control.EnvironmentRepository

+ Events control.EventRecorder

+ IDs control.IDGenerator

+ UnitOfWork control.UnitOfWork

+ type EnvironmentService struct

+ func NewEnvironmentService(o EnvironmentOptions) (*EnvironmentService, error)

+ func (s *EnvironmentService) CreateEnvironment(ctx context.Context, scope control.Scope, cmd control.CreateEnvironment) (control.Environment, error)

+ func (s *EnvironmentService) DeleteEnvironment(ctx context.Context, scope control.Scope, cmd control.DeleteEnvironment) error

+ func (s *EnvironmentService) GetEnvironment(ctx context.Context, scope control.Scope, id control.EnvironmentID) (control.Environment, error)

+ func (s *EnvironmentService) ListEnvironments(ctx context.Context, scope control.Scope, q control.EnvironmentQuery) (control.EnvironmentPage, error)

+ func (s *EnvironmentService) UpdateEnvironment(ctx context.Context, scope control.Scope, cmd control.UpdateEnvironment) (control.Environment, error)

+ type FleetOptions struct

+ Authorizer control.Authorizer

+ Checkpoints control.CheckpointLocator

+ Clock control.Clock

+ DefaultInitTimeoutSec int

+ DefaultSetupTimeoutSec int

+ Environments control.EnvironmentRepository

+ Events control.EventRecorder

+ Fleet control.FleetRepository

+ IDs control.IDGenerator

+ LaunchMaterial LaunchMaterialResolver

+ Pools control.PoolResolver

+ SafetyInterval time.Duration

+ Sessions control.SessionRepository

+ Transport control.RunnerTransport

+ UnitOfWork control.UnitOfWork

+ type FleetService struct

+ func NewFleetService(opts FleetOptions) (*FleetService, error)

+ func (s *FleetService) ApplyRunnerEvent(ctx context.Context, event control.RunnerEvent) error

+ func (s *FleetService) ListRunners(ctx context.Context, scope control.Scope, q control.RunnerQuery) (control.RunnerPage, error)

+ func (s *FleetService) ReconcileRunner(ctx context.Context, snap control.RunnerSnapshot) (control.ReconcileResult, error)

+ func (s *FleetService) RegisterRunner(ctx context.Context, r control.RunnerRegistration) (control.RunnerRegistrationResult, error)

+ func (s *FleetService) Run(ctx context.Context) error

+ func (s *FleetService) Wake(pool control.PoolID)

+ type LaunchMaterial struct

+ EgressAllow []string

+ Environment map[string]string

+ GitAuthorEmail string

+ GitAuthorName string

+ Repos []runner.RepoSpec

+ type LaunchMaterialResolver interface

+ ResolveLaunchMaterial func(context.Context, control.Session, *control.Environment) (LaunchMaterial, error)

+ type SessionOptions struct

+ Authorizer control.Authorizer

+ Clock control.Clock

+ Environments control.EnvironmentRepository

+ Events control.EventRecorder

+ Fleet control.FleetRepository

+ IDs control.IDGenerator

+ Pools control.PoolResolver

+ Sessions control.SessionRepository

+ Transport control.RunnerTransport

+ UnitOfWork control.UnitOfWork

+ Wake func(control.PoolID)

+ type SessionService struct

+ func NewSessionService(o SessionOptions) (*SessionService, error)

+ func (s *SessionService) CreateSession(ctx context.Context, scope control.Scope, cmd control.CreateSession) (control.Session, error)

+ func (s *SessionService) DeleteSession(ctx context.Context, scope control.Scope, cmd control.DeleteSession) error

+ func (s *SessionService) GetSession(ctx context.Context, scope control.Scope, id control.SessionID) (control.Session, error)

+ func (s *SessionService) ListSessions(ctx context.Context, scope control.Scope, q control.SessionQuery) (control.SessionPage, error)

+ func (s *SessionService) ResumeSession(ctx context.Context, scope control.Scope, cmd control.ResumeSession) (control.Session, error)

+ func (s *SessionService) SnapshotSession(ctx context.Context, scope control.Scope, cmd control.SnapshotSession) (control.Checkpoint, error)

+ func (s *SessionService) SuspendSession(ctx context.Context, scope control.Scope, cmd control.SuspendSession) (control.Session, error)