controller

type APIError struct {
	Code    string `json:"code"`
	Message string `json:"message"`
	Details string `json:"details,omitempty"`
}

type APIResponse struct {
	Success   bool        `json:"success"`
	Data      interface{} `json:"data,omitempty"`
	Error     *APIError   `json:"error,omitempty"`
	Timestamp time.Time   `json:"timestamp"`
}

type ClusterProblem struct {
	ID            string    `json:"id"`
	Type          string    `json:"type"`
	Severity      string    `json:"severity"`
	AffectedNodes []string  `json:"affectedNodes"`
	Message       string    `json:"message"`
	DetectedAt    time.Time `json:"detectedAt"`
	IsCorrelated  bool      `json:"isCorrelated"`
	CorrelationID string    `json:"correlationId,omitempty"`
}

type ClusterStatus struct {
	Timestamp      time.Time        `json:"timestamp"`
	OverallHealth  HealthStatus     `json:"overallHealth"`
	TotalNodes     int              `json:"totalNodes"`
	HealthyNodes   int              `json:"healthyNodes"`
	DegradedNodes  int              `json:"degradedNodes"`
	CriticalNodes  int              `json:"criticalNodes"`
	UnknownNodes   int              `json:"unknownNodes"`
	ActiveProblems int              `json:"activeProblems"`
	Correlations   int              `json:"activeCorrelations"`
	NodeSummaries  []NodeSummary    `json:"nodeSummaries,omitempty"`
	RecentProblems []ClusterProblem `json:"recentProblems,omitempty"`
}

type ControllerConfig struct {
	// Server settings
	Server ServerConfig `json:"server" yaml:"server"`

	// Storage settings
	Storage StorageConfig `json:"storage" yaml:"storage"`

	// Correlation settings
	Correlation CorrelationConfig `json:"correlation" yaml:"correlation"`

	// Coordination settings
	Coordination CoordinationConfig `json:"coordination" yaml:"coordination"`

	// Prometheus settings
	Prometheus PrometheusConfig `json:"prometheus" yaml:"prometheus"`

	// Kubernetes settings
	Kubernetes KubernetesConfig `json:"kubernetes" yaml:"kubernetes"`
}

type ControllerMetrics struct {
	// Cluster-level metrics
	NodesTotal     prometheus.Gauge
	NodesHealthy   prometheus.Gauge
	NodesDegraded  prometheus.Gauge
	NodesCritical  prometheus.Gauge
	NodesUnknown   prometheus.Gauge
	ActiveProblems prometheus.Gauge

	// Problem aggregation
	ProblemNodes  *prometheus.GaugeVec
	ProblemActive *prometheus.GaugeVec

	// Correlation metrics
	CorrelationActive   prometheus.Gauge
	CorrelationDetected *prometheus.CounterVec

	// Remediation metrics
	LeasesActive  prometheus.Gauge
	LeasesGranted *prometheus.CounterVec
	LeasesDenied  *prometheus.CounterVec

	// Report ingestion metrics
	ReportsReceived prometheus.Counter
	ReportErrors    *prometheus.CounterVec

	// Storage metrics
	StorageOperations *prometheus.CounterVec
	StorageErrors     *prometheus.CounterVec

	// Server metrics
	RequestDuration *prometheus.HistogramVec
	RequestsTotal   *prometheus.CounterVec
	// contains filtered or unexported fields
}

type CoordinationConfig struct {
	Enabled                   bool          `json:"enabled" yaml:"enabled"`
	MaxConcurrentRemediations int           `json:"maxConcurrentRemediations" yaml:"maxConcurrentRemediations"`
	DefaultLeaseDuration      time.Duration `json:"defaultLeaseDuration" yaml:"defaultLeaseDuration"`
	CooldownPeriod            time.Duration `json:"cooldownPeriod" yaml:"cooldownPeriod"`
}

type Correlation struct {
	ID            string                 `json:"id"`
	Type          string                 `json:"type"` // infrastructure, common-cause, cascade
	Severity      string                 `json:"severity"`
	AffectedNodes []string               `json:"affectedNodes"`
	ProblemTypes  []string               `json:"problemTypes"`
	Message       string                 `json:"message"`
	DetectedAt    time.Time              `json:"detectedAt"`
	UpdatedAt     time.Time              `json:"updatedAt"`
	Status        string                 `json:"status"` // active, resolved, investigating
	Confidence    float64                `json:"confidence"`
	Metadata      map[string]interface{} `json:"metadata,omitempty"`
}

