pkg

Oct 17, 2026

Changes in this version

+ const MountNotAllowedPrefix

+ const SecretContainerDir

+ const TeamVaultCommand

+ const TeamVaultConfigEnv

+ func DefaultSecretDir() string

+ func DefaultTeamVaultConfigPath() string

+ func RemoveSecretFiles(ctx context.Context, dir string, workerID WorkerID) error

+ func ValidateMounts(ctx context.Context, allowlist MountAllowlist, mounts []Mount) error

+ func ValidateSecrets(ctx context.Context, secrets []Secret) error

type CreateRequest

+ Mounts []Mount

+ Secrets []Secret

type DockerConfig

+ MountAllowlist MountAllowlist

+ SecretDir string

+ TeamVault TeamVaultResolver

type KubernetesConfig

+ TeamVault TeamVaultResolver

+ type Mount struct

+ ContainerPath string

+ HostPath string

+ ReadOnly bool

+ Volume string

+ type MountAllowlist []string

+ func ParseMountAllowlist(ctx context.Context, value string) (MountAllowlist, error)

+ func (a MountAllowlist) Allows(hostPath string) bool

+ type ResolvedSecret struct

+ Name string

+ Value string

+ type Secret struct

+ Name string

+ TeamVaultKey string

+ type SecretMount struct

+ HostPath string

+ Name string

+ func WriteSecretFiles(ctx context.Context, dir string, workerID WorkerID, secrets []ResolvedSecret) ([]SecretMount, error)

+ type TeamVaultResolver interface

+ Resolve func(ctx context.Context, key string) (string, error)

+ func NewTeamVaultResolver() TeamVaultResolver

Oct 17, 2026

Changes in this version

+ const DefaultLocalTasksDir

+ const DefaultWeztermBinary

+ func DefaultLocalStateFile(ctx context.Context) (string, error)

type Backend

+ const BackendLocal

+ type LocalConfig struct

+ ClaudeScript string

+ VaultDir string

+ WindowID string

+ type LocalWorker struct

+ CreateSessionID string

+ GuiID string

+ PaneID string

+ SessionID string

+ Task TaskName

+ WorkerID WorkerID

+ type WeztermClient interface

+ GuiID func(ctx context.Context) (string, error)

+ KillPane func(ctx context.Context, guiID string, paneID string) error

+ PaneIDs func(ctx context.Context, guiID string) ([]string, error)

+ Spawn func(ctx context.Context, guiID string, windowID string, inner string) (string, error)

+ func NewWeztermCLIClient(binary string) WeztermClient

type Worker

+ PaneID string

+ SessionID string

type WorkerBackend

+ func NewLocalBackend(client WeztermClient, store WorkerStore, config LocalConfig) WorkerBackend

+ type WorkerStore interface

+ List func(ctx context.Context) ([]LocalWorker, error)

+ Save func(ctx context.Context, workers []LocalWorker) error

+ func NewJSONWorkerStore(path string) WorkerStore

Oct 14, 2026

Changes in this version

type CreateRequest

+ Env map[string]string

Oct 14, 2026

Changes in this version

type EgressDestination

+ PodLabels map[string]string

Oct 13, 2026

Changes in this version

type KubernetesConfig

+ WorkerPriorityClass string

Oct 13, 2026

Changes in this version

+ type EgressDestination struct

+ Namespace string

+ Port int32

+ func ParseEgressDestinations(ctx context.Context, value string) ([]EgressDestination, error)

type KubernetesClient

+ CreateNetworkPolicy func(ctx context.Context, policy *networkingv1.NetworkPolicy) error

type KubernetesConfig

+ EgressAllow []EgressDestination

type WorkerResourceBuilder

+ BuildNetworkPolicy func(owner agentv1.Config) *networkingv1.NetworkPolicy

Oct 13, 2026

Changes in this version

+ const DefaultKubernetesIngressClassName

+ const DefaultKubernetesTemplateConfig

+ type KubernetesClient interface

+ CreateConfig func(ctx context.Context, config *agentv1.Config) (*agentv1.Config, error)

+ CreateIngress func(ctx context.Context, ingress *networkingv1.Ingress) error

+ CreateSecret func(ctx context.Context, secret *corev1.Secret) error

+ CreateService func(ctx context.Context, service *corev1.Service) error

+ DeleteConfig func(ctx context.Context, name string) error

+ GetConfig func(ctx context.Context, name string) (*agentv1.Config, error)

+ GetSecret func(ctx context.Context, name string) (*corev1.Secret, error)

+ ListConfigs func(ctx context.Context, labelSelector string) ([]agentv1.Config, error)

