orchestrator

type HealthCheckReport struct {
	ClaimsChecked  int `json:"claims_checked"`
	StalledClaims  int `json:"stalled_claims"`
	AgentsReleased int `json:"agents_released"`
}

type HealthChecker struct {
	// contains filtered or unexported fields
}

type MachineMonitor struct {
	// contains filtered or unexported fields
}

type MachineMonitorCollector interface {
	CollectReachability(ctx context.Context, machine domain.Machine) (domain.MachineReachability, error)
	CollectWebsocketHealth(ctx context.Context, machine domain.Machine) (domain.WebsocketMachineHealth, 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 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 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"`
}

type RetryService struct {
	// contains filtered or unexported fields
}

type RuntimeLauncher struct {
	// contains filtered or unexported fields
}

type RuntimeStateStore struct {
	// contains filtered or unexported fields
}

type Scheduler struct {
	// contains filtered or unexported fields
}

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"`
}

type TicketWorkspaceResetConflictError struct {
	TicketID uuid.UUID
	RunID    uuid.UUID
}

type TicketWorkspaceResetService struct {
	// contains filtered or unexported fields
}