type CorrelationConfig struct {
	Enabled                bool          `json:"enabled" yaml:"enabled"`
	ClusterWideThreshold   float64       `json:"clusterWideThreshold" yaml:"clusterWideThreshold"`
	EvaluationInterval     time.Duration `json:"evaluationInterval" yaml:"evaluationInterval"`
	MinNodesForCorrelation int           `json:"minNodesForCorrelation" yaml:"minNodesForCorrelation"`
}

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

type CorrelatorStats struct {
	ActiveCorrelations int       `json:"activeCorrelations"`
	TrackedNodes       int       `json:"trackedNodes"`
	LastEvalTime       time.Time `json:"lastEvalTime"`
	Started            bool      `json:"started"`
}

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

type EventRecorderConfig struct {
	Kubeconfig      string
	InCluster       bool
	Namespace       string
	Enabled         bool
	RateLimitPeriod time.Duration
}

type HealthStatus string

type KubernetesConfig struct {
	Enabled      bool   `json:"enabled" yaml:"enabled"`
	Kubeconfig   string `json:"kubeconfig" yaml:"kubeconfig"`
	InCluster    bool   `json:"inCluster" yaml:"inCluster"`
	Namespace    string `json:"namespace" yaml:"namespace"`
	CreateEvents bool   `json:"createEvents" yaml:"createEvents"`
}

type Lease struct {
	ID              string    `json:"id"`
	NodeName        string    `json:"nodeName"`
	RemediationType string    `json:"remediationType"`
	GrantedAt       time.Time `json:"grantedAt"`
	ExpiresAt       time.Time `json:"expiresAt"`
	CompletedAt     time.Time `json:"completedAt,omitempty"`
	Status          string    `json:"status"` // active, completed, expired, cancelled
	Reason          string    `json:"reason,omitempty"`
}

type LeaseRequest struct {
	NodeName          string `json:"node"`
	RemediationType   string `json:"remediation"`
	RequestedDuration string `json:"requestedDuration,omitempty"` // e.g., "5m"
	Reason            string `json:"reason,omitempty"`
	Priority          int    `json:"priority,omitempty"` // higher = more urgent
}

type LeaseResponse struct {
	LeaseID   string    `json:"leaseId,omitempty"`
	Approved  bool      `json:"approved"`
	ExpiresAt time.Time `json:"expiresAt,omitempty"`
	Message   string    `json:"message,omitempty"`
	RetryAt   time.Time `json:"retryAt,omitempty"`  // when to retry if denied
	Position  int       `json:"position,omitempty"` // queue position if waiting
}

type MonitorStatus struct {
	Name       string       `json:"name"`
	Type       string       `json:"type"`
	Status     HealthStatus `json:"status"`
	LastRun    time.Time    `json:"lastRun"`
	Message    string       `json:"message,omitempty"`
	ErrorCount int          `json:"errorCount,omitempty"`
}

type NodeCondition struct {
	Type               string    `json:"type"`
	Status             string    `json:"status"` // True, False, Unknown
	Reason             string    `json:"reason,omitempty"`
	Message            string    `json:"message,omitempty"`
	LastTransitionTime time.Time `json:"lastTransitionTime,omitempty"`
	LastHeartbeatTime  time.Time `json:"lastHeartbeatTime,omitempty"`
}

type NodeDetail struct {
	NodeName       string           `json:"nodeName"`
	NodeUID        string           `json:"nodeUID,omitempty"`
	Health         HealthStatus     `json:"health"`
	LastReportAt   time.Time        `json:"lastReportAt"`
	FirstSeenAt    time.Time        `json:"firstSeenAt"`
	ReportCount    int64            `json:"reportCount"`
	LatestReport   *NodeReport      `json:"latestReport,omitempty"`
	ActiveProblems []ProblemSummary `json:"activeProblems"`
	Conditions     []NodeCondition  `json:"conditions"`
	RecentHistory  []ReportSummary  `json:"recentHistory,omitempty"`
}

type NodeReport struct {
	// Node identification
	NodeName string `json:"nodeName"`
	NodeUID  string `json:"nodeUID,omitempty"`

	// Report metadata
	Timestamp  time.Time `json:"timestamp"`
	ReportID   string    `json:"reportId,omitempty"`
	Version    string    `json:"version,omitempty"`    // node-doctor version
	Uptime     string    `json:"uptime,omitempty"`     // node-doctor uptime
	ReportType string    `json:"reportType,omitempty"` // "periodic", "on-demand", "startup"

	// Health summary
	OverallHealth   HealthStatus     `json:"overallHealth"`
	MonitorStatuses []MonitorStatus  `json:"monitorStatuses,omitempty"`
	ActiveProblems  []ProblemSummary `json:"activeProblems,omitempty"`
	Conditions      []NodeCondition  `json:"conditions,omitempty"`

	// Statistics
	Stats *NodeStats `json:"stats,omitempty"`
}