+ func NewInClusterKubernetesClient(ctx context.Context, namespace string) (KubernetesClient, error)

+ type KubernetesConfig struct

+ AgentNameBase string

+ IngressClassName string

+ IngressDomain string

+ Namespace string

+ TLSSecretName string

+ TemplateConfig string

+ func DefaultKubernetesConfig() KubernetesConfig

type WorkerBackend

+ func NewKubernetesBackend(client KubernetesClient, builder WorkerResourceBuilder, templateConfig string) WorkerBackend

+ type WorkerResourceBuilder interface

+ A2AURL func(name string) string

+ BuildConfig func(template agentv1.Config, workerID WorkerID, task TaskName) *agentv1.Config

+ BuildIngress func(owner agentv1.Config) *networkingv1.Ingress

+ BuildSecret func(owner agentv1.Config, template corev1.Secret, token string) *corev1.Secret

+ BuildService func(owner agentv1.Config) *corev1.Service

+ func NewWorkerResourceBuilder(config KubernetesConfig) WorkerResourceBuilder

Oct 13, 2026

Changes in this version

+ const AuthorizationHeader

+ type Auth struct

+ func NewAuthToken(token string) Auth

+ func (a Auth) Wrap(next http.Handler) http.Handler

Oct 13, 2026

Changes in this version

+ const DefaultAgentNameBase

+ const DefaultAllowedTools

+ const DefaultAnthropicModel

+ const DefaultDockerImage

+ const DefaultPortEnd

+ const DefaultPortStart

+ type DockerClient interface

+ Run func(ctx context.Context, args []string, extraEnv []string) (string, error)

+ func NewDockerCLIClient() DockerClient

+ type DockerConfig struct

+ AgentNameBase string

+ AllowedTools string

+ Image string

+ Model string

+ PortEnd int

+ PortStart int

+ func DefaultDockerConfig() DockerConfig

+ type PortProber interface

+ IsFree func(ctx context.Context, port int) bool

+ func NewTCPPortProber() PortProber

type WorkerBackend

+ func NewDockerBackend(client DockerClient, prober PortProber, config DockerConfig) WorkerBackend

Oct 13, 2026

Changes in this version

+ const A2APath

+ const AgentCardPath

+ func NewA2AExecutor(provider BackendProvider, backend Backend) a2asrv.AgentExecutor

+ func NewA2AHandler(executor a2asrv.AgentExecutor) http.Handler

+ func NewAgentCard(config AgentCardConfig) *a2a.AgentCard

+ func NewAgentCardHandler(card *a2a.AgentCard) http.Handler

+ type AgentCardConfig struct

+ Name string

+ PublicURL string

type Backend

+ const BackendDocker

+ const BackendKubernetes

+ type BackendProvider interface

+ Get func(ctx context.Context, backend Backend) (WorkerBackend, error)

+ func NewBackendProvider(docker WorkerBackend, kubernetes WorkerBackend) BackendProvider

+ type StubWorkerBackend struct

+ func NewStubWorkerBackend() *StubWorkerBackend

+ func (s *StubWorkerBackend) Create(ctx context.Context, req CreateRequest) (*CreateResponse, error)

+ func (s *StubWorkerBackend) List(ctx context.Context) (*ListResponse, error)

+ func (s *StubWorkerBackend) Stop(ctx context.Context, req StopRequest) (*StopResponse, error)

+ type WorkerBackend interface

+ Create func(ctx context.Context, req CreateRequest) (*CreateResponse, error)

+ List func(ctx context.Context) (*ListResponse, error)

+ Stop func(ctx context.Context, req StopRequest) (*StopResponse, error)

Oct 13, 2026

Changes in this version

+ type Backend string

+ type ControlRequest struct

+ Create *CreateRequest

+ Operation Operation

+ Stop *StopRequest

+ type ControlResponse struct

+ Create *CreateResponse

+ List *ListResponse

+ Operation Operation

+ Stop *StopResponse

+ type CreateRequest struct

+ Task TaskName

+ type CreateResponse struct

+ Token string

+ Worker Worker

+ type ListResponse struct

+ Workers []Worker

+ type Operation string

+ const OperationCreate

+ const OperationList

+ const OperationStop

+ type StopRequest struct

+ WorkerID WorkerID

+ type StopResponse struct

+ Worker Worker

+ type TaskName string

+ type Worker struct

+ A2AURL string

+ Backend Backend

+ State WorkerState

+ Task TaskName

+ WorkerID WorkerID

+ type WorkerID string

+ type WorkerState string

+ const WorkerStateRunning

+ const WorkerStateStopped

+ const WorkerStateUnknown