daemon

Jul 15, 2026

Changes in this version

type EngineContext

+ ManagedHookAudit hooks.HookAuditWriter

+ ManagedHookPolicy *hooks.ManagedPolicy

Jul 14, 2026

Changes in this version

+ type ACPBackgroundDrainManager interface

+ Get func(string) (acpclient.BackgroundStatus, error)

+ List func() ([]acpclient.BackgroundStatus, error)

+ Shutdown func()

+ Start func(string, string, bool) (acpclient.BackgroundStatus, error)

+ Stop func(string) (acpclient.BackgroundStatus, error)

type CronScheduler

+ func (cs *CronScheduler) Close()

type Service

+ func NewDaemonService(ctx context.Context) (*Service, error)

+ func (s *Service) Close()

+ func (s *Service) GetACPBackgroundDrain(ctx context.Context, req *pb.ACPBackgroundDrainReq) (*pb.ACPBackgroundDrain, error)

+ func (s *Service) ListACPBackgroundDrains(ctx context.Context, _ *pb.Empty) (*pb.ACPBackgroundDrainList, error)

+ func (s *Service) StartACPBackgroundDrain(ctx context.Context, req *pb.StartACPBackgroundDrainReq) (*pb.ACPBackgroundDrain, error)

+ func (s *Service) StopACPBackgroundDrain(ctx context.Context, req *pb.ACPBackgroundDrainReq) (*pb.ACPBackgroundDrain, error)

+ type ServiceOption func(*Service)

+ func WithACPBackgroundDrainManager(manager ACPBackgroundDrainManager) ServiceOption

Jul 11, 2026

Changes in this version

type EngineContext

+ ProviderRowsMu sync.Mutex

type Service

+ func (s *Service) CommitProviderSave(ctx context.Context, req *pb.CommitProviderSaveReq) (*pb.ProviderOperation, error)

+ func (s *Service) GetProviderOperation(ctx context.Context, req *pb.GetProviderOperationReq) (*pb.ProviderOperation, error)

Jul 5, 2026

Changes in this version

type EngineContext

+ ExtensionMu sync.RWMutex

+ func (ec *EngineContext) ReloadPlugins(ctx context.Context) (*PluginReloadSummary, error)

+ type PluginReloadSummary struct

+ Agents int

+ Commands int

+ Daemons int

+ Hooks int

+ Skills int

+ Tools int

Jul 2, 2026

Changes in this version

type EngineContext

+ func (ec *EngineContext) RunHooks(ctx context.Context, event hooks.Event, data map[string]string) error

type PlanManager

+ func NewPlanManagerWithEngine(engine *EngineContext, hks *hooks.HookConfig) *PlanManager

Jul 2, 2026

Changes in this version

type Service

+ func (s *Service) AddTrustGrant(_ context.Context, req *pb.AddTrustRuleReq) (*pb.TrustState, error)

+ func (s *Service) RevokeTrustGrant(_ context.Context, req *pb.RevokeTrustGrantReq) (*pb.TrustState, error)

Jul 2, 2026

Changes in this version

type Service

+ func (s *Service) AddTrustRule(_ context.Context, req *pb.AddTrustRuleReq) (*pb.TrustState, error)

+ func (s *Service) GetTrustState(context.Context, *pb.Empty) (*pb.TrustState, error)

+ func (s *Service) ResetTrust(context.Context, *pb.Empty) (*pb.TrustState, error)

+ func (s *Service) SetTrustMode(_ context.Context, req *pb.SetTrustModeReq) (*pb.TrustState, error)

type TeamManager

+ func (tm *TeamManager) DirectMessage(teamID, toAgent, content string) error

Jul 1, 2026

Changes in this version

type CompactionRecord

+ ArchiveSessionID string

type Service

+ func (s *Service) UpdateSessionSummary(ctx context.Context, req *pb.UpdateSessionSummaryReq) (*pb.Session, error)

type SessionInfo

+ BranchSummary string

type SessionManager

