k8s

type AgentCRD struct {
	APIVersion string         `json:"apiVersion"`
	Kind       string         `json:"kind"`
	Metadata   ObjectMeta     `json:"metadata"`
	Spec       AgentSpec      `json:"spec"`
	Status     AgentCRDStatus `json:"status,omitempty"`
}

type AgentCRDStatus struct {
	Phase              AgentPhase       `json:"phase"`
	Replicas           int32            `json:"replicas"`
	ReadyReplicas      int32            `json:"readyReplicas"`
	AvailableReplicas  int32            `json:"availableReplicas"`
	Conditions         []AgentCondition `json:"conditions,omitempty"`
	LastScaleTime      *time.Time       `json:"lastScaleTime,omitempty"`
	CurrentMetrics     []MetricValue    `json:"currentMetrics,omitempty"`
	ObservedGeneration int64            `json:"observedGeneration,omitempty"`
}

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

type AgentInstance struct {
	ID          string            `json:"id"`
	AgentName   string            `json:"agentName"`
	Namespace   string            `json:"namespace"`
	Status      InstanceStatus    `json:"status"`
	StartTime   time.Time         `json:"startTime"`
	LastHealthy time.Time         `json:"lastHealthy"`
	Metrics     InstanceMetrics   `json:"metrics"`
	Labels      map[string]string `json:"labels,omitempty"`
}

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

type AgentPhase string

type AgentSpec struct {
	AgentType    string            `json:"agentType"`
	Replicas     int32             `json:"replicas"`
	Model        ModelSpec         `json:"model"`
	Resources    ResourceSpec      `json:"resources"`
	Scaling      ScalingSpec       `json:"scaling,omitempty"`
	HealthCheck  HealthCheckSpec   `json:"healthCheck,omitempty"`
	Environment  map[string]string `json:"environment,omitempty"`
	ConfigMapRef string            `json:"configMapRef,omitempty"`
	SecretRef    string            `json:"secretRef,omitempty"`
}

type HealthCheckSpec struct {
	Enabled             bool          `json:"enabled"`
	Interval            time.Duration `json:"interval"`
	Timeout             time.Duration `json:"timeout"`
	FailureThreshold    int32         `json:"failureThreshold"`
	SuccessThreshold    int32         `json:"successThreshold"`
	InitialDelaySeconds int32         `json:"initialDelaySeconds,omitempty"`
}

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

type InstanceMetrics struct {
	RequestsTotal     int64         `json:"requestsTotal"`
	RequestsPerSecond float64       `json:"requestsPerSecond"`
	AverageLatency    time.Duration `json:"averageLatency"`
	ErrorRate         float64       `json:"errorRate"`
	CPUUsage          float64       `json:"cpuUsage"`
	MemoryUsage       float64       `json:"memoryUsage"`
	TokensUsed        int64         `json:"tokensUsed"`
}

type InstanceProvider interface {
	CreateInstance(ctx context.Context, agent *AgentCRD) (*AgentInstance, error)
	DeleteInstance(ctx context.Context, instanceID string) error
	GetInstanceStatus(ctx context.Context, instanceID string) (InstanceStatus, error)
	ListInstances(ctx context.Context, namespace, name string) ([]*AgentInstance, error)
}

type InstanceStatus string

type MetricValue struct {
	Name         string `json:"name"`
	CurrentValue int64  `json:"currentValue"`
	TargetValue  int64  `json:"targetValue"`
}

type ModelSpec struct {
	Provider    string  `json:"provider"`
	Model       string  `json:"model"`
	Temperature float64 `json:"temperature,omitempty"`
	MaxTokens   int     `json:"maxTokens,omitempty"`
}

type ObjectMeta struct {
	Name            string            `json:"name"`
	Namespace       string            `json:"namespace"`
	Labels          map[string]string `json:"labels,omitempty"`
	Annotations     map[string]string `json:"annotations,omitempty"`
	UID             string            `json:"uid,omitempty"`
	ResourceVersion string            `json:"resourceVersion,omitempty"`
	Generation      int64             `json:"generation,omitempty"`
	CreationTime    time.Time         `json:"creationTimestamp,omitempty"`
}

type OperatorConfig struct {
	Namespace               string        `json:"namespace"`
	ReconcileInterval       time.Duration `json:"reconcileInterval"`
	MetricsPort             int           `json:"metricsPort"`
	HealthProbePort         int           `json:"healthProbePort"`
	LeaderElection          bool          `json:"leaderElection"`
	LeaderElectionID        string        `json:"leaderElectionId"`
	WatchNamespaces         []string      `json:"watchNamespaces,omitempty"`
	EnableWebhooks          bool          `json:"enableWebhooks"`
	CertDir                 string        `json:"certDir,omitempty"`
	MaxConcurrentReconciles int           `json:"maxConcurrentReconciles"`
}

type OperatorMetrics struct {
	ReconcileTotal       atomic.Int64 `json:"reconcileTotal"`
	ReconcileErrors      atomic.Int64 `json:"reconcileErrors"`
	ScaleUpEvents        atomic.Int64 `json:"scaleUpEvents"`
	ScaleDownEvents      atomic.Int64 `json:"scaleDownEvents"`
	SelfHealingEvents    atomic.Int64 `json:"selfHealingEvents"`
	AverageReconcileTime atomic.Int64 `json:"averageReconcileTime"` // nanoseconds
}

type ResourceQuantity struct {
	CPU    string `json:"cpu,omitempty"`
	Memory string `json:"memory,omitempty"`
	GPU    string `json:"gpu,omitempty"`
}

type ResourceSpec struct {
	Requests ResourceQuantity `json:"requests,omitempty"`
	Limits   ResourceQuantity `json:"limits,omitempty"`
}

type ScalingBehavior struct {
	ScaleUp   *ScalingRules `json:"scaleUp,omitempty"`
	ScaleDown *ScalingRules `json:"scaleDown,omitempty"`
}

type ScalingPolicy struct {
	Type          string `json:"type"` // Pods, Percent
	Value         int32  `json:"value"`
	PeriodSeconds int32  `json:"periodSeconds"`
}

type ScalingRules struct {
	StabilizationWindowSeconds int32           `json:"stabilizationWindowSeconds,omitempty"`
	Policies                   []ScalingPolicy `json:"policies,omitempty"`
}

type ScalingSpec struct {
	Enabled        bool             `json:"enabled"`
	MinReplicas    int32            `json:"minReplicas"`
	MaxReplicas    int32            `json:"maxReplicas"`
	TargetMetrics  []TargetMetric   `json:"targetMetrics,omitempty"`
	ScaleDownDelay time.Duration    `json:"scaleDownDelay,omitempty"`
	ScaleUpDelay   time.Duration    `json:"scaleUpDelay,omitempty"`
	CooldownPeriod time.Duration    `json:"cooldownPeriod,omitempty"`
	CustomBehavior *ScalingBehavior `json:"behavior,omitempty"`
}

type TargetMetric struct {
	Type               string `json:"type"` // cpu, memory, custom, requests_per_second, latency
	Name               string `json:"name,omitempty"`
	TargetValue        int64  `json:"targetValue"`
	TargetAverageValue int64  `json:"targetAverageValue,omitempty"`
}