Documentation
¶
Index ¶
- type HealthCheckReport
- type HealthChecker
- type MachineMonitor
- type MachineMonitorCollector
- type MachineMonitorReport
- type RetryResult
- type RetryService
- type RuntimeLauncher
- func (l *RuntimeLauncher) Close(ctx context.Context) error
- func (l *RuntimeLauncher) ConfigureGitHubCredentials(resolver githubauthservice.TokenResolver)
- func (l *RuntimeLauncher) ConfigureMetrics(metrics provider.MetricsProvider)
- func (l *RuntimeLauncher) ConfigurePlatformEnvironment(apiURL string, agentPlatform runtimeAgentPlatform)
- func (l *RuntimeLauncher) ConfigureRuntimeState(store *RuntimeStateStore)
- func (l *RuntimeLauncher) RunTick(ctx context.Context) error
- type RuntimeStateStore
- type Scheduler
- type TickReport
- type TicketWorkspaceResetConflictError
- type TicketWorkspaceResetService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HealthCheckReport ¶
type HealthCheckReport struct {
ClaimsChecked int `json:"claims_checked"`
StalledClaims int `json:"stalled_claims"`
AgentsReleased int `json:"agents_released"`
}
HealthCheckReport summarizes the orchestrator health snapshot.
type HealthChecker ¶
type HealthChecker struct {
// contains filtered or unexported fields
}
HealthChecker inspects orchestrator state and reports unhealthy agents or tickets.
func NewHealthChecker ¶
func NewHealthChecker(client *ent.Client, logger *slog.Logger) *HealthChecker
NewHealthChecker constructs a health checker for the orchestrator runtime.
func (*HealthChecker) ConfigureEvents ¶
func (h *HealthChecker) ConfigureEvents(events provider.EventProvider)
func (*HealthChecker) ConfigureRuntimeState ¶
func (h *HealthChecker) ConfigureRuntimeState(store *RuntimeStateStore)
func (*HealthChecker) Run ¶
func (h *HealthChecker) Run(ctx context.Context) (HealthCheckReport, error)
Run evaluates the current orchestrator health.
type MachineMonitor ¶
type MachineMonitor struct {
// contains filtered or unexported fields
}
func NewMachineMonitor ¶
func NewMachineMonitor(client *ent.Client, logger *slog.Logger, collector MachineMonitorCollector) *MachineMonitor
func (*MachineMonitor) ConfigureEvents ¶
func (m *MachineMonitor) ConfigureEvents(events provider.EventProvider)
func (*MachineMonitor) RunTick ¶
func (m *MachineMonitor) RunTick(ctx context.Context) (MachineMonitorReport, error)
type MachineMonitorCollector ¶
type MachineMonitorCollector interface {
CollectReachability(ctx context.Context, machine domain.Machine) (domain.MachineReachability, error)
CollectSystemResources(ctx context.Context, machine domain.Machine) (domain.MachineSystemResources, error)
CollectGPUResources(ctx context.Context, machine domain.Machine) (domain.MachineGPUResources, error)
CollectAgentEnvironment(ctx context.Context, machine domain.Machine) (domain.MachineAgentEnvironment, error)
CollectFullAudit(ctx context.Context, machine domain.Machine) (domain.MachineFullAudit, error)
}
type MachineMonitorReport ¶
type MachineMonitorReport struct {
MachinesScanned int `json:"machines_scanned"`
MachinesUpdated int `json:"machines_updated"`
L1Checks int `json:"l1_checks"`
L2Checks int `json:"l2_checks"`
L3Checks int `json:"l3_checks"`
L4Checks int `json:"l4_checks"`
L5Checks int `json:"l5_checks"`
OfflineMachines int `json:"offline_machines"`
DegradedMachines int `json:"degraded_machines"`
}
type RetryResult ¶
type RetryResult struct {
TicketID uuid.UUID `json:"ticket_id"`
AttemptCount int `json:"attempt_count"`
ConsecutiveErrors int `json:"consecutive_errors"`
NextRetryAt time.Time `json:"next_retry_at"`
RetryPaused bool `json:"retry_paused"`
PauseReason ticketing.PauseReason `json:"pause_reason"`
ReleasedAgentID *uuid.UUID `json:"released_agent_id,omitempty"`
}
RetryResult reports the state change produced by a retry operation.
type RetryService ¶
type RetryService struct {
// contains filtered or unexported fields
}
RetryService manages ticket retry bookkeeping after failed attempts.
func NewRetryService ¶
func NewRetryService(client *ent.Client, logger *slog.Logger) *RetryService
NewRetryService constructs a retry service for orchestrator failures.
func (*RetryService) MarkAttemptFailed ¶
func (s *RetryService) MarkAttemptFailed(ctx context.Context, ticketID uuid.UUID) (RetryResult, error)
MarkAttemptFailed records a failed attempt and computes the next retry state.
type RuntimeLauncher ¶
type RuntimeLauncher struct {
// contains filtered or unexported fields
}
func NewRuntimeLauncher ¶
func NewRuntimeLauncher( client *ent.Client, logger *slog.Logger, events provider.EventProvider, processManager provider.AgentCLIProcessManager, sshPool *sshinfra.Pool, workflow *workflowservice.Service, ) *RuntimeLauncher
func (*RuntimeLauncher) ConfigureGitHubCredentials ¶
func (l *RuntimeLauncher) ConfigureGitHubCredentials(resolver githubauthservice.TokenResolver)
func (*RuntimeLauncher) ConfigureMetrics ¶
func (l *RuntimeLauncher) ConfigureMetrics(metrics provider.MetricsProvider)
func (*RuntimeLauncher) ConfigurePlatformEnvironment ¶
func (l *RuntimeLauncher) ConfigurePlatformEnvironment(apiURL string, agentPlatform runtimeAgentPlatform)
func (*RuntimeLauncher) ConfigureRuntimeState ¶
func (l *RuntimeLauncher) ConfigureRuntimeState(store *RuntimeStateStore)
type RuntimeStateStore ¶
type RuntimeStateStore struct {
// contains filtered or unexported fields
}
func NewRuntimeStateStore ¶
func NewRuntimeStateStore() *RuntimeStateStore
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler claims runnable tickets and advances orchestrator work.
func NewScheduler ¶
func NewScheduler(client *ent.Client, logger *slog.Logger, events provider.EventProvider) *Scheduler
NewScheduler constructs the orchestrator scheduler.
type TickReport ¶
type TickReport struct {
ScheduledJobsScanned int `json:"scheduled_jobs_scanned"`
ScheduledTicketsCreated int `json:"scheduled_tickets_created"`
WorkflowsScanned int `json:"workflows_scanned"`
CandidatesScanned int `json:"candidates_scanned"`
TicketsDispatched int `json:"tickets_dispatched"`
TicketsSkipped map[string]int `json:"tickets_skipped"`
}
TickReport summarizes the work done during one scheduler tick.
type TicketWorkspaceResetConflictError ¶
func (TicketWorkspaceResetConflictError) Error ¶
func (e TicketWorkspaceResetConflictError) Error() string
func (TicketWorkspaceResetConflictError) WorkspaceResetConflict ¶
func (TicketWorkspaceResetConflictError) WorkspaceResetConflict() bool
type TicketWorkspaceResetService ¶
type TicketWorkspaceResetService struct {
// contains filtered or unexported fields
}
func (*TicketWorkspaceResetService) ResetTicketWorkspace ¶
Source Files
¶
- agent_adapter.go
- agent_adapter_claudecode.go
- agent_adapter_codex.go
- agent_adapter_gemini.go
- claude_protocol.go
- health_checker.go
- machine_monitor.go
- provider_activity.go
- retry_service.go
- run_completion_summary.go
- runtime_launch_observability.go
- runtime_launcher.go
- runtime_launcher_components.go
- runtime_lifecycle.go
- runtime_reconciliation.go
- runtime_runner.go
- runtime_session_registry.go
- runtime_snapshot_materializer.go
- runtime_workspace_provisioner.go
- scheduler.go
- workspace_reset_service.go