+ func (sm *SessionManager) UpdateSummary(ctx context.Context, id, summary string) error

Jul 1, 2026

Changes in this version

+ type CompactionRecord struct

+ CreatedAt time.Time

+ FirstKeptMessageID string

+ ID string

+ MessagesKept int

+ MessagesRemoved int

+ Reason string

+ SessionID string

+ Summary string

type Service

+ func (s *Service) CloneSession(ctx context.Context, req *pb.CloneSessionReq) (*pb.Session, error)

+ func (s *Service) ForkSession(ctx context.Context, req *pb.ForkSessionReq) (*pb.Session, error)

+ func (s *Service) GetSessionTree(ctx context.Context, req *pb.SessionTreeReq) (*pb.SessionList, error)

+ func (s *Service) ListSessionCompactions(ctx context.Context, req *pb.SessionCompactionsReq) (*pb.SessionCompactionList, error)

+ func (s *Service) ListSessionMessages(ctx context.Context, req *pb.SessionMessagesReq) (*pb.SessionHistory, error)

+ type SessionHistoryMessage struct

+ Content string

+ CreatedAt time.Time

+ ID string

+ Role string

+ ToolCallID string

+ ToolName string

type SessionInfo

+ ForkReason string

+ ForkedFromMessageID string

+ ParentID string

+ RootID string

type SessionManager

+ func (sm *SessionManager) Clone(ctx context.Context, sourceID, reason string) (*SessionInfo, error)

+ func (sm *SessionManager) Fork(ctx context.Context, sourceID, messageID, reason string) (*SessionInfo, error)

+ func (sm *SessionManager) ListMessages(ctx context.Context, sessionID string) ([]SessionHistoryMessage, error)

+ func (sm *SessionManager) ListTree(ctx context.Context, rootOrSessionID string) ([]SessionInfo, error)

Jul 1, 2026

Changes in this version

type Service

+ func (s *Service) BlackboardList(ctx context.Context, req *pb.BlackboardListReq) (*pb.BlackboardListResp, error)

+ func (s *Service) BlackboardRead(ctx context.Context, req *pb.BlackboardReadReq) (*pb.BlackboardReadResp, error)

+ func (s *Service) BlackboardWrite(ctx context.Context, req *pb.BlackboardWriteReq) (*pb.BlackboardEntry, error)

Jul 1, 2026

Changes in this version

type EngineContext

+ SecretRedactor executor.SecretRedactor

+ SecretsRedactor *secrets.Redactor

type Service

+ func (s *Service) UpdateSessionModel(ctx context.Context, sessionID, model string) error

type SessionManager

+ func (sm *SessionManager) UpdateModel(ctx context.Context, id, model string) error

May 26, 2026

Changes in this version

+ const ProtoVersion

+ var CheckpointPath = func() string

+ func ClassifyStep(stepID string) stepComplexity

+ func CleanupPID()

+ func CleanupSocket()

+ func Compress(ctx context.Context, messages []provider.Message, preserveCount int, ...) ([]provider.Message, string, error)

+ func DBPath() string

+ func DataDir() string

+ func EnsureDataDir() error

+ func IsRunning() bool

+ func ModelForStep(stepID string, routing config.ModelRouting) string

+ func PIDPath() string

+ func ReadPID() (int, error)

+ func ReloadDaemon(newBinaryPath string) error

+ func SaveCheckpoint(cp *Checkpoint) error

+ func SendNotification(title, body string)

+ func SocketPath() string

+ func Start(ctx context.Context, debug bool) error

+ func StartBackground(debug bool) error

+ func Status() (string, error)

+ func Stop() error

+ func TriggerReload() error

+ func WritePID() error

+ type ActorManager struct

+ func NewActorManager(ctx context.Context, db *sql.DB) (*ActorManager, error)

+ func (am *ActorManager) Close(ctx context.Context) error

+ func (am *ActorManager) SpawnApproval(ctx context.Context, requestID string, gate *ApprovalGate, ...) (*actor.PID, error)