type NodeStats struct {
	StatusesProcessed int64  `json:"statusesProcessed"`
	ProblemsDetected  int64  `json:"problemsDetected"`
	RemediationsRun   int64  `json:"remediationsRun"`
	MemoryUsageBytes  int64  `json:"memoryUsageBytes,omitempty"`
	GoroutineCount    int    `json:"goroutineCount,omitempty"`
	CPUUsagePercent   string `json:"cpuUsagePercent,omitempty"`
}

type NodeSummary struct {
	NodeName       string       `json:"nodeName"`
	Health         HealthStatus `json:"health"`
	LastReportAt   time.Time    `json:"lastReportAt"`
	ProblemCount   int          `json:"problemCount"`
	ConditionCount int          `json:"conditionCount"`
}

type PaginatedResponse struct {
	Items      interface{} `json:"items"`
	TotalCount int         `json:"totalCount"`
	Page       int         `json:"page"`
	PageSize   int         `json:"pageSize"`
	HasMore    bool        `json:"hasMore"`
}

type ProblemSummary struct {
	Type        string    `json:"type"`
	Severity    string    `json:"severity"`
	Message     string    `json:"message"`
	Source      string    `json:"source"`
	DetectedAt  time.Time `json:"detectedAt"`
	LastSeenAt  time.Time `json:"lastSeenAt"`
	Occurrences int       `json:"occurrences,omitempty"`
}

type PrometheusConfig struct {
	Enabled bool   `json:"enabled" yaml:"enabled"`
	Port    int    `json:"port" yaml:"port"`
	Path    string `json:"path" yaml:"path"`
}

type ReportSummary struct {
	ReportID      string       `json:"reportId"`
	Timestamp     time.Time    `json:"timestamp"`
	OverallHealth HealthStatus `json:"overallHealth"`
	ProblemCount  int          `json:"problemCount"`
}

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

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

type ServerConfig struct {
	BindAddress  string        `json:"bindAddress" yaml:"bindAddress"`
	Port         int           `json:"port" yaml:"port"`
	ReadTimeout  time.Duration `json:"readTimeout" yaml:"readTimeout"`
	WriteTimeout time.Duration `json:"writeTimeout" yaml:"writeTimeout"`
	EnableCORS   bool          `json:"enableCORS" yaml:"enableCORS"`
}

type Storage interface {
	// Initialize sets up the database and runs migrations
	Initialize(ctx context.Context) error

	// Close closes the database connection
	Close() error

	// Node Reports
	SaveNodeReport(ctx context.Context, report *NodeReport) error
	GetLatestNodeReport(ctx context.Context, nodeName string) (*NodeReport, error)
	GetNodeReports(ctx context.Context, nodeName string, limit int) ([]*NodeReport, error)
	GetAllLatestReports(ctx context.Context) (map[string]*NodeReport, error)
	DeleteOldReports(ctx context.Context, before time.Time) (int64, error)

	// Leases
	SaveLease(ctx context.Context, lease *Lease) error
	GetLease(ctx context.Context, leaseID string) (*Lease, error)
	GetActiveLeases(ctx context.Context) ([]*Lease, error)
	GetNodeLease(ctx context.Context, nodeName string) (*Lease, error)
	GetLastCompletedLease(ctx context.Context, nodeName string) (*Lease, error)
	UpdateLeaseStatus(ctx context.Context, leaseID, status string) error
	ExpireLeases(ctx context.Context) (int64, error)

	// Correlations
	SaveCorrelation(ctx context.Context, correlation *Correlation) error
	GetCorrelation(ctx context.Context, id string) (*Correlation, error)
	GetActiveCorrelations(ctx context.Context) ([]*Correlation, error)
	UpdateCorrelation(ctx context.Context, correlation *Correlation) error

	// Statistics
	GetNodeCount(ctx context.Context) (int, error)
	GetReportCount(ctx context.Context) (int64, error)
	GetLeaseStats(ctx context.Context) (active, total int64, err error)

	// Maintenance
	RunCleanup(ctx context.Context) error
}

type StorageConfig struct {
	Path      string        `json:"path" yaml:"path"`
	Retention time.Duration `json:"retention" yaml:"retention"` // How long to keep reports
}