+ func (am *ActorManager) SpawnSession(ctx context.Context, sessionID, workingDir string) (*actor.PID, error)

+ type ApprovalActor struct

+ func (a *ApprovalActor) PostStop(ctx *actor.Context) error

+ func (a *ApprovalActor) PreStart(ctx *actor.Context) error

+ func (a *ApprovalActor) Receive(ctx *actor.ReceiveContext)

+ type ApprovalGate struct

+ func NewApprovalGate() *ApprovalGate

+ func (g *ApprovalGate) PendingCount() int

+ func (g *ApprovalGate) Request(requestID string) <-chan ApprovalResponse

+ func (g *ApprovalGate) Resolve(requestID string, approved bool, reason string) bool

+ func (g *ApprovalGate) WaitForResolution(ctx context.Context, approvalID string, timeout time.Duration) (*executor.ApprovalRecord, error)

+ type ApprovalRequest struct

+ Input string

+ ToolName string

+ type ApprovalResponse struct

+ Approved bool

+ Reason string

+ type AutorespondConfig struct

+ Rules []AutorespondRule

+ type AutorespondRule struct

+ Action string

+ Match string

+ Message string

+ type Autoresponder struct

+ func LoadAutoresponder(projectDir string) *Autoresponder

+ func NewAutoresponder(rules []AutorespondRule) *Autoresponder

+ func (ar *Autoresponder) Match(question string) (string, string)

+ type Checkpoint struct

+ CronJobs []CronCheckpoint

+ Providers []ProviderCheckpoint

+ Sessions []SessionCheckpoint

+ Version string

+ func ExportCheckpoint(svc *Service) (*Checkpoint, error)

+ func LoadCheckpoint() (*Checkpoint, error)

+ type CronCheckpoint struct

+ Command string

+ ID string

+ Schedule string

+ SessionID string

+ Status string

+ type CronJob struct

+ Command string

+ ID string

+ LastRun string

+ NextRun string

+ RunCount int32

+ Schedule string

+ SessionID string

+ Status string

+ type CronJobProvider struct

+ func NewCronJobProvider(cs *CronScheduler) *CronJobProvider

+ func (p *CronJobProvider) ActiveJobs() []*pb.Job

+ func (p *CronJobProvider) KillJob(id string) error

+ func (p *CronJobProvider) PauseJob(id string) error

+ func (p *CronJobProvider) ResumeJob(id string) error

+ type CronScheduler struct

+ func NewCronScheduler(db *sql.DB, onTick func(sessionID, command string)) *CronScheduler

+ func (cs *CronScheduler) Create(ctx context.Context, sessionID, schedule, command string) (CronJob, error)

+ func (cs *CronScheduler) List(ctx context.Context) ([]CronJob, error)

+ func (cs *CronScheduler) Pause(ctx context.Context, jobID string) error

+ func (cs *CronScheduler) Resume(ctx context.Context, jobID string) error

+ func (cs *CronScheduler) Start(ctx context.Context) error

+ func (cs *CronScheduler) Stop(ctx context.Context, jobID string) error

+ type EngineContext struct

+ Actors *ActorManager

+ DB *sql.DB

+ Debug bool

+ Hooks *hooks.HookConfig

+ MCPDiscoverer *mcp.Discoverer

+ MemoryStore *ratchetplugin.MemoryStore

+ ModelRouting config.ModelRouting

+ PluginAgents []agent.AgentDefinition

+ PluginCommands []plugins.Command

+ PluginDaemons []*plugins.DaemonTool

+ PluginSkills []skills.Skill

+ ProviderRegistry *ratchetplugin.ProviderRegistry

+ SecretGuard *ratchetplugin.SecretGuard

+ SecretsProvider secrets.Provider

+ ToolRegistry *ratchetplugin.ToolRegistry

+ func NewEngineContext(ctx context.Context, dbPath string) (*EngineContext, error)

+ func (ec *EngineContext) Close()

+ type FleetJobProvider struct

+ func NewFleetJobProvider(fm *FleetManager) *FleetJobProvider

+ func (p *FleetJobProvider) ActiveJobs() []*pb.Job

+ func (p *FleetJobProvider) KillJob(id string) error

+ func (p *FleetJobProvider) PauseJob(id string) error

+ func (p *FleetJobProvider) ResumeJob(id string) error

+ type FleetManager struct

+ func NewFleetManager(routing config.ModelRouting, engine *EngineContext, hks *hooks.HookConfig) *FleetManager

+ func (fm *FleetManager) FindWorker(workerID string) *pb.Agent

+ func (fm *FleetManager) GetStatus(fleetID string) (*pb.FleetStatus, error)

+ func (fm *FleetManager) KillWorker(fleetID, workerID string) error

+ func (fm *FleetManager) ListAllWorkers() []*pb.Agent

+ func (fm *FleetManager) StartFleet(ctx context.Context, req *pb.StartFleetReq, steps []string, ...) string

+ type HumanGate struct

+ func NewHumanGate() *HumanGate

+ func (hg *HumanGate) Pending(teamID string) []HumanRequestEntry

+ func (hg *HumanGate) Request(teamID, fromAgent, question string) string

+ func (hg *HumanGate) Respond(reqID, content string) error

+ func (hg *HumanGate) Wait(ctx context.Context, reqID string) (string, error)

+ type HumanRequestEntry struct

+ FromAgent string

+ ID string

+ Question string

+ TeamID string

+ Timestamp time.Time

+ type JobProvider interface

+ ActiveJobs func() []*pb.Job

+ KillJob func(id string) error

+ PauseJob func(id string) error

+ ResumeJob func(id string) error

+ type JobRegistry struct

+ func NewJobRegistry() *JobRegistry

+ func (jr *JobRegistry) KillJob(id string) error

+ func (jr *JobRegistry) ListJobs() []*pb.Job

+ func (jr *JobRegistry) PauseJob(id string) error

+ func (jr *JobRegistry) Register(jobType string, p JobProvider)

+ func (jr *JobRegistry) ResumeJob(id string) error

+ type PlanManager struct

+ func NewPlanManager(hks *hooks.HookConfig) *PlanManager

+ func (pm *PlanManager) Approve(planID string, skipSteps []string) error

+ func (pm *PlanManager) Create(sessionID, goal string, steps []*pb.PlanStep) *pb.Plan

+ func (pm *PlanManager) ForSession(sessionID string) []*pb.Plan

+ func (pm *PlanManager) Get(planID string) *pb.Plan

+ func (pm *PlanManager) Reject(planID, feedback string) error

+ func (pm *PlanManager) UpdateStep(planID, stepID, stepStatus, errMsg string) error

+ type Project struct

+ ConfigPath string

+ CreatedAt time.Time

+ Cwd string

+ ID string

+ Name string

+ Paths []string

+ Status string

+ TeamIDs []string

+ WorkDir string

+ type ProjectRegistry struct

+ func NewProjectRegistry() *ProjectRegistry

+ func (pr *ProjectRegistry) AddTeam(projectID, teamID string)

+ func (pr *ProjectRegistry) Get(id string) (*Project, error)

+ func (pr *ProjectRegistry) GetByName(name string) (*Project, error)

+ func (pr *ProjectRegistry) List() []Project

+ func (pr *ProjectRegistry) Register(name, configPath string, opts *RegisterOpts) (*Project, error)

+ func (pr *ProjectRegistry) RemoveTeam(projectID, teamID string)

+ func (pr *ProjectRegistry) SetStatus(id, status string) error

+ type ProviderCheckpoint struct

+ Alias string

+ Model string

+ Type string

+ type RegisterOpts struct

+ Cwd string

+ Paths []string

+ WorkDir string

+ type Service struct

+ func NewService(ctx context.Context) (*Service, error)

+ func (s *Service) AddProvider(ctx context.Context, req *pb.AddProviderReq) (*pb.Provider, error)

+ func (s *Service) ApprovePlan(req *pb.ApprovePlanReq, stream pb.RatchetDaemon_ApprovePlanServer) error

+ func (s *Service) AttachSession(req *pb.AttachReq, stream pb.RatchetDaemon_AttachSessionServer) error

+ func (s *Service) AttachTeam(req *pb.AttachTeamReq, stream pb.RatchetDaemon_AttachTeamServer) error

+ func (s *Service) CheckVersion(ctx context.Context, req *pb.VersionCheckReq) (*pb.VersionCheckResp, error)

+ func (s *Service) ClaimTask(_ context.Context, req *pb.TaskClaimReq) (*pb.TaskInfo, error)

+ func (s *Service) CreateCron(ctx context.Context, req *pb.CreateCronReq) (*pb.CronJob, error)

+ func (s *Service) CreateSession(ctx context.Context, req *pb.CreateSessionReq) (*pb.Session, error)

+ func (s *Service) CreateTask(_ context.Context, req *pb.TaskCreateReq) (*pb.TaskInfo, error)

+ func (s *Service) DetachSession(ctx context.Context, req *pb.DetachReq) (*pb.Empty, error)

+ func (s *Service) DirectMessage(ctx context.Context, req *pb.DirectMessageReq) (*pb.Empty, error)

+ func (s *Service) GetAgentStatus(ctx context.Context, req *pb.AgentStatusReq) (*pb.Agent, error)

+ func (s *Service) GetFleetStatus(ctx context.Context, req *pb.FleetStatusReq) (*pb.FleetStatus, error)

+ func (s *Service) GetProjectStatus(ctx context.Context, req *pb.ProjectReq) (*pb.ProjectStatus, error)

+ func (s *Service) GetTask(_ context.Context, req *pb.TaskReq) (*pb.TaskInfo, error)

+ func (s *Service) GetTeamStatus(ctx context.Context, req *pb.TeamStatusReq) (*pb.TeamStatus, error)

+ func (s *Service) Health(ctx context.Context, _ *pb.Empty) (*pb.HealthResponse, error)

+ func (s *Service) KillFleetWorker(ctx context.Context, req *pb.KillFleetWorkerReq) (*pb.Empty, error)

+ func (s *Service) KillJob(ctx context.Context, req *pb.JobReq) (*pb.Empty, error)

+ func (s *Service) KillProject(ctx context.Context, req *pb.ProjectReq) (*pb.Empty, error)

+ func (s *Service) KillSession(ctx context.Context, req *pb.KillReq) (*pb.Empty, error)

+ func (s *Service) KillTeam(ctx context.Context, req *pb.KillTeamReq) (*pb.Empty, error)

+ func (s *Service) ListAgents(ctx context.Context, _ *pb.Empty) (*pb.AgentList, error)

+ func (s *Service) ListCrons(ctx context.Context, _ *pb.Empty) (*pb.CronJobList, error)

+ func (s *Service) ListJobs(ctx context.Context, _ *pb.Empty) (*pb.JobList, error)

+ func (s *Service) ListPendingHuman(ctx context.Context, req *pb.PendingHumanReq) (*pb.PendingHumanList, error)

+ func (s *Service) ListProjects(ctx context.Context, _ *pb.Empty) (*pb.ProjectList, error)

+ func (s *Service) ListProviders(ctx context.Context, _ *pb.Empty) (*pb.ProviderList, error)

+ func (s *Service) ListSessions(ctx context.Context, _ *pb.Empty) (*pb.SessionList, error)

+ func (s *Service) ListTasks(_ context.Context, req *pb.TaskListReq) (*pb.TaskList, error)

+ func (s *Service) ListTeams(ctx context.Context, req *pb.ListTeamsReq) (*pb.TeamList, error)

+ func (s *Service) MeshStream(stream pb.RatchetDaemon_MeshStreamServer) error

+ func (s *Service) PauseCron(ctx context.Context, req *pb.CronJobReq) (*pb.Empty, error)

+ func (s *Service) PauseJob(ctx context.Context, req *pb.JobReq) (*pb.Empty, error)

+ func (s *Service) PauseProject(ctx context.Context, req *pb.ProjectReq) (*pb.Empty, error)

+ func (s *Service) RegisterMeshNode(ctx context.Context, req *pb.RegisterNodeReq) (*pb.RegisterNodeResp, error)

+ func (s *Service) RejectPlan(ctx context.Context, req *pb.RejectPlanReq) (*pb.Empty, error)

+ func (s *Service) RemoveProvider(ctx context.Context, req *pb.RemoveProviderReq) (*pb.Empty, error)

+ func (s *Service) RenameTeam(ctx context.Context, req *pb.TeamRenameReq) (*pb.Empty, error)

+ func (s *Service) RequestReload(req *pb.ReloadReq, stream pb.RatchetDaemon_RequestReloadServer) error

+ func (s *Service) RespondToHuman(ctx context.Context, req *pb.HumanResponse) (*pb.Empty, error)

+ func (s *Service) RespondToPermission(ctx context.Context, req *pb.PermissionResponse) (*pb.Empty, error)

+ func (s *Service) ResumeCron(ctx context.Context, req *pb.CronJobReq) (*pb.Empty, error)

+ func (s *Service) ResumeJob(ctx context.Context, req *pb.JobReq) (*pb.Empty, error)

+ func (s *Service) ResumeProject(ctx context.Context, req *pb.ProjectReq) (*pb.Empty, error)

+ func (s *Service) SendMessage(req *pb.SendMessageReq, stream pb.RatchetDaemon_SendMessageServer) error

+ func (s *Service) SendMessageChan(ctx context.Context, sessionID, content string) (<-chan *pb.ChatEvent, error)

+ func (s *Service) SetDefaultProvider(ctx context.Context, req *pb.SetDefaultProviderReq) (*pb.Empty, error)

+ func (s *Service) SetShutdownFunc(fn func())

+ func (s *Service) Shutdown(ctx context.Context, _ *pb.Empty) (*pb.Empty, error)

+ func (s *Service) StartFleet(req *pb.StartFleetReq, stream pb.RatchetDaemon_StartFleetServer) error

+ func (s *Service) StartProject(ctx context.Context, req *pb.StartProjectReq) (*pb.ProjectStatus, error)

+ func (s *Service) StartTeam(req *pb.StartTeamReq, stream pb.RatchetDaemon_StartTeamServer) error

+ func (s *Service) SteerTeam(ctx context.Context, req *pb.SteerTeamReq) (*pb.Empty, error)

+ func (s *Service) StopCron(ctx context.Context, req *pb.CronJobReq) (*pb.Empty, error)

+ func (s *Service) TeamAddAgent(ctx context.Context, req *pb.TeamAddAgentReq) (*pb.Empty, error)

+ func (s *Service) TeamRemoveAgent(ctx context.Context, req *pb.TeamRemoveAgentReq) (*pb.Empty, error)

+ func (s *Service) TestProvider(ctx context.Context, req *pb.TestProviderReq) (*pb.TestProviderResult, error)

+ func (s *Service) UpdateProviderModel(ctx context.Context, req *pb.UpdateProviderModelReq) (*pb.Empty, error)

+ func (s *Service) UpdateTask(_ context.Context, req *pb.TaskUpdateReq) (*pb.TaskInfo, error)

+ type SessionActor struct

+ func (a *SessionActor) PostStop(ctx *actor.Context) error

+ func (a *SessionActor) PreStart(ctx *actor.Context) error

+ func (a *SessionActor) Receive(ctx *actor.ReceiveContext)

+ type SessionBroadcaster struct

+ func NewSessionBroadcaster() *SessionBroadcaster

+ func (b *SessionBroadcaster) Publish(sessionID string, event *pb.ChatEvent)

+ func (b *SessionBroadcaster) Subscribe(sessionID string) (<-chan *pb.ChatEvent, string)

+ func (b *SessionBroadcaster) Unsubscribe(sessionID, subID string)

+ type SessionCheckpoint struct

+ ID string

+ Model string

+ Name string

+ Provider string

+ Status string

+ WorkingDir string

+ type SessionInfo struct

+ Agents int

+ CreatedAt time.Time

+ ID string

+ Model string

+ Name string

+ Provider string

+ Status string

+ WorkingDir string

+ type SessionJobProvider struct

+ func NewSessionJobProvider(sm *SessionManager) *SessionJobProvider

+ func (p *SessionJobProvider) ActiveJobs() []*pb.Job

+ func (p *SessionJobProvider) KillJob(id string) error

+ func (p *SessionJobProvider) PauseJob(id string) error

+ func (p *SessionJobProvider) ResumeJob(id string) error

+ type SessionManager struct

+ func NewSessionManager(db *sql.DB) *SessionManager

+ func (sm *SessionManager) CleanupStale(ctx context.Context, maxAge time.Duration) (int64, error)

+ func (sm *SessionManager) Create(ctx context.Context, workingDir, provider, model, initialPrompt string) (*SessionInfo, error)

+ func (sm *SessionManager) Get(ctx context.Context, id string) (*SessionInfo, error)

+ func (sm *SessionManager) Kill(ctx context.Context, id string) error

+ func (sm *SessionManager) List(ctx context.Context) ([]SessionInfo, error)

+ func (sm *SessionManager) Publish(sessionID string, event any)

+ func (sm *SessionManager) SessionsInDir(dir string) []string

+ func (sm *SessionManager) SetBackground(ctx context.Context, id string) error

+ func (sm *SessionManager) Subscribe(sessionID string) chan any

+ type SessionMessage struct

+ Content string

+ Role string

+ type TeamJobProvider struct

+ func NewTeamJobProvider(tm *TeamManager) *TeamJobProvider

+ func (p *TeamJobProvider) ActiveJobs() []*pb.Job

+ func (p *TeamJobProvider) KillJob(id string) error

+ func (p *TeamJobProvider) PauseJob(id string) error

+ func (p *TeamJobProvider) ResumeJob(id string) error

+ type TeamManager struct

+ func NewTeamManager(engine *EngineContext, hks *hooks.HookConfig) *TeamManager

+ func (tm *TeamManager) AddAgent(teamID, agentSpec string) error

+ func (tm *TeamManager) AttachTeam(teamID, mode string) (string, <-chan *pb.TeamActivityEvent, error)

+ func (tm *TeamManager) DetachTeam(teamID, observerID string)

+ func (tm *TeamManager) FindAgent(agentID string) *pb.Agent

+ func (tm *TeamManager) GetStatus(teamID string) (*pb.TeamStatus, error)

+ func (tm *TeamManager) KillAgent(teamID string) error

+ func (tm *TeamManager) ListAllAgents() []*pb.Agent

+ func (tm *TeamManager) ListTeams(projectID string) []*pb.TeamStatus

+ func (tm *TeamManager) RemoveAgent(teamID, agentName string) error

+ func (tm *TeamManager) Rename(teamID, newName string) error

+ func (tm *TeamManager) StartMeshTeam(ctx context.Context, task string, configs []mesh.NodeConfig, ...) (string, <-chan *pb.TeamEvent)

+ func (tm *TeamManager) StartTeam(ctx context.Context, req *pb.StartTeamReq) (string, <-chan *pb.TeamEvent)

+ type TokenTracker struct

+ func NewTokenTracker() *TokenTracker

+ func (t *TokenTracker) AddTokens(sessionID string, input, output int)

+ func (t *TokenTracker) Reset(sessionID string)

+ func (t *TokenTracker) ShouldCompress(sessionID string, threshold float64, modelLimit int) bool

+ func (t *TokenTracker) Total(sessionID string) int

+ type WorkerCostEntry struct

+ Complexity string

+ Model string

+ StepID string

+ WorkerName string

+ func FleetCostBreakdown(steps []string, routing config.ModelRouting) []WorkerCostEntry