optimization

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConstraintTypeCapacity = "capacity"

	ConstraintTypePerformance = "performance"

	ConstraintTypeCost = "cost"

	ConstraintTypeCompliance = "compliance"

	ConstraintTypeSLA = "sla"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type A1InterfaceConfig

type A1InterfaceConfig struct{}

type AIConfigurationTuner

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

func NewAIConfigurationTuner

func NewAIConfigurationTuner(config *AITunerConfig, logger logr.Logger) *AIConfigurationTuner

func (*AIConfigurationTuner) GetOptimalConfiguration

func (tuner *AIConfigurationTuner) GetOptimalConfiguration() *SystemConfiguration

func (*AIConfigurationTuner) StartAutoTuning

func (tuner *AIConfigurationTuner) StartAutoTuning(ctx context.Context) error

func (*AIConfigurationTuner) StopAutoTuning

func (tuner *AIConfigurationTuner) StopAutoTuning(ctx context.Context) error

type AITunerConfig

type AITunerConfig struct {
	OptimizationAlgorithm OptimizationAlgorithmType `json:"optimizationAlgorithm"`

	HyperparameterStrategy HyperparameterStrategy `json:"hyperparameterStrategy"`

	LearningRate float64 `json:"learningRate"`

	ExplorationRate float64 `json:"explorationRate"`

	ConvergenceThreshold float64 `json:"convergenceThreshold"`

	MaxIterations int `json:"maxIterations"`

	EarlyStoppingPatience int `json:"earlyStoppingPatience"`

	ExperimentDuration time.Duration `json:"experimentDuration"`

	WarmupPeriod time.Duration `json:"warmupPeriod"`

	CooldownPeriod time.Duration `json:"cooldownPeriod"`

	MaxConcurrentExperiments int `json:"maxConcurrentExperiments"`

	PerformanceDegradationThreshold float64 `json:"performanceDegradationThreshold"`

	MaxConfigurationChanges int `json:"maxConfigurationChanges"`

	RollbackTriggerThreshold float64 `json:"rollbackTriggerThreshold"`

	SafetyCheckInterval time.Duration `json:"safetyCheckInterval"`

	ObjectiveWeights map[string]float64 `json:"objectiveWeights"`

	ParetoOptimization bool `json:"paretoOptimization"`

	AcquisitionFunction AcquisitionFunction `json:"acquisitionFunction"`

	KernelType KernelType `json:"kernelType"`

	InitialSamples int `json:"initialSamples"`

	PopulationSize int `json:"populationSize"`

	MutationRate float64 `json:"mutationRate"`

	CrossoverRate float64 `json:"crossoverRate"`

	SelectionStrategy SelectionStrategy `json:"selectionStrategy"`

	RewardFunction RewardFunctionType `json:"rewardFunction"`

	DiscountFactor float64 `json:"discountFactor"`

	PolicyUpdateFrequency int `json:"policyUpdateFrequency"`
}

func GetDefaultAITunerConfig

func GetDefaultAITunerConfig() *AITunerConfig

type AMFConfig

type AMFConfig struct {
	MaxConcurrentRegistrations int `json:"maxConcurrentRegistrations"`

	RegistrationRetryPolicy RetryPolicy `json:"registrationRetryPolicy"`

	MobilityUpdateInterval time.Duration `json:"mobilityUpdateInterval"`

	AuthenticationCacheSize int `json:"authenticationCacheSize"`

	AuthenticationCacheTTL time.Duration `json:"authenticationCacheTTL"`

	LoadBalancingStrategy LoadBalancingStrategy `json:"loadBalancingStrategy"`

	FailoverThreshold float64 `json:"failoverThreshold"`

	ScalingPolicy ScalingPolicyConfig `json:"scalingPolicy"`
}

type AMFMetrics

type AMFMetrics struct {
	RegistrationLatency time.Duration `json:"registrationLatency"`

	RegistrationSuccessRate float64 `json:"registrationSuccessRate"`

	ActiveConnections int `json:"activeConnections"`

	HandoverSuccessRate float64 `json:"handoverSuccessRate"`

	AuthenticationLatency time.Duration `json:"authenticationLatency"`
}

type AccessPattern

type AccessPattern string
const (
	AccessPatternRare AccessPattern = "rare"

	AccessPatternRegular AccessPattern = "regular"

	AccessPatternFrequent AccessPattern = "frequent"

	AccessPatternBursty AccessPattern = "bursty"
)

type AcquisitionFunction

type AcquisitionFunction string
const (
	AcquisitionFunctionEI AcquisitionFunction = "expected_improvement"

	AcquisitionFunctionPI AcquisitionFunction = "probability_improvement"

	AcquisitionFunctionUCB AcquisitionFunction = "upper_confidence_bound"

	AcquisitionFunctionEHVI AcquisitionFunction = "expected_hypervolume_improvement"
)

type AcquisitionOptimizer

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

type AdmissionControlConfig

type AdmissionControlConfig struct{}

type AffinityConfig

type AffinityConfig struct {
	NodeAffinity string `json:"nodeAffinity"`

	PodAffinity string `json:"podAffinity"`

	PodAntiAffinity string `json:"podAntiAffinity"`
}

type AlgorithmPerformanceTracker

type AlgorithmPerformanceTracker struct{}

type AnalysisConfig

type AnalysisConfig struct {
	RealTimeAnalysisInterval time.Duration `json:"realTimeAnalysisInterval"`

	HistoricalAnalysisInterval time.Duration `json:"historicalAnalysisInterval"`

	PredictiveAnalysisInterval time.Duration `json:"predictiveAnalysisInterval"`

	CPUBottleneckThreshold float64 `json:"cpuBottleneckThreshold"`

	MemoryBottleneckThreshold float64 `json:"memoryBottleneckThreshold"`

	LatencyBottleneckThreshold time.Duration `json:"latencyBottleneckThreshold"`

	ThroughputBottleneckThreshold float64 `json:"throughputBottleneckThreshold"`

	PatternDetectionWindow time.Duration `json:"patternDetectionWindow"`

	AnomalyDetectionSensitivity float64 `json:"anomalyDetectionSensitivity"`

	TrendAnalysisWindow time.Duration `json:"trendAnalysisWindow"`

	PredictionHorizon time.Duration `json:"predictionHorizon"`

	ModelRetrainingInterval time.Duration `json:"modelRetrainingInterval"`

	FeatureImportanceThreshold float64 `json:"featureImportanceThreshold"`

	Components []ComponentAnalysisConfig `json:"components"`
}

func GetDefaultAnalysisConfig

func GetDefaultAnalysisConfig() *AnalysisConfig

type AnalysisType

type AnalysisType string
const (
	AnalysisTypeStatistical AnalysisType = "statistical"

	AnalysisTypeTrend AnalysisType = "trend"

	AnalysisTypeAnomaly AnalysisType = "anomaly"

	AnalysisTypeCorrelation AnalysisType = "correlation"

	AnalysisTypePredictive AnalysisType = "predictive"
)

type AnomalyType

type AnomalyType string
const (
	AnomalyTypePoint AnomalyType = "point"

	AnomalyTypeContextual AnomalyType = "contextual"

	AnomalyTypeCollective AnomalyType = "collective"
)

type AuditEntry

type AuditEntry struct {
	Timestamp time.Time `json:"timestamp"`

	EventType string `json:"eventType"`

	Actor string `json:"actor"`

	Action string `json:"action"`

	Resource string `json:"resource"`

	Details map[string]interface{} `json:"details"`

	Outcome string `json:"outcome"`
}

type AuditLogger

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

func (*AuditLogger) LogOptimizationRequest

func (al *AuditLogger) LogOptimizationRequest(ctx context.Context, req *OptimizationRequest)

type AutomatedOptimizationPipeline

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

func NewAutomatedOptimizationPipeline

func NewAutomatedOptimizationPipeline(
	logger logr.Logger,
	k8sClient client.Client,
	clientset kubernetes.Interface,
	config *AutomationConfig,
) *AutomatedOptimizationPipeline

func (*AutomatedOptimizationPipeline) GetOptimizationStatus

func (pipeline *AutomatedOptimizationPipeline) GetOptimizationStatus() string

Add GetOptimizationStatus method to AutomatedOptimizationPipeline

func (*AutomatedOptimizationPipeline) GetPipelineState

func (pipeline *AutomatedOptimizationPipeline) GetPipelineState() *PipelineState

func (*AutomatedOptimizationPipeline) PauseOptimizations

func (pipeline *AutomatedOptimizationPipeline) PauseOptimizations()

func (*AutomatedOptimizationPipeline) RequestOptimization

func (pipeline *AutomatedOptimizationPipeline) RequestOptimization(
	ctx context.Context,
	recommendations []*OptimizationRecommendation,
	priority OptimizationPriority,
	requestedBy string,
) string

func (*AutomatedOptimizationPipeline) ResumeOptimizations

func (pipeline *AutomatedOptimizationPipeline) ResumeOptimizations()

func (*AutomatedOptimizationPipeline) Start

func (pipeline *AutomatedOptimizationPipeline) Start(ctx context.Context) error

func (*AutomatedOptimizationPipeline) Stop

func (pipeline *AutomatedOptimizationPipeline) Stop()

type AutomationConfig

type AutomationConfig struct {
	EnableAutoApproval bool `json:"enableAutoApproval"`

	ApprovalThreshold float64 `json:"approvalThreshold"`

	MaxConcurrentOptimizations int `json:"maxConcurrentOptimizations"`

	OptimizationInterval time.Duration `json:"optimizationInterval"`

	ValidationTimeout time.Duration `json:"validationTimeout"`

	RollbackOnFailure bool `json:"rollbackOnFailure"`

	NotificationConfig *NotificationConfig `json:"notificationConfig"`

	SafetyChecks *SafetyChecks `json:"safetyChecks"`
}

type AutomationLevel

type AutomationLevel string
const (
	AutomationFull AutomationLevel = "full"

	AutomationPartial AutomationLevel = "partial"

	AutomationManual AutomationLevel = "manual"

	AutomationAssisted AutomationLevel = "assisted"
)

type AvailabilityMetric

type AvailabilityMetric struct {
	*PerformanceMetric

	Uptime time.Duration `json:"uptime"`

	Downtime time.Duration `json:"downtime"`

	MTBF time.Duration `json:"mtbf"` // Mean Time Between Failures

	MTTR time.Duration `json:"mttr"` // Mean Time To Recovery

	IncidentCount int `json:"incidentCount"`
}

type BatchConfig

type BatchConfig struct {
	OptimalSize int `json:"optimalSize"`

	MaxWaitTime time.Duration `json:"maxWaitTime"`

	ConcurrencyLevel int `json:"concurrencyLevel"`

	BufferSize int `json:"bufferSize"`
}

type BayesianOptimization

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

type BeamformingConfig

type BeamformingConfig struct{}

type BenchmarkComparison

type BenchmarkComparison struct {
	Industry float64 `json:"industry"`

	Internal float64 `json:"internal"`

	BestPractice float64 `json:"bestPractice"`

	Deviation float64 `json:"deviation"`

	Ranking string `json:"ranking"`
}

type BenchmarkEnvironment

type BenchmarkEnvironment struct {
	Platform string `json:"platform"`

	Version string `json:"version"`

	Configuration map[string]string `json:"configuration"`

	ResourceLimits map[string]string `json:"resourceLimits"`

	Load string `json:"load"`

	Concurrency int `json:"concurrency"`
}

type BottleneckPredictor

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

BottleneckPredictor predicts performance bottlenecks using ML

func NewBottleneckPredictor

func NewBottleneckPredictor(predictionHorizon time.Duration) *BottleneckPredictor

NewBottleneckPredictor creates a new bottleneck predictor

type BottleneckSolution

type BottleneckSolution struct {
	BottleneckType string `json:"bottleneckType"`

	Description string `json:"description"`

	ComponentTypes []shared.ComponentType `json:"componentTypes"`

	Solutions []*OptimizationSolution `json:"solutions"`

	PreventiveMeasures []string `json:"preventiveMeasures"`

	DetectionMethod string `json:"detectionMethod"`
}

type BufferSizeConfig

type BufferSizeConfig struct{}

type CacheConfig

type CacheConfig struct {
	Strategy CachingStrategy `json:"strategy"`

	TTL time.Duration `json:"ttl"`

	MaxSize int64 `json:"maxSize"`

	EvictionPolicy string `json:"evictionPolicy"`

	CompressionEnabled bool `json:"compressionEnabled"`

	DistributedCache bool `json:"distributedCache"`
}

type CacheOptimizationStrategy

type CacheOptimizationStrategy struct {
	StrategyName   string                 `json:"strategyName"`
	CacheSize      int64                  `json:"cacheSize"`
	TTL            time.Duration          `json:"ttl"`
	EvictionPolicy string                 `json:"evictionPolicy"`
	HitRatio       float64                `json:"hitRatio"`
	Config         map[string]interface{} `json:"config"`
}

CacheOptimizationStrategy represents a cache optimization strategy

type CachingStrategy

type CachingStrategy string
const (
	CachingStrategyNone CachingStrategy = "none"

	CachingStrategySimple CachingStrategy = "simple"

	CachingStrategyIntelligent CachingStrategy = "intelligent"

	CachingStrategyPredictive CachingStrategy = "predictive"

	CachingStrategyAdaptive CachingStrategy = "adaptive"
)

type CapacityOptimization

type CapacityOptimization struct{}

type CapacityPrediction

type CapacityPrediction struct {
	ResourceType string `json:"resourceType"`

	ComponentType shared.ComponentType `json:"componentType"`

	CurrentUtilization float64 `json:"currentUtilization"`

	PredictedUtilization float64 `json:"predictedUtilization"`

	TimeToCapacity time.Duration `json:"timeToCapacity"`

	CapacityThreshold float64 `json:"capacityThreshold"`

	RecommendedActions []string `json:"recommendedActions"`
}

type ChargingOptimization

type ChargingOptimization struct{}

type ChartDataSeries

type ChartDataSeries struct {
	Labels []string `json:"labels"`

	Values []float64 `json:"values"`

	Colors []string `json:"colors,omitempty"`
}

type ChartsData

type ChartsData struct {
	LatencyChart *ChartDataSeries `json:"latencyChart"`

	ThroughputChart *ChartDataSeries `json:"throughputChart"`

	ErrorRateChart *ChartDataSeries `json:"errorRateChart"`

	ResourceChart *ChartDataSeries `json:"resourceChart"`

	CostChart *ChartDataSeries `json:"costChart"`

	LatencyDistribution *HistogramData `json:"latencyDistribution"`

	ResponseSizes *HistogramData `json:"responseSizes"`

	ComponentBreakdown *PieChartData `json:"componentBreakdown"`

	ErrorBreakdown *PieChartData `json:"errorBreakdown"`
}

type ComparisonOperator

type ComparisonOperator string
const (
	OperatorGreaterThan ComparisonOperator = "gt"

	OperatorLessThan ComparisonOperator = "lt"

	OperatorEqual ComparisonOperator = "eq"

	OperatorGreaterEqual ComparisonOperator = "gte"

	OperatorLessEqual ComparisonOperator = "lte"

	OperatorBetween ComparisonOperator = "between"
)

type ComplexityLevel

type ComplexityLevel string
const (
	ComplexityLow ComplexityLevel = "low"

	ComplexityMedium ComplexityLevel = "medium"

	ComplexityHigh ComplexityLevel = "high"

	ComplexityCritical ComplexityLevel = "critical"
)

type ComplianceCheckConfig

type ComplianceCheckConfig struct{}

type ComplianceHistoryEntry

type ComplianceHistoryEntry struct {
	Timestamp time.Time `json:"timestamp"`

	Compliance float64 `json:"compliance"`

	Violations int `json:"violations"`

	MetricName string `json:"metricName"`

	ActionTaken string `json:"actionTaken"`
}

type ComplianceRequirement

type ComplianceRequirement struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	Standard string `json:"standard"` // e.g., "O-RAN", "3GPP", "ITU"

	ComponentTypes []shared.ComponentType `json:"componentTypes"`

	Requirements []string `json:"requirements"`

	ValidationRules []string `json:"validationRules"`

	Mandatory bool `json:"mandatory"`

	Deadline time.Time `json:"deadline,omitempty"`
}

type ComponentAnalysis

type ComponentAnalysis struct {
	ComponentType shared.ComponentType `json:"componentType"`

	HealthStatus SystemHealthStatus `json:"healthStatus"`

	PerformanceScore float64 `json:"performanceScore"`

	MetricAnalyses map[string]*MetricAnalysis `json:"metricAnalyses"`

	PerformanceIssues []*PerformanceIssue `json:"performanceIssues"`

	ResourceConstraints []*ResourceConstraint `json:"resourceConstraints"`

	OptimizationOpportunities []*OptimizationOpportunity `json:"optimizationOpportunities"`

	ResourceUtilization *ResourceUtilization `json:"resourceUtilization"`

	PerformanceMetrics *ComponentPerformanceMetrics `json:"performanceMetrics"`
}

type ComponentAnalysisConfig

type ComponentAnalysisConfig struct {
	Name string `json:"name"`

	Type shared.ComponentType `json:"type"`

	Metrics []MetricConfig `json:"metrics"`

	Thresholds map[string]float64 `json:"thresholds"`

	OptimizationStrategies []string `json:"optimizationStrategies"`

	Priority OptimizationPriority `json:"priority"`
}

type ComponentHealth

type ComponentHealth struct {
	Name string `json:"name"`

	Status string `json:"status"`

	HealthScore float64 `json:"healthScore"`

	LastCheck time.Time `json:"lastCheck"`

	Issues []string `json:"issues"`

	Metrics map[string]float64 `json:"metrics"`

	Recommendations int `json:"recommendations"`
}

type ComponentOptimizer

type ComponentOptimizer interface {
	GetOptimizationStrategies() []RecommendationStrategy

	OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)

	ValidateOptimization(ctx context.Context, result *OptimizationResult) error

	RollbackOptimization(ctx context.Context, result *OptimizationResult) error
}

type ComponentOptimizerRegistry

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

func NewComponentOptimizerRegistry

func NewComponentOptimizerRegistry(logger logr.Logger) *ComponentOptimizerRegistry

func (*ComponentOptimizerRegistry) GetOptimizer

func (registry *ComponentOptimizerRegistry) GetOptimizer(componentType shared.ComponentType) (ComponentOptimizer, error)

type ComponentPerformanceMetrics

type ComponentPerformanceMetrics struct {
	ComponentType shared.ComponentType `json:"componentType"`

	MeasurementPeriod TimePeriod `json:"measurementPeriod"`

	ResponseTime *PerformanceMetric `json:"responseTime"`

	Throughput *PerformanceMetric `json:"throughput"`

	ErrorRate *PerformanceMetric `json:"errorRate"`

	Availability *AvailabilityMetric `json:"availability"`

	Reliability *ReliabilityMetric `json:"reliability"`

	Scalability *ScalabilityMetric `json:"scalability"`

	Efficiency *EfficiencyMetric `json:"efficiency"`

	CustomMetrics map[string]*PerformanceMetric `json:"customMetrics"`

	SLACompliance *SLAComplianceMetric `json:"slaCompliance"`

	QualityScore float64 `json:"qualityScore"`

	PerformanceTrends []*MetricTrend `json:"performanceTrends"`

	BenchmarkResults *PerformanceBenchmark `json:"benchmarkResults"`
}

type ComponentType

type ComponentType = shared.ComponentType

type ConfidenceInterval

type ConfidenceInterval struct {
	Timestamp time.Time `json:"timestamp,omitempty"`

	LowerBound float64 `json:"lowerBound"`

	UpperBound float64 `json:"upperBound"`

	ConfidenceLevel float64 `json:"confidenceLevel"`
}

type ConfigurationConstraint

type ConfigurationConstraint struct {
	Name string `json:"name"`

	Type ConstraintType `json:"type"`

	Parameters []string `json:"parameters"`

	Expression string `json:"expression"`

	Violation ConstraintViolation `json:"violation"`
}

type ConfigurationSpace

type ConfigurationSpace struct {
	Parameters map[string]*ParameterSpace `json:"parameters"`

	Constraints []*ConfigurationConstraint `json:"constraints"`

	Dependencies []*ParameterDependency `json:"dependencies"`

	Categories map[string][]string `json:"categories"`

	SearchStrategy SearchStrategy `json:"searchStrategy"`
}

type ConflictResolutionPolicy

type ConflictResolutionPolicy string

type ConnectivityOptConfig

type ConnectivityOptConfig struct{}

type ConstraintImpact

type ConstraintImpact struct {
	PerformanceDegradation float64 `json:"performanceDegradation"`

	AffectedServices []string `json:"affectedServices"`

	BusinessImpact string `json:"businessImpact"`

	SLAViolationRisk float64 `json:"slaViolationRisk"`

	CostImplication float64 `json:"costImplication"`
}

type ConstraintType

type ConstraintType string
const (
	ConstraintTypeLinear ConstraintType = "linear"

	ConstraintTypeNonlinear ConstraintType = "nonlinear"

	ConstraintTypeConditional ConstraintType = "conditional"

	ConstraintTypeExclusion ConstraintType = "exclusion"
)

type ConstraintViolation

type ConstraintViolation string
const (
	ConstraintViolationReject ConstraintViolation = "reject"

	ConstraintViolationPenalize ConstraintViolation = "penalize"

	ConstraintViolationRepair ConstraintViolation = "repair"
)

type ConvergenceTracker

type ConvergenceTracker struct{}

func NewConvergenceTracker

func NewConvergenceTracker(threshold float64) *ConvergenceTracker

func (*ConvergenceTracker) IsConverged

func (ct *ConvergenceTracker) IsConverged(history []*LearningIteration) (bool, float64)

type CoreNetworkConfig

type CoreNetworkConfig struct {
	AMFConfig *AMFConfig `json:"amfConfig"`

	SMFConfig *SMFConfig `json:"smfConfig"`

	UPFConfig *UPFConfig `json:"upfConfig"`

	NSSFConfig *NSSFConfig `json:"nssfConfig"`

	ServiceMeshConfig *ServiceMeshConfig `json:"serviceMeshConfig"`

	SessionOptimization *SessionOptimization `json:"sessionOptimization"`
}

type CoreNetworkOptimizer

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

func NewCoreNetworkOptimizer

func NewCoreNetworkOptimizer(config *CoreNetworkConfig, logger logr.Logger) *CoreNetworkOptimizer

func (*CoreNetworkOptimizer) OptimizeCore

func (optimizer *CoreNetworkOptimizer) OptimizeCore(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)

type CostAnalysis

type CostAnalysis struct {
	CurrentCost float64 `json:"currentCost"`

	OptimizedCost float64 `json:"optimizedCost"`

	PotentialSavings float64 `json:"potentialSavings"`

	CostEfficiency float64 `json:"costEfficiency"`

	CostBreakdown map[string]float64 `json:"costBreakdown"`

	OptimizationROI float64 `json:"optimizationROI"`
}

type CoverageOptimization

type CoverageOptimization struct{}

type DashboardConfig

type DashboardConfig struct {
	ListenAddress string `json:"listenAddress"`

	ListenPort int `json:"listenPort"`

	TLSEnabled bool `json:"tlsEnabled"`

	CertFile string `json:"certFile,omitempty"`

	KeyFile string `json:"keyFile,omitempty"`

	DataUpdateInterval time.Duration `json:"dataUpdateInterval"`

	MetricsUpdateInterval time.Duration `json:"metricsUpdateInterval"`

	EnableWebUI bool `json:"enableWebUI"`

	UIPath string `json:"uiPath"`

	StaticAssetsPath string `json:"staticAssetsPath"`

	EnableAPI bool `json:"enableAPI"`

	APIPrefix string `json:"apiPrefix"`

	EnableWebSocket bool `json:"enableWebSocket"`

	WSPath string `json:"wsPath"`

	MaxWSConnections int `json:"maxWSConnections"`

	AuthenticationEnabled bool `json:"authenticationEnabled"`

	AllowedOrigins []string `json:"allowedOrigins"`

	HistoryRetentionDays int `json:"historyRetentionDays"`

	MaxDataPoints int `json:"maxDataPoints"`

	AlertingEnabled bool `json:"alertingEnabled"`

	AlertWebhookURL string `json:"alertWebhookUrl,omitempty"`
}

func GetDefaultDashboardConfig

func GetDefaultDashboardConfig() *DashboardConfig

type DashboardData

type DashboardData struct {
	Overview *DashboardOverview `json:"overview"`

	PerformanceMetrics *DashboardPerformanceMetrics `json:"performanceMetrics"`

	OptimizationStatus *OptimizationStatusData `json:"optimizationStatus"`

	ComponentHealth map[shared.ComponentType]*ComponentHealth `json:"componentHealth"`

	ChartsData *ChartsData `json:"chartsData"`

	ActiveRecommendations []*DashboardRecommendation `json:"activeRecommendations"`

	HistoricalData *HistoricalData `json:"historicalData"`

	SystemInfo *SystemInfo `json:"systemInfo"`

	LastUpdated time.Time `json:"lastUpdated"`
}

type DashboardOverview

type DashboardOverview struct {
	OverallHealth string `json:"overallHealth"`

	HealthScore float64 `json:"healthScore"`

	LatencyP99 time.Duration `json:"latencyP99"`

	ThroughputRPS float64 `json:"throughputRps"`

	ErrorRate float64 `json:"errorRate"`

	AvailabilityPercent float64 `json:"availabilityPercent"`

	CPUUtilization float64 `json:"cpuUtilization"`

	MemoryUtilization float64 `json:"memoryUtilization"`

	TotalOptimizations int `json:"totalOptimizations"`

	SuccessfulOptimizations int `json:"successfulOptimizations"`

	ActiveOptimizations int `json:"activeOptimizations"`

	LastOptimization time.Time `json:"lastOptimization"`

	LatencyImprovement float64 `json:"latencyImprovement"`

	CostSavings float64 `json:"costSavings"`

	EfficiencyGain float64 `json:"efficiencyGain"`
}

type DashboardPerformanceMetrics

type DashboardPerformanceMetrics struct {
	LatencyMetrics *LatencyMetrics `json:"latencyMetrics"`

	ThroughputMetrics *ThroughputMetrics `json:"throughputMetrics"`

	ResourceMetrics *ResourceMetrics `json:"resourceMetrics"`

	ErrorMetrics *ErrorMetrics `json:"errorMetrics"`

	CustomMetrics map[string]float64 `json:"customMetrics"`

	Trends map[string]*TrendData `json:"trends"`
}

type DashboardRecommendation

type DashboardRecommendation struct {
	ID string `json:"id"`

	Title string `json:"title"`

	Description string `json:"description"`

	Priority string `json:"priority"`

	Category string `json:"category"`

	ExpectedImprovement *ExpectedImpact `json:"expectedImprovement"`

	RiskLevel string `json:"riskLevel"`

	EstimatedTime time.Duration `json:"estimatedTime"`

	AutoImplementable bool `json:"autoImplementable"`

	CreatedAt time.Time `json:"createdAt"`

	Status string `json:"status"`
}

type DataPathOptimization

type DataPathOptimization struct{}

type DataPoint

type DataPoint struct {
	Timestamp time.Time `json:"timestamp"`

	Value float64 `json:"value"`

	Label string `json:"label,omitempty"`
}

type DependencyCondition

type DependencyCondition struct {
	ParentValue interface{} `json:"parentValue"`

	ChildEnabled bool `json:"childEnabled"`

	ChildConstraints []string `json:"childConstraints"`
}

type E2InterfaceConfig

type E2InterfaceConfig struct{}

type EdgeCachingConfig

type EdgeCachingConfig struct{}

type EdgeConfig

type EdgeConfig struct {
	EdgeNodeSelection *EdgeNodeSelectionConfig `json:"edgeNodeSelection"`

	WorkloadPlacement *WorkloadPlacementConfig `json:"workloadPlacement"`

	LatencyOptimization *LatencyOptimizationConfig `json:"latencyOptimization"`

	CachingStrategy *EdgeCachingConfig `json:"cachingStrategy"`

	ConnectivityOptimization *ConnectivityOptConfig `json:"connectivityOptimization"`

	ResourceManagement *EdgeResourceMgmtConfig `json:"resourceManagement"`
}

type EdgeDeploymentOptimizer

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

func NewEdgeDeploymentOptimizer

func NewEdgeDeploymentOptimizer(config *EdgeConfig, logger logr.Logger) *EdgeDeploymentOptimizer

func (*EdgeDeploymentOptimizer) OptimizeEdge

type EdgeMetrics

type EdgeMetrics struct {
	EdgeNodeID string `json:"edgeNodeId"`

	Latency time.Duration `json:"latency"`

	Throughput float64 `json:"throughput"`

	ResourceUtilization float64 `json:"resourceUtilization"`

	CacheHitRate float64 `json:"cacheHitRate"`

	ConnectivityQuality float64 `json:"connectivityQuality"`
}

type EdgeNodeSelectionConfig

type EdgeNodeSelectionConfig struct{}

type EdgeResourceMgmtConfig

type EdgeResourceMgmtConfig struct{}

type EfficiencyMetric

type EfficiencyMetric struct {
	*PerformanceMetric

	ResourceEfficiency float64 `json:"resourceEfficiency"`

	CostEfficiency float64 `json:"costEfficiency"`

	EnergyEfficiency float64 `json:"energyEfficiency"`

	TimeEfficiency float64 `json:"timeEfficiency"`

	WasteReduction float64 `json:"wasteReduction"`

	OptimizationGain float64 `json:"optimizationGain"`
}

type EmailAuthConfig

type EmailAuthConfig struct {
	Username string `json:"username"`

	Password string `json:"password"`
}

type EmailConfig

type EmailConfig struct {
	SMTPServer string `json:"smtpServer"`

	Port int `json:"port"`

	From string `json:"from"`

	To []string `json:"to"`

	AuthConfig *EmailAuthConfig `json:"authConfig,omitempty"`
}

type EmbeddingConfig

type EmbeddingConfig struct {
	Model string `json:"model"`

	Dimensions int `json:"dimensions"`

	BatchSize int `json:"batchSize"`

	CachingEnabled bool `json:"cachingEnabled"`

	CompressionRatio float64 `json:"compressionRatio"`
}

type EnergyEfficiencyConfig

type EnergyEfficiencyConfig struct{}

type ErrorMetrics

type ErrorMetrics struct {
	TotalErrors int `json:"totalErrors"`

	ErrorRate float64 `json:"errorRate"`

	ErrorsByType map[string]int `json:"errorsByType"`

	ErrorsByComponent map[shared.ComponentType]int `json:"errorsByComponent"`

	CriticalErrors int `json:"criticalErrors"`
}

type EstimatedImprovement

type EstimatedImprovement struct {
	PerformanceGain float64 `json:"performanceGain"`

	CostSaving float64 `json:"costSaving"`

	ResourceReduction float64 `json:"resourceReduction"`

	LatencyImprovement time.Duration `json:"latencyImprovement"`

	ThroughputIncrease float64 `json:"throughputIncrease"`

	EfficiencyGain float64 `json:"efficiencyGain"`

	MetricImpacts map[string]float64 `json:"metricImpacts"`

	SLACompliance float64 `json:"slaCompliance"`
}

type ExecutionProgress

type ExecutionProgress struct {
	CurrentStep string `json:"currentStep"`

	TotalSteps int `json:"totalSteps"`

	CompletedSteps int `json:"completedSteps"`

	PercentComplete float64 `json:"percentComplete"`

	EstimatedTimeRemaining time.Duration `json:"estimatedTimeRemaining,omitempty"`
}

type ExecutionStatus

type ExecutionStatus string
const (
	ExecutionStatusPending ExecutionStatus = "pending"

	ExecutionStatusRunning ExecutionStatus = "running"

	ExecutionStatusCompleted ExecutionStatus = "completed"

	ExecutionStatusFailed ExecutionStatus = "failed"

	ExecutionStatusRolledBack ExecutionStatus = "rolled_back"
)

type ExpectedBenefits

type ExpectedBenefits struct {
	LatencyReduction float64 `json:"latencyReduction"`

	ThroughputIncrease float64 `json:"throughputIncrease"`

	ResourceSavings float64 `json:"resourceSavings"`

	CostSavings float64 `json:"costSavings"`

	EfficiencyGain float64 `json:"efficiencyGain,omitempty"`

	ErrorRateReduction float64 `json:"errorRateReduction,omitempty"`

	ReliabilityImprovement float64 `json:"reliabilityImprovement"`

	EnergyEfficiencyGain float64 `json:"energyEfficiencyGain"`

	SignalingEfficiencyGain float64 `json:"signalingEfficiencyGain"`

	SpectrumEfficiencyGain float64 `json:"spectrumEfficiencyGain"`

	InteropImprovements float64 `json:"interopImprovements"`
}

type ExpectedImpact

type ExpectedImpact struct {
	// Performance improvements
	LatencyReduction   float64 `json:"latencyReduction"`
	ThroughputIncrease float64 `json:"throughputIncrease"`
	EfficiencyGain     float64 `json:"efficiencyGain"`

	// Resource improvements
	ResourceSavings  float64 `json:"resourceSavings"`
	CostSavings      float64 `json:"costSavings"`
	EnergyEfficiency float64 `json:"energyEfficiency"`

	// Reliability improvements
	ReliabilityImprovement float64 `json:"reliabilityImprovement"`
	AvailabilityGain       float64 `json:"availabilityGain"`

	// Telecom-specific impacts
	SignalingEfficiencyGain float64 `json:"signalingEfficiencyGain"`
	SpectrumEfficiencyGain  float64 `json:"spectrumEfficiencyGain"`
	InteropImprovements     float64 `json:"interopImprovements"`

	// Quality of service
	SLAComplianceImprovement float64 `json:"slaComplianceImprovement"`
	UserExperienceGain       float64 `json:"userExperienceGain"`

	// Confidence metrics
	ConfidenceLevel        float64 `json:"confidenceLevel"`
	DataQuality            float64 `json:"dataQuality"`
	PerformanceImprovement float64 `json:"performanceImprovement"`
	ResourceReduction      float64 `json:"resourceReduction"`
	MemoryReduction        float64 `json:"memoryReduction"`
}

ExpectedImpact represents the expected impact of implementing an optimization

type ExperienceBuffer

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

ExperienceBuffer stores training experiences

func NewExperienceBuffer

func NewExperienceBuffer(maxSize int) *ExperienceBuffer

NewExperienceBuffer creates a new experience buffer

func (*ExperienceBuffer) Add

func (e *ExperienceBuffer) Add(state []float64, action int, reward float64)

Add adds a new experience to the buffer

func (*ExperienceBuffer) Clear

func (e *ExperienceBuffer) Clear()

Clear removes all experiences from the buffer

type ExperimentManager

type ExperimentManager struct{}

func NewExperimentManager

func NewExperimentManager(config *AITunerConfig, logger logr.Logger) *ExperimentManager

type ExtendedOptimizationRecommendation

type ExtendedOptimizationRecommendation struct {
	*OptimizationRecommendation
	ComponentType    ComponentType   `json:"componentType"`
	OptimizationType string          `json:"optimizationType"`
	EstimatedImpact  *ExpectedImpact `json:"estimatedImpact"`
}

Add ComponentType field to OptimizationRecommendation struct

type FailedOptimization

type FailedOptimization struct {
	Request *OptimizationRequest `json:"request"`

	Timestamp time.Time `json:"timestamp"`

	Reason string `json:"reason"`

	ErrorDetails string `json:"errorDetails"`

	RecoveryAttempted bool `json:"recoveryAttempted"`

	RecoverySuccessful bool `json:"recoverySuccessful"`
}

type ForecastData

type ForecastData struct {
	PredictedValues []float64 `json:"predictedValues"`

	ConfidenceIntervals []ConfidenceInterval `json:"confidenceIntervals"` // Using existing type

	ForecastHorizon time.Duration `json:"forecastHorizon"`

	ModelAccuracy float64 `json:"modelAccuracy"`

	ModelType string `json:"modelType"`
}

type ForecastPoint

type ForecastPoint struct {
	Timestamp time.Time `json:"timestamp"`

	PredictedValue float64 `json:"predictedValue"`
}

type GaussianProcess

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

type HAConfig

type HAConfig struct{}

type HWAccelerationConfig

type HWAccelerationConfig struct{}

type HandoverOptimization

type HandoverOptimization struct{}

type HealthStatus

type HealthStatus string

HealthStatus represents the health status of a component

const (
	// HealthStatusOptimal holds healthstatusoptimal value (unique to HealthStatus)
	HealthStatusOptimal HealthStatus = "optimal"
	// HealthStatusUnhealthy holds healthstatusunhealthy value (unique to HealthStatus)
	HealthStatusUnhealthy HealthStatus = "unhealthy"
)

type HistogramData

type HistogramData struct {
	Buckets []string `json:"buckets"`

	Counts []int `json:"counts"`
}

type HistoricalData

type HistoricalData struct {
	PerformanceTrends map[string][]*DataPoint `json:"performanceTrends"`

	OptimizationHistory []*HistoricalOptimization `json:"optimizationHistory"`

	CostSavingsTrend []*DataPoint `json:"costSavingsTrend"`

	EfficiencyTrend []*DataPoint `json:"efficiencyTrend"`
}

type HistoricalDataStore

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

HistoricalDataStore stores historical performance data

func NewHistoricalDataStore

func NewHistoricalDataStore(retentionPeriod time.Duration) *HistoricalDataStore

NewHistoricalDataStore creates a new historical data store

type HistoricalOptimization

type HistoricalOptimization struct {
	ID string `json:"id"`

	Timestamp time.Time `json:"timestamp"`

	Type string `json:"type"`

	Success bool `json:"success"`

	Duration time.Duration `json:"duration"`

	ImprovementAchieved float64 `json:"improvementAchieved"`

	CostSavings float64 `json:"costSavings"`
}

type HyperparameterStrategy

type HyperparameterStrategy string
const (
	HyperparameterStrategyAdaptive HyperparameterStrategy = "adaptive"

	HyperparameterStrategyFixed HyperparameterStrategy = "fixed"

	HyperparameterStrategyScheduled HyperparameterStrategy = "scheduled"

	HyperparameterStrategyMetaLearning HyperparameterStrategy = "meta_learning"
)

type ImpactLevel

type ImpactLevel string
const (
	ImpactCritical ImpactLevel = "critical"

	ImpactHigh ImpactLevel = "high"

	ImpactMedium ImpactLevel = "medium"

	ImpactLow ImpactLevel = "low"

	ImpactMinimal ImpactLevel = "minimal"
)

type ImpactPredictor

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

ImpactPredictor uses machine learning to predict optimization impacts

func NewImpactPredictor

func NewImpactPredictor(logger logr.Logger) *ImpactPredictor

NewImpactPredictor creates a new impact predictor

func (*ImpactPredictor) PredictImpact

func (ip *ImpactPredictor) PredictImpact(
	strategy *OptimizationStrategyConfig,
	analysis *ComponentAnalysis,
	overallResult *PerformanceAnalysisResult,
) *ExpectedImpact

PredictImpact predicts the expected impact of implementing a strategy

type ImplementationStep

type ImplementationStep struct {
	Order int `json:"order"`

	Name string `json:"name"`

	Description string `json:"description"`

	EstimatedTime time.Duration `json:"estimatedTime"`

	AutomationLevel AutomationLevel `json:"automationLevel"`

	RequiredSkills []string `json:"requiredSkills,omitempty"`

	ValidationPoint bool `json:"validationPoint,omitempty"`

	RollbackAction string `json:"rollbackAction,omitempty"`
}

type IndexOptimizationRule

type IndexOptimizationRule struct {
	DataSize string `json:"dataSize"`

	QueryPattern string `json:"queryPattern"`

	OptimalIndexType string `json:"optimalIndexType"`

	Parameters map[string]int `json:"parameters"`
}

type InefficientResource

type InefficientResource struct {
	ResourceName string `json:"resourceName"`

	ComponentType shared.ComponentType `json:"componentType"`

	CurrentUtilization float64 `json:"currentUtilization"`

	OptimalUtilization float64 `json:"optimalUtilization"`

	WastedCapacity float64 `json:"wastedCapacity"`

	CostImpact float64 `json:"costImpact"`
}

type IntegrationTestConfig

type IntegrationTestConfig struct{}

type InterXAppCommConfig

type InterXAppCommConfig struct{}

type InterferenceManagement

type InterferenceManagement struct{}

type InteropConfig

type InteropConfig struct {
	VendorAdaptationLayer *VendorAdaptationConfig `json:"vendorAdaptationLayer"`

	ProtocolTranslation *ProtocolTranslationConfig `json:"protocolTranslation"`

	StandardsCompliance *ComplianceCheckConfig `json:"standardsCompliance"`

	IntegrationTesting *IntegrationTestConfig `json:"integrationTesting"`

	VersionCompatibility *VersionCompatibilityConfig `json:"versionCompatibility"`

	PerformanceNormalization *PerfNormalizationConfig `json:"performanceNormalization"`
}

type InteropMetrics

type InteropMetrics struct {
	VendorCompatibility map[string]float64 `json:"vendorCompatibility"`

	ProtocolCompliance float64 `json:"protocolCompliance"`

	IntegrationLatency time.Duration `json:"integrationLatency"`

	StandardsCompliance float64 `json:"standardsCompliance"`

	CrossVendorLatency time.Duration `json:"crossVendorLatency"`
}

type InteropOptimizer

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

func NewInteropOptimizer

func NewInteropOptimizer(config *InteropConfig, logger logr.Logger) *InteropOptimizer

func (*InteropOptimizer) OptimizeInterop

func (optimizer *InteropOptimizer) OptimizeInterop(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)

type IssueCategory

type IssueCategory string
const (
	IssueCategoryLatency IssueCategory = "latency"

	IssueCategoryThroughput IssueCategory = "throughput"

	IssueCategoryMemory IssueCategory = "memory"

	IssueCategoryCPU IssueCategory = "cpu"

	IssueCategoryNetwork IssueCategory = "network"

	IssueCategoryStorage IssueCategory = "storage"

	IssueCategoryAvailability IssueCategory = "availability"
)

type IssueResolution

type IssueResolution struct {
	ResolutionID string `json:"resolutionId"`

	Status ResolutionStatus `json:"status"`

	Actions []string `json:"actions"`

	ResolvedAt time.Time `json:"resolvedAt,omitempty"`

	ResolvedBy string `json:"resolvedBy"`

	VerificationSteps []string `json:"verificationSteps"`

	PreventionMeasures []string `json:"preventionMeasures"`
}

type K8sOptimizerConfig

type K8sOptimizerConfig struct {
	ResourceOptimizationRules []ResourceOptimizationRule `json:"resourceOptimizationRules"`

	SchedulingPolicies map[string]SchedulingPolicy `json:"schedulingPolicies"`

	NetworkingConfigs map[string]NetworkConfig `json:"networkingConfigs"`

	StorageConfigs map[string]StorageConfig `json:"storageConfigs"`
}

type Kernel

type Kernel interface {
	Compute(x1, x2 []float64, hyperparams map[string]float64) float64

	GetHyperparameters() []string
}

type KernelType

type KernelType string
const (
	KernelTypeRBF KernelType = "rbf"

	KernelTypeMatern KernelType = "matern"

	KernelTypeLinear KernelType = "linear"

	KernelTypePolynomial KernelType = "polynomial"
)

type KubernetesOptimizer

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

func NewKubernetesOptimizer

func NewKubernetesOptimizer(config *K8sOptimizerConfig, logger logr.Logger) *KubernetesOptimizer

func (*KubernetesOptimizer) GetOptimizationStrategies

func (opt *KubernetesOptimizer) GetOptimizationStrategies() []RecommendationStrategy

func (*KubernetesOptimizer) OptimizeConfiguration

func (opt *KubernetesOptimizer) OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)

func (*KubernetesOptimizer) RollbackOptimization

func (opt *KubernetesOptimizer) RollbackOptimization(ctx context.Context, result *OptimizationResult) error

func (*KubernetesOptimizer) ValidateOptimization

func (opt *KubernetesOptimizer) ValidateOptimization(ctx context.Context, result *OptimizationResult) error

type LLMOptimizerConfig

type LLMOptimizerConfig struct {
	OptimalTokenRanges map[string]TokenRange `json:"optimalTokenRanges"`

	TokenCompressionRatio float64 `json:"tokenCompressionRatio"`

	ModelPerformanceMap map[string]ModelPerformance `json:"modelPerformanceMap"`

	CostOptimizedModels []string `json:"costOptimizedModels"`

	CacheConfigurations map[string]CacheConfig `json:"cacheConfigurations"`

	TTLOptimizationRules []TTLRule `json:"ttlOptimizationRules"`

	ConnectionPoolSizes map[string]int `json:"connectionPoolSizes"`

	TimeoutConfigurations map[string]time.Duration `json:"timeoutConfigurations"`

	BatchSizeOptimization map[string]BatchConfig `json:"batchSizeOptimization"`
}

type LLMProcessorOptimizer

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

func NewLLMProcessorOptimizer

func NewLLMProcessorOptimizer(config *LLMOptimizerConfig, logger logr.Logger) *LLMProcessorOptimizer

func (*LLMProcessorOptimizer) GetOptimizationStrategies

func (opt *LLMProcessorOptimizer) GetOptimizationStrategies() []RecommendationStrategy

func (*LLMProcessorOptimizer) OptimizeConfiguration

func (opt *LLMProcessorOptimizer) OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)

func (*LLMProcessorOptimizer) RollbackOptimization

func (opt *LLMProcessorOptimizer) RollbackOptimization(ctx context.Context, result *OptimizationResult) error

func (*LLMProcessorOptimizer) ValidateOptimization

func (opt *LLMProcessorOptimizer) ValidateOptimization(ctx context.Context, result *OptimizationResult) error

type LatencyMetrics

type LatencyMetrics struct {
	P50 time.Duration `json:"p50"`

	P95 time.Duration `json:"p95"`

	P99 time.Duration `json:"p99"`

	P999 time.Duration `json:"p999"`

	Mean time.Duration `json:"mean"`

	Max time.Duration `json:"max"`

	Min time.Duration `json:"min"`
}

type LatencyOptimizationConfig

type LatencyOptimizationConfig struct{}

type LearningIteration

type LearningIteration struct {
	Iteration int `json:"iteration"`

	Timestamp time.Time `json:"timestamp"`

	Configuration *SystemConfiguration `json:"configuration"`

	Performance *PerformanceMetrics `json:"performance"`

	Improvement float64 `json:"improvement"`

	ExplorationRatio float64 `json:"explorationRatio"`

	ConvergenceMetric float64 `json:"convergenceMetric"`

	Algorithm OptimizationAlgorithmType `json:"algorithm"`
}

type LoadBalancingStrategy

type LoadBalancingStrategy string

type MLMetrics

type MLMetrics struct {
	PolicyLoss    float64       `json:"policy_loss"`
	ValueLoss     float64       `json:"value_loss"`
	KLDivergence  float64       `json:"kl_divergence"`
	RewardMean    float64       `json:"reward_mean"`
	RewardStd     float64       `json:"reward_std"`
	EpisodesTotal int64         `json:"episodes_total"`
	TrainingTime  time.Duration `json:"training_time"`
	LastUpdate    time.Time     `json:"last_update"`
}

MLMetrics tracks optimization performance

type MLModelMetadata

type MLModelMetadata struct {
	ModelID string `json:"modelId"`

	Name string `json:"name"`

	Type string `json:"type"`

	Version string `json:"version"`

	ComponentTypes []shared.ComponentType `json:"componentTypes"`

	Accuracy float64 `json:"accuracy"`

	TrainedOn time.Time `json:"trainedOn"`

	LastValidated time.Time `json:"lastValidated"`

	Parameters json.RawMessage `json:"parameters"`

	InputFeatures []string `json:"inputFeatures"`

	OutputFormat string `json:"outputFormat"`
}

type MLOptimizationEngine

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

MLOptimizationEngine implements Proximal Policy Optimization (PPO) for network resource optimization

func NewMLOptimizationEngine

func NewMLOptimizationEngine(logger logr.Logger) *MLOptimizationEngine

NewMLOptimizationEngine creates a new ML-driven optimization engine

func (*MLOptimizationEngine) AddExperience

func (m *MLOptimizationEngine) AddExperience(state NetworkState, action OptimizationAction, reward float64, nextState NetworkState)

AddExperience stores a new experience for training

func (*MLOptimizationEngine) GetMetrics

func (m *MLOptimizationEngine) GetMetrics() MLMetrics

GetMetrics returns current ML optimization metrics

func (*MLOptimizationEngine) PredictAction

PredictAction uses the policy network to predict the best action

func (*MLOptimizationEngine) Stop

func (m *MLOptimizationEngine) Stop() error

Stop gracefully stops the ML optimization engine

func (*MLOptimizationEngine) TrainModel

func (m *MLOptimizationEngine) TrainModel() error

TrainModel performs PPO training on collected experiences

type MLOptimizationModel

type MLOptimizationModel struct {
	ModelID     string                 `json:"modelId"`
	ModelType   string                 `json:"modelType"`
	Version     string                 `json:"version"`
	Accuracy    float64                `json:"accuracy"`
	LastTrained time.Time              `json:"lastTrained"`
	Parameters  map[string]interface{} `json:"parameters"`
}

MLOptimizationModel represents an ML model for optimization

type MessageRoutingConfig

type MessageRoutingConfig struct{}

type MetricAnalysis

type MetricAnalysis struct {
	MetricName string `json:"metricName"`

	CurrentValue float64 `json:"currentValue"`

	TargetValue float64 `json:"targetValue"`

	Deviation float64 `json:"deviation"`

	Statistics *MetricStatistics `json:"statistics"`

	Trend *TrendAnalysis `json:"trend"`

	AnomalyScore float64 `json:"anomalyScore"`

	IsAnomalous bool `json:"isAnomalous"`

	Correlations []*MetricCorrelation `json:"correlations"`

	Forecast *MetricForecast `json:"forecast"`
}

type MetricAnomaly

type MetricAnomaly struct {
	MetricName string `json:"metricName"`

	ComponentType shared.ComponentType `json:"componentType"`

	AnomalyType AnomalyType `json:"anomalyType"`

	DetectedAt time.Time `json:"detectedAt"`

	Severity SeverityLevel `json:"severity"`

	Description string `json:"description"`

	ExpectedValue float64 `json:"expectedValue"`

	ActualValue float64 `json:"actualValue"`

	AnomalyScore float64 `json:"anomalyScore"`
}

type MetricConfig

type MetricConfig struct {
	Name string `json:"name"`

	PrometheusQuery string `json:"prometheusQuery"`

	AnalysisType AnalysisType `json:"analysisType"`

	Weight float64 `json:"weight"`

	Target float64 `json:"target"`
}

type MetricCorrelation

type MetricCorrelation struct {
	MetricName string `json:"metricName"`

	CorrelationCoefficient float64 `json:"correlationCoefficient"`

	PValue float64 `json:"pValue"`

	IsSignificant bool `json:"isSignificant"`

	LagTime time.Duration `json:"lagTime"`
}

type MetricForecast

type MetricForecast struct {
	ForecastHorizon time.Duration `json:"forecastHorizon"`

	PredictedValues []ForecastPoint `json:"predictedValues"`

	ConfidenceIntervals []ConfidenceInterval `json:"confidenceIntervals"`

	ModelAccuracy float64 `json:"modelAccuracy"`

	ModelType string `json:"modelType"`
}

type MetricStatistics

type MetricStatistics struct {
	Mean float64 `json:"mean"`

	Median float64 `json:"median"`

	StandardDeviation float64 `json:"standardDeviation"`

	Percentiles map[int]float64 `json:"percentiles"`

	Min float64 `json:"min"`

	Max float64 `json:"max"`

	Variance float64 `json:"variance"`
}

type MetricTrend

type MetricTrend struct {
	MetricName string `json:"metricName"`

	TrendType string `json:"trendType"`

	Direction string `json:"direction"`

	ChangeRate float64 `json:"changeRate"`

	Confidence float64 `json:"confidence"`

	TimeHorizon time.Duration `json:"timeHorizon"`

	Forecast []float64 `json:"forecast"`

	InflectionPoints []time.Time `json:"inflectionPoints"`
}

type MetricsCache

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

func NewMetricsCache

func NewMetricsCache(ttl time.Duration) *MetricsCache

type MetricsStore

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

MetricsStore stores metrics data for analysis

func NewMetricsStore

func NewMetricsStore() *MetricsStore

NewMetricsStore creates a new metrics store

type MitigationStrategy

type MitigationStrategy struct {
	Name            string        `json:"name"`
	Description     string        `json:"description"`
	Effectiveness   float64       `json:"effectiveness"` // 0.0 to 1.0
	Cost            float64       `json:"cost"`
	TimeToImplement time.Duration `json:"timeToImplement"`
	Priority        int           `json:"priority"`
	Prerequisites   []string      `json:"prerequisites,omitempty"`
	Steps           []string      `json:"steps,omitempty"`
}

MitigationStrategy represents a strategy to mitigate risks

type ModelPerformance

type ModelPerformance struct {
	Name string `json:"name"`

	AverageLatency time.Duration `json:"averageLatency"`

	TokensPerSecond float64 `json:"tokensPerSecond"`

	AccuracyScore float64 `json:"accuracyScore"`

	CostPerToken float64 `json:"costPerToken"`

	MaxContextLength int `json:"maxContextLength"`

	OptimalBatchSize int `json:"optimalBatchSize"`
}

type NSSFConfig

type NSSFConfig struct {
	SliceSelectionCriteria []SliceSelectionCriterion `json:"sliceSelectionCriteria"`

	SliceAvailabilityTracking bool `json:"sliceAvailabilityTracking"`

	LoadBalancingEnabled bool `json:"loadBalancingEnabled"`

	DynamicSliceAllocation bool `json:"dynamicSliceAllocation"`

	SliceIsolationLevel SliceIsolationLevel `json:"sliceIsolationLevel"`

	ResourceAllocationPolicy ResourceAllocationPolicy `json:"resourceAllocationPolicy"`
}

type NearRTRICConfig

type NearRTRICConfig struct {
	ProcessingLatencyTarget time.Duration `json:"processingLatencyTarget"`

	ControlLoopFrequency time.Duration `json:"controlLoopFrequency"`

	XAppSchedulingPolicy XAppSchedulingPolicy `json:"xAppSchedulingPolicy"`

	ConflictResolutionPolicy ConflictResolutionPolicy `json:"conflictResolutionPolicy"`

	ResourceAllocation *RICResourceAllocation `json:"resourceAllocation"`

	MessageRouting *MessageRoutingConfig `json:"messageRouting"`

	HighAvailabilityConfig *HAConfig `json:"highAvailabilityConfig"`
}

type NetworkConfig

type NetworkConfig struct {
	ServiceMesh bool `json:"serviceMesh"`

	CNI string `json:"cni"`

	LoadBalancerType string `json:"loadBalancerType"`

	IngressController string `json:"ingressController"`

	NetworkPolicies bool `json:"networkPolicies"`
}

type NetworkOptimizationProfile

type NetworkOptimizationProfile struct {
	ProfileName       string                 `json:"profileName"`
	MaxConnections    int                    `json:"maxConnections"`
	ConnectionTimeout time.Duration          `json:"connectionTimeout"`
	RetryPolicy       string                 `json:"retryPolicy"`
	LoadBalancing     string                 `json:"loadBalancing"`
	Settings          map[string]interface{} `json:"settings"`
}

NetworkOptimizationProfile represents network optimization settings

type NetworkSliceConfig

type NetworkSliceConfig struct {
	SliceTemplates map[string]*SliceTemplate `json:"sliceTemplates"`

	ResourcePooling *ResourcePoolingConfig `json:"resourcePooling"`

	SliceIsolation *SliceIsolationConfig `json:"sliceIsolation"`

	QoSDifferentiation *QoSDifferentiationConfig `json:"qosDifferentiation"`

	AutoScaling *SliceAutoScalingConfig `json:"autoScaling"`

	Performance *SlicePerformanceConfig `json:"performance"`
}

type NetworkSliceOptimizer

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

func NewNetworkSliceOptimizer

func NewNetworkSliceOptimizer(config *NetworkSliceConfig, logger logr.Logger) *NetworkSliceOptimizer

func (*NetworkSliceOptimizer) OptimizeSlicing

func (optimizer *NetworkSliceOptimizer) OptimizeSlicing(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)

type NetworkState

type NetworkState struct {
	CPUUtilization    float64   `json:"cpu_utilization"`
	MemoryUtilization float64   `json:"memory_utilization"`
	NetworkLatency    float64   `json:"network_latency"`
	PacketLoss        float64   `json:"packet_loss"`
	ThroughputMbps    float64   `json:"throughput_mbps"`
	ActiveConnections int64     `json:"active_connections"`
	ErrorRate         float64   `json:"error_rate"`
	Timestamp         time.Time `json:"timestamp"`
}

NetworkState represents the current state of network resources

type NonRTRICConfig

type NonRTRICConfig struct{}

type NotificationConfig

type NotificationConfig struct {
	EnableNotifications bool `json:"enableNotifications"`

	EmailConfig *EmailConfig `json:"emailConfig,omitempty"`

	WebhookConfig *WebhookConfig `json:"webhookConfig,omitempty"`

	SlackConfig *SlackConfig `json:"slackConfig,omitempty"`
}

type ObjectivePriority

type ObjectivePriority string
const (
	ObjectivePriorityCritical ObjectivePriority = "critical"

	ObjectivePriorityHigh ObjectivePriority = "high"

	ObjectivePriorityMedium ObjectivePriority = "medium"

	ObjectivePriorityLow ObjectivePriority = "low"
)

type ObjectiveType

type ObjectiveType string
const (
	ObjectiveTypeMinimize ObjectiveType = "minimize"

	ObjectiveTypeMaximize ObjectiveType = "maximize"

	ObjectiveTypeTarget ObjectiveType = "target"
)

type Observation

type Observation struct {
	Input []float64 `json:"input"`

	Output float64 `json:"output"`

	Noise float64 `json:"noise"`
}

type OpportunityPriority

type OpportunityPriority string
const (
	OpportunityPriorityLow OpportunityPriority = "low"

	OpportunityPriorityMedium OpportunityPriority = "medium"

	OpportunityPriorityHigh OpportunityPriority = "high"

	OpportunityPriorityCritical OpportunityPriority = "critical"
)

type OpportunityRiskAssessment

type OpportunityRiskAssessment struct {
	OverallRisk RiskLevel `json:"overallRisk"` // Using existing RiskLevel type

	RiskFactors []OpportunityRiskFactor `json:"riskFactors"`

	MitigationStrategies []string `json:"mitigationStrategies"`

	ImpactAnalysis *RiskImpactAnalysis `json:"impactAnalysis"`

	ApprovalRequired bool `json:"approvalRequired"`

	BackupPlan string `json:"backupPlan"`
}

type OpportunityRiskFactor

type OpportunityRiskFactor struct {
	Name string `json:"name"`

	Description string `json:"description"`

	Probability float64 `json:"probability"`

	Impact float64 `json:"impact"`

	Category string `json:"category"`

	Mitigation string `json:"mitigation"`

	Contingency string `json:"contingency"`
}

type OptimizationAction

type OptimizationAction int

OptimizationAction defines possible optimization actions

const (
	ActionScaleUp OptimizationAction = iota
	ActionScaleDown
	ActionRebalance
	ActionOptimizeLatency
	ActionOptimizeThroughput
	ActionNoAction
)

type OptimizationAlgorithm

type OptimizationAlgorithm interface {
	Initialize(configSpace *ConfigurationSpace, objectives []OptimizationObjective) error

	SuggestConfiguration(ctx context.Context, history []*LearningIteration) (*SystemConfiguration, error)

	UpdateModel(ctx context.Context, iteration *LearningIteration) error

	IsConverged(ctx context.Context, history []*LearningIteration) (bool, float64)

	GetName() string

	GetHyperparameters() map[string]interface{}

	SetHyperparameters(params map[string]interface{}) error
}

type OptimizationAlgorithmType

type OptimizationAlgorithmType string
const (
	AlgorithmBayesianOptimization OptimizationAlgorithmType = "bayesian_optimization"

	AlgorithmGeneticAlgorithm OptimizationAlgorithmType = "genetic_algorithm"

	AlgorithmReinforcementLearning OptimizationAlgorithmType = "reinforcement_learning"

	AlgorithmGradientDescent OptimizationAlgorithmType = "gradient_descent"

	AlgorithmSimulatedAnnealing OptimizationAlgorithmType = "simulated_annealing"

	AlgorithmParticleSwarmOptimization OptimizationAlgorithmType = "particle_swarm"

	AlgorithmRandomSearch OptimizationAlgorithmType = "random_search"

	AlgorithmGridSearch OptimizationAlgorithmType = "grid_search"

	AlgorithmHyperband OptimizationAlgorithmType = "hyperband"

	AlgorithmTPE OptimizationAlgorithmType = "tree_parzen_estimator"
)

type OptimizationBestPractice

type OptimizationBestPractice struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	ComponentType shared.ComponentType `json:"componentType"`

	Category OptimizationCategory `json:"category"`

	Priority int `json:"priority"`

	ApplicableWhen []string `json:"applicableWhen"`

	Implementation string `json:"implementation"`

	ExpectedBenefit float64 `json:"expectedBenefit"`

	RiskLevel string `json:"riskLevel"`

	ValidationSteps []string `json:"validationSteps"`
}

type OptimizationCategory

type OptimizationCategory string
const (
	CategoryPerformance OptimizationCategory = "performance"

	CategoryResource OptimizationCategory = "resource"

	CategoryCost OptimizationCategory = "cost"

	CategoryReliability OptimizationCategory = "reliability"

	CategorySecurity OptimizationCategory = "security"

	CategoryCompliance OptimizationCategory = "compliance"

	CategoryMaintenance OptimizationCategory = "maintenance"

	CategoryTelecommunications OptimizationCategory = "telecommunications"
)

type OptimizationDashboard

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

func NewOptimizationDashboard

func NewOptimizationDashboard(
	config *DashboardConfig,

	pipeline *AutomatedOptimizationPipeline,

	analysisEngine *PerformanceAnalysisEngine,

	logger logr.Logger,
) *OptimizationDashboard

func (*OptimizationDashboard) Start

func (dashboard *OptimizationDashboard) Start(ctx context.Context) error

func (*OptimizationDashboard) Stop

func (dashboard *OptimizationDashboard) Stop(ctx context.Context) error

type OptimizationEngine

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

func NewOptimizationEngine

func NewOptimizationEngine(config *AITunerConfig, logger logr.Logger) *OptimizationEngine

func (*OptimizationEngine) Initialize

func (oe *OptimizationEngine) Initialize(space *ConfigurationSpace, objectives []OptimizationObjective) error

func (*OptimizationEngine) SuggestConfiguration

func (oe *OptimizationEngine) SuggestConfiguration(ctx context.Context, history []*LearningIteration) (*SystemConfiguration, error)

func (*OptimizationEngine) UpdateModel

func (oe *OptimizationEngine) UpdateModel(ctx context.Context, iteration *LearningIteration) error

type OptimizationExecution

type OptimizationExecution struct {
	Request *OptimizationRequest `json:"request"`

	Status ExecutionStatus `json:"status"`

	StartTime time.Time `json:"startTime"`

	EndTime time.Time `json:"endTime,omitempty"`

	Progress *ExecutionProgress `json:"progress"`

	Results []*OptimizationResult `json:"results"`

	Errors []error `json:"errors,omitempty"`
}

type OptimizationHistoryEntry

type OptimizationHistoryEntry struct {
	Timestamp time.Time `json:"timestamp"`

	ComponentType shared.ComponentType `json:"componentType"`

	OptimizationType string `json:"optimizationType"`

	BeforeMetrics map[string]float64 `json:"beforeMetrics"`

	AfterMetrics map[string]float64 `json:"afterMetrics"`

	ImprovementPct float64 `json:"improvementPct"`

	Success bool `json:"success"`

	FailureReason string `json:"failureReason,omitempty"`

	Duration time.Duration `json:"duration"`
}

type OptimizationKnowledgeBase

type OptimizationKnowledgeBase struct {
	BestPractices map[shared.ComponentType][]*OptimizationBestPractice `json:"bestPractices"`

	OptimizationHistory []*OptimizationHistoryEntry `json:"optimizationHistory"`

	KnownBottlenecks map[string]*BottleneckSolution `json:"knownBottlenecks"`

	TelecomRules []*TelecomOptimizationRule `json:"telecomRules"`

	ModelMetadata map[string]*MLModelMetadata `json:"modelMetadata"`

	ComplianceRequirements []*ComplianceRequirement `json:"complianceRequirements"`

	LastUpdated time.Time `json:"lastUpdated"`
}

func NewOptimizationKnowledgeBase

func NewOptimizationKnowledgeBase() *OptimizationKnowledgeBase

NewOptimizationKnowledgeBase creates a new knowledge base Note: OptimizationKnowledgeBase type is defined in types.go

type OptimizationMetricsCollector

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

func NewOptimizationMetricsCollector

func NewOptimizationMetricsCollector(pipeline *AutomatedOptimizationPipeline, logger logr.Logger) *OptimizationMetricsCollector

func (*OptimizationMetricsCollector) UpdateMetrics

func (collector *OptimizationMetricsCollector) UpdateMetrics(ctx context.Context)

type OptimizationObjective

type OptimizationObjective struct {
	Name string `json:"name"`

	Type ObjectiveType `json:"type"`

	Weight float64 `json:"weight"`

	Target float64 `json:"target,omitempty"`

	Tolerance float64 `json:"tolerance,omitempty"`

	Priority ObjectivePriority `json:"priority"`
}

type OptimizationOpportunity

type OptimizationOpportunity struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	ComponentType shared.ComponentType `json:"componentType"`

	Category OptimizationCategory `json:"category"`

	Priority OpportunityPriority `json:"priority"`

	EstimatedImprovement *EstimatedImprovement `json:"estimatedImprovement"`

	RiskAssessment *OpportunityRiskAssessment `json:"riskAssessment"`

	ROIAnalysis *ROIAnalysis `json:"roiAnalysis"`

	Dependencies []string `json:"dependencies"`

	Prerequisites []string `json:"prerequisites"`

	ValidationCriteria []string `json:"validationCriteria"`

	DetectedAt time.Time `json:"detectedAt"`

	EstimatedCompletion time.Duration `json:"estimatedCompletion"`
}

type OptimizationPriority

type OptimizationPriority string

OptimizationPriority represents the priority level of optimizations

const (
	PriorityCritical OptimizationPriority = "critical"
	PriorityHigh     OptimizationPriority = "high"
	PriorityMedium   OptimizationPriority = "medium"
	PriorityLow      OptimizationPriority = "low"
)

type OptimizationQueue

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

func (*OptimizationQueue) Dequeue

func (q *OptimizationQueue) Dequeue() *OptimizationRequest

func (*OptimizationQueue) Enqueue

func (q *OptimizationQueue) Enqueue(req *OptimizationRequest)

func (*OptimizationQueue) Size

func (q *OptimizationQueue) Size() int

type OptimizationRanker

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

OptimizationRanker ranks optimization opportunities

func NewOptimizationRanker

func NewOptimizationRanker(config *AnalysisConfig, logger logr.Logger) *OptimizationRanker

NewOptimizationRanker creates a new optimization ranker

type OptimizationRecommendation

type OptimizationRecommendation struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Title string `json:"title"`

	Description string `json:"description"`

	Category OptimizationCategory `json:"category"`

	Priority OptimizationPriority `json:"priority"`

	Impact ExpectedBenefits `json:"impact"`

	RiskLevel RiskLevel `json:"riskLevel"`

	RiskScore float64 `json:"riskScore"`

	Steps []ImplementationStep `json:"steps"`

	ImplementationSteps []ImplementationStep `json:"implementationSteps"`

	Automation AutomationLevel `json:"automationLevel"`

	Metadata json.RawMessage `json:"metadata,omitempty"`
}

func (*OptimizationRecommendation) GetComponentType

func (o *OptimizationRecommendation) GetComponentType() ComponentType

Add missing fields to OptimizationRecommendation

func (*OptimizationRecommendation) GetEstimatedImpact

func (o *OptimizationRecommendation) GetEstimatedImpact() *ExpectedImpact

EstimatedImpact field accessor

func (*OptimizationRecommendation) GetOptimizationType

func (o *OptimizationRecommendation) GetOptimizationType() string

type OptimizationRecommendationEngine

type OptimizationRecommendationEngine interface {
	GenerateRecommendations(ctx, data interface{}) ([]*OptimizationRecommendation, error)

	UpdateRecommendations(recommendations []*OptimizationRecommendation) error
}

type OptimizationRequest

type OptimizationRequest struct {
	ID string `json:"id"`

	Priority OptimizationPriority `json:"priority"`

	Recommendations []*OptimizationRecommendation `json:"recommendations"`

	RequestedBy string `json:"requestedBy"`

	ScheduledTime time.Time `json:"scheduledTime"`

	Deadline time.Time `json:"deadline,omitempty"`

	Context json.RawMessage `json:"context"`

	AutoApproved bool `json:"autoApproved"`
}

type OptimizationResult

type OptimizationResult struct {
	ComponentType shared.ComponentType `json:"componentType"`

	AppliedStrategies []string `json:"appliedStrategies"`

	ConfigChanges json.RawMessage `json:"configChanges"`

	ExpectedImpact *ExpectedImpact `json:"expectedImpact"`

	ValidationMetrics []string `json:"validationMetrics"`

	RollbackData json.RawMessage `json:"rollbackData"`

	Timestamp time.Time `json:"timestamp"`
}

type OptimizationRiskAssessment

type OptimizationRiskAssessment struct {
	OverallRiskLevel RiskLevel `json:"overallRiskLevel"`

	ImplementationRisk float64 `json:"implementationRisk"`

	PerformanceRisk float64 `json:"performanceRisk"`

	AvailabilityRisk float64 `json:"availabilityRisk"`

	SecurityRisk float64 `json:"securityRisk"`

	ComplianceRisk float64 `json:"complianceRisk"`

	IdentifiedRisks []RecommendationRiskFactor `json:"identifiedRisks"`

	MitigationStrategies []RecommendationMitigationStrategy `json:"mitigationStrategies"`

	RiskScoreBreakdown map[string]float64 `json:"riskScoreBreakdown"`
}

func ConvertRiskAssessment

func ConvertRiskAssessment(ra *RiskAssessment) *OptimizationRiskAssessment

type OptimizationRollbackManager

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

func (*OptimizationRollbackManager) Rollback

func (rm *OptimizationRollbackManager) Rollback(ctx context.Context, optimizationID string) error

func (*OptimizationRollbackManager) SaveRollbackData

func (rm *OptimizationRollbackManager) SaveRollbackData(optimizationID string, original, modified runtime.Object, data interface{})

type OptimizationRuleAction

type OptimizationRuleAction struct {
	ActionType string `json:"actionType"`

	Parameters map[string]string `json:"parameters"`

	AutoExecute bool `json:"autoExecute"`

	RequireApproval bool `json:"requireApproval"`

	NotificationLevel string `json:"notificationLevel"`
}

type OptimizationRuleCondition

type OptimizationRuleCondition struct {
	MetricName string `json:"metricName"`

	Operator string `json:"operator"`

	ThresholdValue float64 `json:"thresholdValue"`

	TimeWindow time.Duration `json:"timeWindow"`

	Severity string `json:"severity"`
}

type OptimizationSolution

type OptimizationSolution struct {
	Name string `json:"name"`

	Description string `json:"description"`

	Steps []string `json:"steps"`

	EstimatedTime time.Duration `json:"estimatedTime"`

	Complexity string `json:"complexity"` // "low", "medium", "high"

	SuccessRate float64 `json:"successRate"`

	Prerequisites []string `json:"prerequisites"`

	RollbackSteps []string `json:"rollbackSteps"`
}

type OptimizationStats

type OptimizationStats struct {
	TotalRun int `json:"totalRun"`

	Successful int `json:"successful"`

	Failed int `json:"failed"`

	AverageSuccessRate float64 `json:"averageSuccessRate"`

	AverageDuration time.Duration `json:"averageDuration"`

	LastSuccess time.Time `json:"lastSuccess"`

	LastFailure time.Time `json:"lastFailure"`

	TotalLatencyReduction float64 `json:"totalLatencyReduction"`

	TotalCostSavings float64 `json:"totalCostSavings"`

	TotalEfficiencyGain float64 `json:"totalEfficiencyGain"`
}

type OptimizationStatusData

type OptimizationStatusData struct {
	PipelineStatus string `json:"pipelineStatus"`

	QueuedOptimizations int `json:"queuedOptimizations"`

	RunningOptimizations []*RunningOptimization `json:"runningOptimizations"`

	OptimizationStats *OptimizationStats `json:"optimizationStats"`

	AutoOptimizationEnabled bool `json:"autoOptimizationEnabled"`

	LastAnalysis time.Time `json:"lastAnalysis"`

	NextAnalysis time.Time `json:"nextAnalysis"`
}

type OptimizationStrategy

type OptimizationStrategy string
const (
	OptimizationStrategyLBFGS OptimizationStrategy = "lbfgs"

	OptimizationStrategyDifferentialEvolution OptimizationStrategy = "differential_evolution"

	OptimizationStrategyDirectSearch OptimizationStrategy = "direct_search"
)

type OptimizationStrategyConfig

type OptimizationStrategyConfig struct {
	ID                  string               `json:"id"`
	Name                string               `json:"name"`
	Description         string               `json:"description"`
	Category            OptimizationCategory `json:"category"`
	TargetComponent     ComponentType        `json:"targetComponent"`
	Priority            OptimizationPriority `json:"priority"`
	ExpectedBenefits    *ExpectedBenefits    `json:"expectedBenefits"`
	ImplementationSteps []ImplementationStep `json:"implementationSteps"`
	RiskFactors         []string             `json:"riskFactors"`
	RiskLevel           RiskLevel            `json:"riskLevel"`
	Confidence          float64              `json:"confidence"`
	EstimatedDuration   time.Duration        `json:"estimatedDuration"`
	ValidationCriteria  []string             `json:"validationCriteria"`
	RollbackPlan        string               `json:"rollbackPlan"`
	ApprovalRequired    bool                 `json:"approvalRequired"`
	CreatedAt           time.Time            `json:"createdAt"`
	UpdatedAt           time.Time            `json:"updatedAt"`
}

OptimizationStrategyConfig represents a complete optimization strategy configuration Note: OptimizationStrategy already exists as a string type in ai_configuration_tuner.go

type OptimizationValidator

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

OptimizationValidator validates optimization results

func (*OptimizationValidator) ValidateOptimization

func (v *OptimizationValidator) ValidateOptimization(ctx context.Context, result *OptimizationResult) error

ValidateOptimization validates an optimization result

type OptimizerManager

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

OptimizerManager manages optimization processes

type PacketProcessingMode

type PacketProcessingMode string

type ParameterDependency

type ParameterDependency struct {
	ParentParameter string `json:"parentParameter"`

	ChildParameter string `json:"childParameter"`

	DependencyType ParameterDependencyType `json:"dependencyType"`

	Conditions []DependencyCondition `json:"conditions"`
}

type ParameterDependencyType

type ParameterDependencyType string
const (
	DependencyTypeConditional ParameterDependencyType = "conditional"

	DependencyTypeHierarchical ParameterDependencyType = "hierarchical"

	DependencyTypeMutualExclusion ParameterDependencyType = "mutual_exclusion"
)

type ParameterOptimizer

type ParameterOptimizer struct{}

func NewParameterOptimizer

func NewParameterOptimizer(config *AITunerConfig, logger logr.Logger) *ParameterOptimizer

type ParameterPriority

type ParameterPriority string
const (
	ParameterPriorityCritical ParameterPriority = "critical"

	ParameterPriorityHigh ParameterPriority = "high"

	ParameterPriorityMedium ParameterPriority = "medium"

	ParameterPriorityLow ParameterPriority = "low"
)

type ParameterRange

type ParameterRange struct {
	Min float64 `json:"min"`

	Max float64 `json:"max"`

	Step float64 `json:"step,omitempty"`

	LogScale bool `json:"logScale,omitempty"`
}

type ParameterSpace

type ParameterSpace struct {
	Name string `json:"name"`

	Type ParameterType `json:"type"`

	Range *ParameterRange `json:"range,omitempty"`

	DiscreteValues []interface{} `json:"discreteValues,omitempty"`

	DefaultValue interface{} `json:"defaultValue"`

	Priority ParameterPriority `json:"priority"`

	SearchHint SearchHint `json:"searchHint"`

	TransformFunction string `json:"transformFunction,omitempty"`

	ValidationRules []ValidationRule `json:"validationRules"`
}

type ParameterType

type ParameterType string
const (
	ParameterTypeInteger ParameterType = "integer"

	ParameterTypeFloat ParameterType = "float"

	ParameterTypeBoolean ParameterType = "boolean"

	ParameterTypeCategorical ParameterType = "categorical"

	ParameterTypeOrdinal ParameterType = "ordinal"
)

type PatternDetector

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

PatternDetector detects patterns in performance data

func NewPatternDetector

func NewPatternDetector(sensitivity float64, window time.Duration) *PatternDetector

NewPatternDetector creates a new pattern detector

func (*PatternDetector) DetectPatterns

func (pd *PatternDetector) DetectPatterns(ctx context.Context, store *MetricsStore) ([]*PerformancePattern, error)

DetectPatterns detects patterns in metrics data

type PatternType

type PatternType string
const (
	PatternTypeCyclical PatternType = "cyclical"

	PatternTypeSpike PatternType = "spike"

	PatternTypeGradualDegradation PatternType = "gradual_degradation"

	PatternTypeThresholdBreach PatternType = "threshold_breach"

	PatternTypeCorrelatedFailure PatternType = "correlated_failure"

	PatternTypeLoadImbalance PatternType = "load_imbalance"
)

type PerfNormalizationConfig

type PerfNormalizationConfig struct{}

type PerformanceAnalysisEngine

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

func NewPerformanceAnalysisEngine

func NewPerformanceAnalysisEngine(config *AnalysisConfig, prometheusClient v1.API, logger logr.Logger) *PerformanceAnalysisEngine

func (*PerformanceAnalysisEngine) AnalyzePerformance

func (engine *PerformanceAnalysisEngine) AnalyzePerformance(ctx context.Context) (*PerformanceAnalysisResult, error)

func (*PerformanceAnalysisEngine) GetPerformanceBaseline

func (engine *PerformanceAnalysisEngine) GetPerformanceBaseline(ctx context.Context) (*PerformanceBaseline, error)

type PerformanceAnalysisResult

type PerformanceAnalysisResult struct {
	Timestamp time.Time `json:"timestamp"`

	AnalysisID string `json:"analysisId"`

	SystemHealth SystemHealthStatus `json:"systemHealth"`

	OverallScore float64 `json:"overallScore"`

	ComponentAnalyses map[shared.ComponentType]*ComponentAnalysis `json:"componentAnalyses"`

	IdentifiedBottlenecks []*PerformanceBottleneck `json:"identifiedBottlenecks"`

	PredictedBottlenecks []*PredictedBottleneck `json:"predictedBottlenecks"`

	DetectedPatterns []*PerformancePattern `json:"detectedPatterns"`

	AnomalousMetrics []*MetricAnomaly `json:"anomalousMetrics"`

	PerformanceTrends []*PerformanceTrend `json:"performanceTrends"`

	CapacityPredictions []*CapacityPrediction `json:"capacityPredictions"`

	ResourceEfficiency *ResourceEfficiencyAnalysis `json:"resourceEfficiency"`

	WasteAnalysis *ResourceWasteAnalysis `json:"wasteAnalysis"`

	CostAnalysis *CostAnalysis `json:"costAnalysis"`

	TelecomMetrics *TelecomPerformanceAnalysis `json:"telecomMetrics"`

	RecommendationsSummary *RecommendationsSummary `json:"recommendationsSummary"`
}

type PerformanceAnalyzer

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

PerformanceAnalyzer performs system performance analysis

func NewPerformanceAnalyzer

func NewPerformanceAnalyzer(logger logr.Logger, k8sClient client.Client, clientset kubernetes.Interface, prometheusClient v1.API) *PerformanceAnalyzer

NewPerformanceAnalyzer creates a new performance analyzer

type PerformanceBaseline

type PerformanceBaseline struct {
	ComponentType   ComponentType       `json:"componentType"`
	Timestamp       time.Time           `json:"timestamp"`
	Metrics         map[string]float64  `json:"metrics"`
	ResourceUsage   ResourceUtilization `json:"resourceUsage"`
	ThroughputRate  float64             `json:"throughputRate"`
	ResponseTime    time.Duration       `json:"responseTime"`
	ErrorRate       float64             `json:"errorRate"`
	BaselineVersion string              `json:"baselineVersion"`
	EnvironmentInfo map[string]string   `json:"environmentInfo"`
}

PerformanceBaseline represents a performance baseline for comparison

func (*PerformanceBaseline) GetSystemConfiguration

func (pb *PerformanceBaseline) GetSystemConfiguration() map[string]string

Add missing PerformanceBaseline fields

func (*PerformanceBaseline) GetValidityPeriod

func (pb *PerformanceBaseline) GetValidityPeriod() time.Duration

type PerformanceBenchmark

type PerformanceBenchmark struct {
	BenchmarkSuite string `json:"benchmarkSuite"`

	Version string `json:"version"`

	ExecutionTime time.Time `json:"executionTime"`

	Duration time.Duration `json:"duration"`

	Results map[string]float64 `json:"results"`

	Percentile float64 `json:"percentile"`

	Ranking int `json:"ranking"`

	BaselineComparison map[string]float64 `json:"baselineComparison"`

	Environment *BenchmarkEnvironment `json:"environment"`
}

type PerformanceBottleneck

type PerformanceBottleneck struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	ComponentType shared.ComponentType `json:"componentType"`

	Severity SeverityLevel `json:"severity"` // Using existing SeverityLevel type

	AffectedMetrics []string `json:"affectedMetrics"`

	RootCause string `json:"rootCause"`

	ImpactScore float64 `json:"impactScore"`

	DetectedAt time.Time `json:"detectedAt"`

	Duration time.Duration `json:"duration"`

	AffectedComponents []shared.ComponentType `json:"affectedComponents"`

	RecommendedActions []string `json:"recommendedActions"`

	PredictedGrowth float64 `json:"predictedGrowth"`

	BusinessImpact string `json:"businessImpact"`
}

type PerformanceForecaster

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

PerformanceForecaster forecasts performance metrics

func NewPerformanceForecaster

func NewPerformanceForecaster(config *AnalysisConfig, logger logr.Logger) *PerformanceForecaster

NewPerformanceForecaster creates a new performance forecaster

type PerformanceIssue

type PerformanceIssue struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	ComponentType shared.ComponentType `json:"componentType"`

	Category IssueCategory `json:"category"`

	Severity SeverityLevel `json:"severity"` // Using existing SeverityLevel type

	MetricName string `json:"metricName"`

	CurrentValue float64 `json:"currentValue"`

	ExpectedValue float64 `json:"expectedValue"`

	Deviation float64 `json:"deviation"`

	FirstDetected time.Time `json:"firstDetected"`

	LastSeen time.Time `json:"lastSeen"`

	Frequency int `json:"frequency"`

	TrendDirection string `json:"trendDirection"`

	RootCauseAnalysis *RootCauseAnalysis `json:"rootCauseAnalysis,omitempty"`

	Resolution *IssueResolution `json:"resolution,omitempty"`
}

type PerformanceMetric

type PerformanceMetric struct {
	Value float64 `json:"value"`

	Unit string `json:"unit"`

	Target float64 `json:"target"`

	Baseline float64 `json:"baseline"`

	Improvement float64 `json:"improvement"`

	Trend string `json:"trend"`

	Statistics *MetricStatistics `json:"statistics"` // Using existing type

	SLABoundaries *SLABoundaries `json:"slaBoundaries"`

	QualityGates []*QualityGate `json:"qualityGates"`
}

type PerformanceMetrics

type PerformanceMetrics struct {
	Latency time.Duration `json:"latency"`

	Throughput float64 `json:"throughput"`

	ErrorRate float64 `json:"errorRate"`

	ResourceUsage ResourceUsage `json:"resourceUsage"`

	CustomMetrics map[string]float64 `json:"customMetrics"`

	MeasurementTime time.Time `json:"measurementTime"`

	ConfidenceInterval *ConfidenceInterval `json:"confidenceInterval"`
}

type PerformancePattern

type PerformancePattern struct {
	PatternType PatternType `json:"patternType"`

	Description string `json:"description"`

	AffectedComponents []shared.ComponentType `json:"affectedComponents"`

	DetectionConfidence float64 `json:"detectionConfidence"`

	Frequency time.Duration `json:"frequency"`

	Impact ImpactLevel `json:"impact"`

	RecommendedActions []string `json:"recommendedActions"`
}

type PerformancePredictor

type PerformancePredictor struct{}

func NewPerformancePredictor

func NewPerformancePredictor(logger logr.Logger) *PerformancePredictor

type PerformanceTrend

type PerformanceTrend struct {
	ComponentType shared.ComponentType `json:"componentType"`

	MetricName string `json:"metricName"`

	TrendType TrendType `json:"trendType"`

	Direction TrendDirection `json:"direction"`

	Slope float64 `json:"slope"`

	Confidence float64 `json:"confidence"`

	StartTime time.Time `json:"startTime"`

	EndTime time.Time `json:"endTime"`

	DataPoints int `json:"dataPoints"`

	AverageValue float64 `json:"averageValue"`

	VarianceValue float64 `json:"varianceValue"`

	SeasonalityDetected bool `json:"seasonalityDetected"`

	SeasonalPeriod time.Duration `json:"seasonalPeriod,omitempty"`

	ChangePoints []time.Time `json:"changePoints"`

	Forecast *ForecastData `json:"forecast,omitempty"`
}

type PieChartData

type PieChartData struct {
	Labels []string `json:"labels"`

	Values []float64 `json:"values"`

	Colors []string `json:"colors"`
}

type PipelineState

type PipelineState struct {
	Status PipelineStatus `json:"status"`

	ActiveOptimizations []*OptimizationExecution `json:"activeOptimizations"`

	CompletedOptimizations []*OptimizationResult `json:"completedOptimizations"`

	FailedOptimizations []*FailedOptimization `json:"failedOptimizations"`

	LastRun time.Time `json:"lastRun"`

	NextScheduledRun time.Time `json:"nextScheduledRun"`

	Statistics *PipelineStatistics `json:"statistics"`
}

type PipelineStatistics

type PipelineStatistics struct {
	TotalRequests int `json:"totalRequests"`

	SuccessfulOptimizations int `json:"successfulOptimizations"`

	FailedOptimizations int `json:"failedOptimizations"`

	RollbackCount int `json:"rollbackCount"`

	AverageExecutionTime time.Duration `json:"averageExecutionTime"`

	TotalImprovementPct float64 `json:"totalImprovementPct"`

	MostOptimizedComponents []string `json:"mostOptimizedComponents"`

	LastUpdateTime time.Time `json:"lastUpdateTime"`
}

type PipelineStatus

type PipelineStatus string
const (
	PipelineStatusIdle PipelineStatus = "idle"

	PipelineStatusRunning PipelineStatus = "running"

	PipelineStatusPaused PipelineStatus = "paused"

	PipelineStatusError PipelineStatus = "error"
)

type PolicyEngineConfig

type PolicyEngineConfig struct{}

type PolicyNetwork

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

PolicyNetwork represents the neural network for policy decisions

func NewPolicyNetwork

func NewPolicyNetwork(inputSize, outputSize, hiddenSize int) *PolicyNetwork

NewPolicyNetwork creates a new policy network

func (*PolicyNetwork) Forward

func (p *PolicyNetwork) Forward(input []float64) []float64

Forward performs forward pass through policy network

type PredictedBottleneck

type PredictedBottleneck struct {
	ComponentType shared.ComponentType `json:"componentType"`

	MetricName string `json:"metricName"`

	PredictedOccurrence time.Time `json:"predictedOccurrence"`

	Confidence float64 `json:"confidence"`

	ExpectedSeverity SeverityLevel `json:"expectedSeverity"`

	MitigationActions []string `json:"mitigationActions"`
}

type ProtocolTranslationConfig

type ProtocolTranslationConfig struct{}

type QoSClass

type QoSClass struct{}

type QoSClassMetrics

type QoSClassMetrics struct {
	LatencyP99 time.Duration `json:"latencyP99"`

	PacketLossRate float64 `json:"packetLossRate"`

	Jitter time.Duration `json:"jitter"`

	Throughput float64 `json:"throughput"`

	ComplianceRate float64 `json:"complianceRate"`
}

type QoSConfig

type QoSConfig struct {
	QoSClassDefinitions map[string]*QoSClass `json:"qosClassDefinitions"`

	DynamicQoSAdjustment bool `json:"dynamicQosAdjustment"`

	QoSViolationHandling *QoSViolationConfig `json:"qosViolationHandling"`

	SLAMonitoring *SLAMonitoringConfig `json:"slaMonitoring"`

	TrafficShaping *TrafficShapingConfig `json:"trafficShaping"`

	AdmissionControl *AdmissionControlConfig `json:"admissionControl"`
}

type QoSDifferentiationConfig

type QoSDifferentiationConfig struct{}

type QoSEnforcementPolicy

type QoSEnforcementPolicy string

type QoSFlowOptimization

type QoSFlowOptimization struct{}

type QoSMetrics

type QoSMetrics struct {
	SLACompliance float64 `json:"slaCompliance"`

	QoSViolations int `json:"qosViolations"`

	TrafficShapingEff float64 `json:"trafficShapingEfficiency"`

	AdmissionControlRate float64 `json:"admissionControlRate"`

	ClassMetrics map[string]*QoSClassMetrics `json:"classMetrics"`
}

type QoSOptimizer

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

func NewQoSOptimizer

func NewQoSOptimizer(config *QoSConfig, logger logr.Logger) *QoSOptimizer

func (*QoSOptimizer) OptimizeQoS

func (optimizer *QoSOptimizer) OptimizeQoS(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)

type QoSParameters

type QoSParameters struct{}

type QoSViolationConfig

type QoSViolationConfig struct{}

type QualityGate

type QualityGate struct {
	Name string `json:"name"`

	Threshold float64 `json:"threshold"`

	Operator string `json:"operator"`

	Passed bool `json:"passed"`

	ActualValue float64 `json:"actualValue"`

	Impact string `json:"impact"`
}

type QueryOptimizationRule

type QueryOptimizationRule struct {
	Pattern string `json:"pattern"`

	Optimization string `json:"optimization"`

	ExpansionTerms []string `json:"expansionTerms"`

	FilterStrategy string `json:"filterStrategy"`
}

type RAGOptimizerConfig

type RAGOptimizerConfig struct {
	VectorDBConfigs map[string]VectorDBConfig `json:"vectorDBConfigs"`

	IndexOptimizationRules []IndexOptimizationRule `json:"indexOptimizationRules"`

	EmbeddingConfigs map[string]EmbeddingConfig `json:"embeddingConfigs"`

	RetrievalStrategies map[string]RetrievalConfig `json:"retrievalStrategies"`

	QueryOptimizationRules []QueryOptimizationRule `json:"queryOptimizationRules"`
}

type RAGSystemOptimizer

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

func NewRAGSystemOptimizer

func NewRAGSystemOptimizer(config *RAGOptimizerConfig, logger logr.Logger) *RAGSystemOptimizer

func (*RAGSystemOptimizer) GetOptimizationStrategies

func (opt *RAGSystemOptimizer) GetOptimizationStrategies() []RecommendationStrategy

func (*RAGSystemOptimizer) OptimizeConfiguration

func (opt *RAGSystemOptimizer) OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)

func (*RAGSystemOptimizer) RollbackOptimization

func (opt *RAGSystemOptimizer) RollbackOptimization(ctx context.Context, result *OptimizationResult) error

func (*RAGSystemOptimizer) ValidateOptimization

func (opt *RAGSystemOptimizer) ValidateOptimization(ctx context.Context, result *OptimizationResult) error

type RANConfig

type RANConfig struct {
	CoverageOptimization *CoverageOptimization `json:"coverageOptimization"`

	CapacityOptimization *CapacityOptimization `json:"capacityOptimization"`

	InterferenceManagement *InterferenceManagement `json:"interferenceManagement"`

	HandoverOptimization *HandoverOptimization `json:"handoverOptimization"`

	BeamformingConfig *BeamformingConfig `json:"beamformingConfig"`

	EnergyEfficiencyConfig *EnergyEfficiencyConfig `json:"energyEfficiencyConfig"`
}

type RANMetrics

type RANMetrics struct {
	CoverageEfficiency float64 `json:"coverageEfficiency"`

	CapacityUtilization float64 `json:"capacityUtilization"`

	InterferenceLevel float64 `json:"interferenceLevel"`

	HandoverSuccessRate float64 `json:"handoverSuccessRate"`

	BeamformingGain float64 `json:"beamformingGain"`

	EnergyEfficiency float64 `json:"energyEfficiency"`

	SpectrumEfficiency float64 `json:"spectrumEfficiency"`
}

type RANOptimizer

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

func NewRANOptimizer

func NewRANOptimizer(config *RANConfig, logger logr.Logger) *RANOptimizer

func (*RANOptimizer) OptimizeRAN

func (optimizer *RANOptimizer) OptimizeRAN(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)

type RICConfig

type RICConfig struct {
	NearRTRICConfig *NearRTRICConfig `json:"nearRtRicConfig"`

	NonRTRICConfig *NonRTRICConfig `json:"nonRtRicConfig"`

	XAppOptimization *XAppOptimization `json:"xAppOptimization"`

	E2InterfaceConfig *E2InterfaceConfig `json:"e2InterfaceConfig"`

	A1InterfaceConfig *A1InterfaceConfig `json:"a1InterfaceConfig"`

	RICServicesConfig *RICServicesConfig `json:"ricServicesConfig"`
}

type RICMetrics

type RICMetrics struct {
	NearRTRICLatency time.Duration `json:"nearRtRicLatency"`

	NonRTRICLatency time.Duration `json:"nonRtRicLatency"`

	XAppPerformance map[string]*XAppMetrics `json:"xAppPerformance"`

	E2MessageLatency time.Duration `json:"e2MessageLatency"`

	A1PolicyLatency time.Duration `json:"a1PolicyLatency"`

	ConflictResolutions int `json:"conflictResolutions"`
}

type RICOptimizer

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

func NewRICOptimizer

func NewRICOptimizer(config *RICConfig, logger logr.Logger) *RICOptimizer

func (*RICOptimizer) OptimizeRIC

func (optimizer *RICOptimizer) OptimizeRIC(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)

type RICResourceAllocation

type RICResourceAllocation struct{}

type RICServicesConfig

type RICServicesConfig struct{}

type ROIAnalysis

type ROIAnalysis struct {
	InitialInvestment float64 `json:"initialInvestment"`

	ExpectedSavings float64 `json:"expectedSavings"`

	ROIPercentage float64 `json:"roiPercentage"`

	PaybackPeriod time.Duration `json:"paybackPeriod"`

	NetPresentValue float64 `json:"netPresentValue"`

	SavingsBreakdown map[string]float64 `json:"savingsBreakdown"`

	CostBreakdown map[string]float64 `json:"costBreakdown"`

	AssumptionsUsed []string `json:"assumptionsUsed"`

	SensitivityAnalysis map[string]float64 `json:"sensitivityAnalysis"`
}

type ROICalculator

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

ROICalculator calculates return on investment for optimizations

func NewROICalculator

func NewROICalculator(logger logr.Logger) *ROICalculator

NewROICalculator creates a new ROI calculator

func (*ROICalculator) CalculateROI

func (rc *ROICalculator) CalculateROI(
	strategy *OptimizationStrategyConfig,
	expectedImpact *ExpectedImpact,
	riskAssessment *RiskAssessment,
) float64

CalculateROI calculates the ROI for implementing an optimization

type RecommendationMitigationStrategy

type RecommendationMitigationStrategy struct {
	Name string `json:"name"`

	Description string `json:"description"`

	Effectiveness float64 `json:"effectiveness"`

	Cost float64 `json:"cost"`

	TimeToImplement time.Duration `json:"timeToImplement"`
}

type RecommendationRiskFactor

type RecommendationRiskFactor struct {
	Name string `json:"name"`

	Description string `json:"description"`

	Probability float64 `json:"probability"`

	Impact ImpactLevel `json:"impact"`

	Mitigation string `json:"mitigation"`

	Category RiskCategory `json:"category"`
}

type RecommendationStrategy

type RecommendationStrategy struct {
	Name string `json:"name"`

	Category OptimizationCategory `json:"category"`

	TargetComponent ComponentType `json:"targetComponent"`

	ApplicableScenarios []ScenarioCondition `json:"applicableScenarios"`

	ExpectedBenefits *ExpectedBenefits `json:"expectedBenefits"`

	ImplementationSteps []ImplementationStep `json:"implementationSteps"`

	RiskLevel RiskLevel `json:"riskLevel"`

	Confidence float64 `json:"confidence"`

	EstimatedDuration time.Duration `json:"estimatedDuration"`
}

type RecommendationStrategyType

type RecommendationStrategyType string
const (
	RecommendationStrategyConservative RecommendationStrategyType = "conservative"

	RecommendationStrategyAggressive RecommendationStrategyType = "aggressive"

	RecommendationStrategyBalanced RecommendationStrategyType = "balanced"
)

type RecommendationsSummary

type RecommendationsSummary struct {
	TotalRecommendations int `json:"totalRecommendations"`

	CriticalRecommendations int `json:"criticalRecommendations"`

	ExpectedImpact *ExpectedImpact `json:"expectedImpact"`

	ImplementationComplexity ComplexityLevel `json:"implementationComplexity"`

	EstimatedImplementationTime time.Duration `json:"estimatedImplementationTime"`

	RecommendationsByCategory map[string]int `json:"recommendationsByCategory"`
}

type ReliabilityMetric

type ReliabilityMetric struct {
	*PerformanceMetric

	SuccessRate float64 `json:"successRate"`

	FailureRate float64 `json:"failureRate"`

	RetryRate float64 `json:"retryRate"`

	RecoveryTime time.Duration `json:"recoveryTime"`

	DataIntegrity float64 `json:"dataIntegrity"`

	ConsistencyScore float64 `json:"consistencyScore"`
}

type ResolutionStatus

type ResolutionStatus string
const (
	ResolutionStatusPending ResolutionStatus = "pending"

	ResolutionStatusInProgress ResolutionStatus = "in_progress"

	ResolutionStatusResolved ResolutionStatus = "resolved"

	ResolutionStatusFailed ResolutionStatus = "failed"
)

type ResourceAllocation

type ResourceAllocation struct{}

type ResourceAllocationPolicy

type ResourceAllocationPolicy string

type ResourceConstraint

type ResourceConstraint struct {
	ID string `json:"id"`

	Name string `json:"name"`

	ComponentType shared.ComponentType `json:"componentType"`

	ResourceType ResourceType `json:"resourceType"` // Using existing ResourceType

	ConstraintType string `json:"constraintType"` // Using string to avoid conflicts

	CurrentUsage float64 `json:"currentUsage"`

	MaxCapacity float64 `json:"maxCapacity"`

	UtilizationPct float64 `json:"utilizationPct"`

	Threshold float64 `json:"threshold"`

	ProjectedGrowth float64 `json:"projectedGrowth"`

	TimeToExhaustion time.Duration `json:"timeToExhaustion,omitempty"`

	Impact ConstraintImpact `json:"impact"`

	Recommendations []string `json:"recommendations"`

	DetectedAt time.Time `json:"detectedAt"`

	BusinessContext string `json:"businessContext"`
}

type ResourceConsumption

type ResourceConsumption struct {
	CPU    resource.Quantity `json:"cpu"`
	Memory resource.Quantity `json:"memory"`
	Disk   resource.Quantity `json:"disk"`
}

ResourceConsumption represents resource consumption metrics

type ResourceEfficiencyAnalysis

type ResourceEfficiencyAnalysis struct {
	OverallEfficiency float64 `json:"overallEfficiency"`

	ComponentEfficiencies map[shared.ComponentType]float64 `json:"componentEfficiencies"`

	InefficientResources []InefficientResource `json:"inefficientResources"`

	OptimizationPotential float64 `json:"optimizationPotential"`
}

type ResourceMetric

type ResourceMetric struct {
	Current float64 `json:"current"`

	Average float64 `json:"average"`

	Peak float64 `json:"peak"`

	Minimum float64 `json:"minimum"`

	Percentiles map[string]float64 `json:"percentiles"`

	Unit string `json:"unit"`

	Threshold *ResourceThreshold `json:"threshold"`

	Anomalies []*UtilizationAnomaly `json:"anomalies"`
}

type ResourceMetrics

type ResourceMetrics struct {
	CPU *ResourceUsageMetrics `json:"cpu"`

	Memory *ResourceUsageMetrics `json:"memory"`

	Storage *ResourceUsageMetrics `json:"storage"`

	Network *ResourceUsageMetrics `json:"network"`

	GPU *ResourceUsageMetrics `json:"gpu,omitempty"`
}

type ResourceOptimizationRule

type ResourceOptimizationRule struct {
	WorkloadType string `json:"workloadType"`

	CPURequest resource.Quantity `json:"cpuRequest"`

	CPULimit resource.Quantity `json:"cpuLimit"`

	MemoryRequest resource.Quantity `json:"memoryRequest"`

	MemoryLimit resource.Quantity `json:"memoryLimit"`

	QoSClass string `json:"qosClass"`
}

type ResourcePoolingConfig

type ResourcePoolingConfig struct{}

type ResourceThreshold

type ResourceThreshold struct {
	Warning float64 `json:"warning"`

	Critical float64 `json:"critical"`

	Target float64 `json:"target"`

	Optimal float64 `json:"optimal"`
}

type ResourceType

type ResourceType string
const (
	ResourceTypeCPU ResourceType = "cpu"

	ResourceTypeMemory ResourceType = "memory"

	ResourceTypeNetwork ResourceType = "network"

	ResourceTypeStorage ResourceType = "storage"

	ResourceTypeCompute ResourceType = "compute"
)

type ResourceUsage

type ResourceUsage struct {
	CPUUsage float64 `json:"cpuUsage"`

	MemoryUsage float64 `json:"memoryUsage"`

	NetworkIO float64 `json:"networkIO"`

	DiskIO float64 `json:"diskIO"`

	GPUUsage float64 `json:"gpuUsage,omitempty"`
}

type ResourceUsageMetrics

type ResourceUsageMetrics struct {
	Current float64 `json:"current"`

	Average float64 `json:"average"`

	Peak float64 `json:"peak"`

	Limit float64 `json:"limit"`

	UtilizationPercent float64 `json:"utilizationPercent"`
}

type ResourceUtilization

type ResourceUtilization struct {
	ComponentType shared.ComponentType `json:"componentType"`

	TimePeriod TimePeriod `json:"timePeriod"`

	CPUUtilization *ResourceMetric `json:"cpuUtilization"`

	MemoryUtilization *ResourceMetric `json:"memoryUtilization"`

	StorageUtilization *ResourceMetric `json:"storageUtilization"`

	NetworkUtilization *ResourceMetric `json:"networkUtilization"`

	CustomMetrics map[string]*ResourceMetric `json:"customMetrics"`

	EfficiencyScore float64 `json:"efficiencyScore"`

	WasteFactors []*WasteFactor `json:"wasteFactors"`

	OptimizationPotential float64 `json:"optimizationPotential"`

	BenchmarkComparison *BenchmarkComparison `json:"benchmarkComparison"`

	TrendAnalysis *UtilizationTrend `json:"trendAnalysis"`
}

type ResourceWasteAnalysis

type ResourceWasteAnalysis struct {
	TotalWaste float64 `json:"totalWaste"`

	WasteByCategory map[string]float64 `json:"wasteByCategory"`

	TopWastedResources []WastedResource `json:"topWastedResources"`

	PotentialSavings float64 `json:"potentialSavings"`
}

type ResultsAnalyzer

type ResultsAnalyzer struct{}

func NewResultsAnalyzer

func NewResultsAnalyzer(logger logr.Logger) *ResultsAnalyzer

type RetrievalConfig

type RetrievalConfig struct {
	Strategy string `json:"strategy"`

	TopK int `json:"topK"`

	ScoreThreshold float64 `json:"scoreThreshold"`

	DiversityFactor float64 `json:"diversityFactor"`

	RerankingEnabled bool `json:"rerankingEnabled"`

	HybridSearch bool `json:"hybridSearch"`
}

type RetryPolicy

type RetryPolicy struct{}

type RewardFunctionType

type RewardFunctionType string
const (
	RewardFunctionPerformance RewardFunctionType = "performance_based"

	RewardFunctionMultiObjective RewardFunctionType = "multi_objective"

	RewardFunctionCostAware RewardFunctionType = "cost_aware"

	RewardFunctionRiskAdjusted RewardFunctionType = "risk_adjusted"
)

type RiskAssessment

type RiskAssessment struct {
	OverallRiskLevel     RiskLevel            `json:"overallRiskLevel"`
	ImplementationRisk   float64              `json:"implementationRisk"`
	PerformanceRisk      float64              `json:"performanceRisk"`
	AvailabilityRisk     float64              `json:"availabilityRisk"`
	SecurityRisk         float64              `json:"securityRisk"`
	ComplianceRisk       float64              `json:"complianceRisk"`
	IdentifiedRisks      []string             `json:"identifiedRisks"`
	MitigationStrategies []MitigationStrategy `json:"mitigationStrategies"`
	RiskScoreBreakdown   map[string]float64   `json:"riskScoreBreakdown"`
	AssessmentTimestamp  time.Time            `json:"assessmentTimestamp"`
	ValidityPeriod       time.Duration        `json:"validityPeriod"`
}

RiskAssessment represents a comprehensive risk assessment

type RiskAssessor

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

RiskAssessor assesses risks associated with optimization implementations

func NewRiskAssessor

func NewRiskAssessor(logger logr.Logger) *RiskAssessor

NewRiskAssessor creates a new risk assessor

func (*RiskAssessor) AssessRisk

func (ra *RiskAssessor) AssessRisk(
	strategy *OptimizationStrategyConfig,
	analysis *ComponentAnalysis,
	overallResult *PerformanceAnalysisResult,
) *RiskAssessment

AssessRisk assesses the risk of implementing an optimization strategy

type RiskCategory

type RiskCategory string
const (
	RiskCategoryPerformance RiskCategory = "performance"

	RiskCategoryAvailability RiskCategory = "availability"

	RiskCategorySecurity RiskCategory = "security"

	RiskCategoryCompliance RiskCategory = "compliance"

	RiskCategoryOperational RiskCategory = "operational"

	RiskCategoryFinancial RiskCategory = "financial"
)

type RiskImpactAnalysis

type RiskImpactAnalysis struct {
	PerformanceRisk float64 `json:"performanceRisk"`

	AvailabilityRisk float64 `json:"availabilityRisk"`

	SecurityRisk float64 `json:"securityRisk"`

	ComplianceRisk float64 `json:"complianceRisk"`

	BusinessImpact string `json:"businessImpact"`

	RecoveryTime time.Duration `json:"recoveryTime"`

	AffectedSystems []string `json:"affectedSystems"`
}

type RiskLevel

type RiskLevel string
const (
	RiskLevelVeryLow RiskLevel = "very_low"

	RiskLevelLow RiskLevel = "low"

	RiskLevelMedium RiskLevel = "medium"

	RiskLevelHigh RiskLevel = "high"

	RiskLevelVeryHigh RiskLevel = "very_high"

	RiskLevelCritical RiskLevel = "critical"
)

type RollbackEntry

type RollbackEntry struct {
	OptimizationID string `json:"optimizationId"`

	Timestamp time.Time `json:"timestamp"`

	OriginalState runtime.Object `json:"originalState"`

	ModifiedState runtime.Object `json:"modifiedState"`

	RollbackData interface{} `json:"rollbackData"`
}

type RollbackManager

type RollbackManager struct{}

func NewRollbackManager

func NewRollbackManager(logger logr.Logger) *RollbackManager

func (*RollbackManager) EmergencyRollback

func (rm *RollbackManager) EmergencyRollback(ctx context.Context) error

type RootCauseAnalysis

type RootCauseAnalysis struct {
	PossibleCauses []string `json:"possibleCauses"`

	MostLikelyCause string `json:"mostLikelyCause"`

	ConfidenceScore float64 `json:"confidenceScore"`

	AnalysisMethod string `json:"analysisMethod"`

	SupportingEvidence []string `json:"supportingEvidence"`

	CorrelatedMetrics []string `json:"correlatedMetrics"`

	AnalysisTimestamp time.Time `json:"analysisTimestamp"`
}

type RunningOptimization

type RunningOptimization struct {
	ID string `json:"id"`

	Type string `json:"type"`

	Progress float64 `json:"progress"`

	StartTime time.Time `json:"startTime"`

	EstimatedCompletion time.Time `json:"estimatedCompletion"`

	CurrentStep string `json:"currentStep"`

	Priority string `json:"priority"`
}

type SLABoundaries

type SLABoundaries struct {
	Target float64 `json:"target"`

	Threshold float64 `json:"threshold"`

	Critical float64 `json:"critical"`

	Optimal float64 `json:"optimal"`
}

type SLAComplianceMetric

type SLAComplianceMetric struct {
	OverallCompliance float64 `json:"overallCompliance"`

	SLAViolations int `json:"slaViolations"`

	ComplianceByMetric map[string]float64 `json:"complianceByMetric"`

	PenaltyCost float64 `json:"penaltyCost"`

	RiskScore float64 `json:"riskScore"`

	ComplianceHistory []*ComplianceHistoryEntry `json:"complianceHistory"`
}

type SLAMonitoringConfig

type SLAMonitoringConfig struct{}

type SMFConfig

type SMFConfig struct {
	MaxConcurrentSessions int `json:"maxConcurrentSessions"`

	SessionEstablishmentTimeout time.Duration `json:"sessionEstablishmentTimeout"`

	QoSFlowOptimization *QoSFlowOptimization `json:"qosFlowOptimization"`

	UPFSelectionStrategy UPFSelectionStrategy `json:"upfSelectionStrategy"`

	ChargingOptimization *ChargingOptimization `json:"chargingOptimization"`

	PolicyEngineConfig *PolicyEngineConfig `json:"policyEngineConfig"`

	SessionStateManagement *SessionStateConfig `json:"sessionStateManagement"`
}

type SMFMetrics

type SMFMetrics struct {
	SessionEstablishmentLatency time.Duration `json:"sessionEstablishmentLatency"`

	SessionEstablishmentRate float64 `json:"sessionEstablishmentRate"`

	ActiveSessions int `json:"activeSessions"`

	QoSFlowSetupSuccessRate float64 `json:"qosFlowSetupSuccessRate"`

	PolicyEnforcementLatency time.Duration `json:"policyEnforcementLatency"`
}

type SafetyChecks

type SafetyChecks struct {
	ValidateHealthStatus bool `json:"validateHealthStatus"`

	CheckResourceLimits bool `json:"checkResourceLimits"`

	ValidateDependencies bool `json:"validateDependencies"`

	RequireBackup bool `json:"requireBackup"`

	MaxResourceChange float64 `json:"maxResourceChange"`

	MaxConfigChanges int `json:"maxConfigChanges"`
}

type SafetyConstraints

type SafetyConstraints struct{}

func NewSafetyConstraints

func NewSafetyConstraints(config *AITunerConfig, logger logr.Logger) *SafetyConstraints

func (*SafetyConstraints) ValidateConfiguration

func (sc *SafetyConstraints) ValidateConfiguration(config *SystemConfiguration) bool

type ScalabilityMetric

type ScalabilityMetric struct {
	*PerformanceMetric

	MaxCapacity float64 `json:"maxCapacity"`

	CurrentLoad float64 `json:"currentLoad"`

	LoadFactor float64 `json:"loadFactor"`

	ElasticityScore float64 `json:"elasticityScore"`

	ScalingLatency time.Duration `json:"scalingLatency"`

	ResourceEfficiency float64 `json:"resourceEfficiency"`
}

type ScalingPolicyConfig

type ScalingPolicyConfig struct{}

type ScenarioCondition

type ScenarioCondition struct {
	MetricName string `json:"metricName"`

	Operator ComparisonOperator `json:"operator"`

	Threshold interface{} `json:"threshold"`

	ComponentType ComponentType `json:"componentType"`
}

type SchedulingPolicy

type SchedulingPolicy struct {
	NodeSelector map[string]string `json:"nodeSelector"`

	Affinity AffinityConfig `json:"affinity"`

	Tolerations []TolerationConfig `json:"tolerations"`

	PriorityClass string `json:"priorityClass"`

	TopologySpread TopologySpreadConfig `json:"topologySpread"`
}

type SearchHint

type SearchHint string
const (
	SearchHintLinear SearchHint = "linear"

	SearchHintLogarithmic SearchHint = "logarithmic"

	SearchHintExponential SearchHint = "exponential"

	SearchHintCyclic SearchHint = "cyclic"
)

type SearchStrategy

type SearchStrategy string
const (
	SearchStrategyRandom SearchStrategy = "random"

	SearchStrategySystem SearchStrategy = "systematic"

	SearchStrategyAdaptive SearchStrategy = "adaptive"

	SearchStrategyHierarchical SearchStrategy = "hierarchical"
)

type SecurityOptimizationPolicy

type SecurityOptimizationPolicy struct {
	PolicyName      string                 `json:"policyName"`
	EncryptionLevel string                 `json:"encryptionLevel"`
	AuthMethod      string                 `json:"authMethod"`
	ComplianceLevel string                 `json:"complianceLevel"`
	Rules           []string               `json:"rules"`
	Configuration   map[string]interface{} `json:"configuration"`
}

SecurityOptimizationPolicy represents security optimization policy

type SelectionStrategy

type SelectionStrategy string
const (
	SelectionStrategyTournament SelectionStrategy = "tournament"

	SelectionStrategyRoulette SelectionStrategy = "roulette_wheel"

	SelectionStrategyRank SelectionStrategy = "rank_based"

	SelectionStrategyElitist SelectionStrategy = "elitist"
)

type ServiceMeshConfig

type ServiceMeshConfig struct{}

type SessionOptimization

type SessionOptimization struct{}

type SessionStateConfig

type SessionStateConfig struct{}

type SeverityLevel

type SeverityLevel string
const (
	SeverityCritical SeverityLevel = "critical"

	SeverityHigh SeverityLevel = "high"

	SeverityMedium SeverityLevel = "medium"

	SeverityLow SeverityLevel = "low"

	SeverityInfo SeverityLevel = "info"
)

type SlackConfig

type SlackConfig struct {
	WebhookURL string `json:"webhookUrl"`

	Channel string `json:"channel"`

	Username string `json:"username,omitempty"`
}

type SliceAutoScalingConfig

type SliceAutoScalingConfig struct{}

type SliceIsolationConfig

type SliceIsolationConfig struct{}

type SliceIsolationLevel

type SliceIsolationLevel string

type SliceMetrics

type SliceMetrics struct {
	SliceID string `json:"sliceId"`

	SliceType SliceType `json:"sliceType"`

	Latency time.Duration `json:"latency"`

	Throughput float64 `json:"throughput"`

	Reliability float64 `json:"reliability"`

	ResourceUtilization float64 `json:"resourceUtilization"`

	IsolationEfficiency float64 `json:"isolationEfficiency"`

	SLACompliance float64 `json:"slaCompliance"`
}

type SliceOptimizationStrategy

type SliceOptimizationStrategy string

type SlicePerformanceConfig

type SlicePerformanceConfig struct{}

type SliceSelectionCriterion

type SliceSelectionCriterion struct{}

type SliceTemplate

type SliceTemplate struct {
	SliceType SliceType `json:"sliceType"`

	LatencyRequirement time.Duration `json:"latencyRequirement"`

	ThroughputRequirement float64 `json:"throughputRequirement"`

	ReliabilityRequirement float64 `json:"reliabilityRequirement"`

	ResourceAllocation *ResourceAllocation `json:"resourceAllocation"`

	QoSParameters *QoSParameters `json:"qosParameters"`

	OptimizationStrategy SliceOptimizationStrategy `json:"optimizationStrategy"`
}

type SliceType

type SliceType string
const (
	SliceTypeEMBB SliceType = "embb" // Enhanced Mobile Broadband

	SliceTypeURLLC SliceType = "urllc" // Ultra-Reliable Low-Latency Communications

	SliceTypeMMTC SliceType = "mmtc" // Massive Machine-Type Communications

)

type StorageConfig

type StorageConfig struct {
	StorageClass string `json:"storageClass"`

	VolumeBindingMode string `json:"volumeBindingMode"`

	IOPSLimit int `json:"iopsLimit"`

	ThroughputLimit string `json:"throughputLimit"`

	CachingEnabled bool `json:"cachingEnabled"`
}

type SystemConfiguration

type SystemConfiguration struct {
	ID string `json:"id"`

	Parameters json.RawMessage `json:"parameters"`

	Timestamp time.Time `json:"timestamp"`

	PerformanceMetrics *PerformanceMetrics `json:"performanceMetrics,omitempty"`

	Cost float64 `json:"cost,omitempty"`

	RiskScore float64 `json:"riskScore,omitempty"`

	FitnessScore float64 `json:"fitnessScore,omitempty"`

	ExperimentID string `json:"experimentId,omitempty"`

	ValidationStatus ValidationStatus `json:"validationStatus"`
}

type SystemHealthStatus

type SystemHealthStatus string
const (
	HealthStatusHealthy SystemHealthStatus = "healthy"

	HealthStatusWarning SystemHealthStatus = "warning"

	HealthStatusCritical SystemHealthStatus = "critical"

	HealthStatusUnknown SystemHealthStatus = "unknown"
)

type SystemInfo

type SystemInfo struct {
	Version string `json:"version"`

	BuildTime time.Time `json:"buildTime"`

	Uptime time.Duration `json:"uptime"`

	NodeCount int `json:"nodeCount"`

	PodCount int `json:"podCount"`

	ComponentVersions map[string]string `json:"componentVersions"`

	ConfigurationHash string `json:"configurationHash"`
}

type SystemOptimizer

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

SystemOptimizer optimizes system performance

func NewSystemOptimizer

func NewSystemOptimizer(logger logr.Logger, k8sClient client.Client, clientset kubernetes.Interface) *SystemOptimizer

NewSystemOptimizer creates a new system optimizer

func (*SystemOptimizer) OptimizeComponent

func (so *SystemOptimizer) OptimizeComponent(ctx context.Context, componentType ComponentType, recommendation *OptimizationRecommendation) (*OptimizationResult, error)

OptimizeComponent optimizes a specific component

type TTLRule

type TTLRule struct {
	Pattern string `json:"pattern"`

	BaseTTL time.Duration `json:"baseTTL"`

	AccessPattern AccessPattern `json:"accessPattern"`

	Multiplier float64 `json:"multiplier"`
}

type TelecomMetrics

type TelecomMetrics struct {
	AMFMetrics *AMFMetrics `json:"amfMetrics"`

	SMFMetrics *SMFMetrics `json:"smfMetrics"`

	UPFMetrics *UPFMetrics `json:"upfMetrics"`

	SliceMetrics map[string]*SliceMetrics `json:"sliceMetrics"`

	RICMetrics *RICMetrics `json:"ricMetrics"`

	RANMetrics *RANMetrics `json:"ranMetrics"`

	QoSMetrics *QoSMetrics `json:"qosMetrics"`

	EdgeMetrics map[string]*EdgeMetrics `json:"edgeMetrics"`

	InteropMetrics *InteropMetrics `json:"interopMetrics"`
}

type TelecomMetricsCollector

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

func NewTelecomMetricsCollector

func NewTelecomMetricsCollector(logger logr.Logger) *TelecomMetricsCollector

func (*TelecomMetricsCollector) CollectMetrics

func (collector *TelecomMetricsCollector) CollectMetrics(ctx context.Context) (*TelecomMetrics, error)

type TelecomOptimizationCategory

type TelecomOptimizationCategory string
const (
	TelecomCategoryLatency TelecomOptimizationCategory = "latency"

	TelecomCategoryThroughput TelecomOptimizationCategory = "throughput"

	TelecomCategoryReliability TelecomOptimizationCategory = "reliability"

	TelecomCategoryEfficiency TelecomOptimizationCategory = "efficiency"

	TelecomCategoryInterop TelecomOptimizationCategory = "interoperability"

	TelecomCategoryCompliance TelecomOptimizationCategory = "compliance"

	TelecomCategoryScalability TelecomOptimizationCategory = "scalability"

	TelecomCategoryEnergyEff TelecomOptimizationCategory = "energy_efficiency"
)

type TelecomOptimizationRule

type TelecomOptimizationRule struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	ComponentTypes []shared.ComponentType `json:"componentTypes"`

	Conditions []OptimizationRuleCondition `json:"conditions"`

	Actions []OptimizationRuleAction `json:"actions"`

	Priority int `json:"priority"`

	SLAImpact string `json:"slaImpact"`

	ComplianceLevel string `json:"complianceLevel"`

	Enabled bool `json:"enabled"`
}

type TelecomOptimizationStrategy

type TelecomOptimizationStrategy struct {
	Name string `json:"name"`

	Category OptimizationCategory `json:"category"`

	TargetComponent ComponentType `json:"targetComponent"`

	ApplicableScenarios []ScenarioCondition `json:"applicableScenarios"`

	ExpectedBenefits *ExpectedBenefits `json:"expectedBenefits"`

	ImplementationSteps []ImplementationStep `json:"implementationSteps"`

	RiskFactors []RecommendationRiskFactor `json:"riskFactors"`
}

type TelecomOptimizerConfig

type TelecomOptimizerConfig struct {
	CoreNetworkConfig *CoreNetworkConfig `json:"coreNetworkConfig"`

	NetworkSliceConfig *NetworkSliceConfig `json:"networkSliceConfig"`

	RICConfig *RICConfig `json:"ricConfig"`

	RANConfig *RANConfig `json:"ranConfig"`

	InteropConfig *InteropConfig `json:"interopConfig"`

	QoSConfig *QoSConfig `json:"qosConfig"`

	EdgeConfig *EdgeConfig `json:"edgeConfig"`

	LatencyThresholds map[string]time.Duration `json:"latencyThresholds"`

	ThroughputThresholds map[string]float64 `json:"throughputThresholds"`

	AvailabilityTargets map[string]float64 `json:"availabilityTargets"`

	OptimizationPriorities map[TelecomOptimizationCategory]float64 `json:"optimizationPriorities"`
}

func GetDefaultTelecomOptimizerConfig

func GetDefaultTelecomOptimizerConfig() *TelecomOptimizerConfig

type TelecomPerformanceAnalysis

type TelecomPerformanceAnalysis struct {
	CoreNetworkLatency float64 `json:"coreNetworkLatency"`

	SignalingEfficiency float64 `json:"signalingEfficiency"`

	SessionSetupTime float64 `json:"sessionSetupTime"`

	RICLatency float64 `json:"ricLatency"`

	E2Throughput float64 `json:"e2Throughput"`

	XAppPerformance map[string]float64 `json:"xAppPerformance"`

	SliceIsolation float64 `json:"sliceIsolation"`

	SliceLatency map[string]float64 `json:"sliceLatency"`

	SliceThroughput map[string]float64 `json:"sliceThroughput"`

	QoSCompliance float64 `json:"qosCompliance"`

	SLAViolations int `json:"slaViolations"`

	InteropEfficiency float64 `json:"interopEfficiency"`

	VendorSpecificIssues []string `json:"vendorSpecificIssues"`
}

type TelecomPerformanceOptimizer

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

func NewTelecomPerformanceOptimizer

func NewTelecomPerformanceOptimizer(config *TelecomOptimizerConfig, logger logr.Logger) *TelecomPerformanceOptimizer

func (*TelecomPerformanceOptimizer) GetTelecomOptimizationStrategies

func (optimizer *TelecomPerformanceOptimizer) GetTelecomOptimizationStrategies() []TelecomOptimizationStrategy

func (*TelecomPerformanceOptimizer) OptimizeTelecomPerformance

func (optimizer *TelecomPerformanceOptimizer) OptimizeTelecomPerformance(
	ctx context.Context,

	analysisResult *PerformanceAnalysisResult,
) ([]*OptimizationRecommendation, error)

type ThroughputMetrics

type ThroughputMetrics struct {
	RequestsPerSecond float64 `json:"requestsPerSecond"`

	MessagesPerSecond float64 `json:"messagesPerSecond"`

	BytesPerSecond float64 `json:"bytesPerSecond"`

	TransactionsPerSecond float64 `json:"transactionsPerSecond"`
}

type TimePeriod

type TimePeriod struct {
	Start time.Time `json:"start"`

	End time.Time `json:"end"`

	Duration time.Duration `json:"duration"`

	Granularity string `json:"granularity"`
}

type TokenRange

type TokenRange struct {
	Min int `json:"min"`

	Max int `json:"max"`

	Optimal int `json:"optimal"`

	CostFactor float64 `json:"costFactor"`

	LatencyFactor float64 `json:"latencyFactor"`
}

type TolerationConfig

type TolerationConfig struct {
	Key string `json:"key"`

	Operator string `json:"operator"`

	Value string `json:"value"`

	Effect string `json:"effect"`
}

type TopologySpreadConfig

type TopologySpreadConfig struct {
	MaxSkew int `json:"maxSkew"`

	TopologyKey string `json:"topologyKey"`

	WhenUnsatisfiable string `json:"whenUnsatisfiable"`
}

type TrafficShapingConfig

type TrafficShapingConfig struct{}

type TrafficSteeringRule

type TrafficSteeringRule struct{}

type TrendAnalysis

type TrendAnalysis struct {
	Direction TrendDirection `json:"direction"`

	Slope float64 `json:"slope"`

	Confidence float64 `json:"confidence"`

	SeasonalityDetected bool `json:"seasonalityDetected"`

	SeasonalPeriod time.Duration `json:"seasonalPeriod"`

	ChangePoints []time.Time `json:"changePoints"`
}

type TrendData

type TrendData struct {
	Direction string `json:"direction"`

	Slope float64 `json:"slope"`

	ChangePercent float64 `json:"changePercent"`

	Confidence float64 `json:"confidence"`

	PredictedValue float64 `json:"predictedValue"`
}

type TrendDirection

type TrendDirection string
const (
	TrendDirectionIncreasing TrendDirection = "increasing"

	TrendDirectionDecreasing TrendDirection = "decreasing"

	TrendDirectionStable TrendDirection = "stable"

	TrendDirectionVolatile TrendDirection = "volatile"
)

type TrendType

type TrendType string
const (
	TrendTypeLinear TrendType = "linear"

	TrendTypeExponential TrendType = "exponential"

	TrendTypeSeasonal TrendType = "seasonal"

	TrendTypeCyclical TrendType = "cyclical"

	TrendTypeNoTrend TrendType = "no_trend"
)

type UPFConfig

type UPFConfig struct {
	PacketProcessingMode PacketProcessingMode `json:"packetProcessingMode"`

	BufferSizes BufferSizeConfig `json:"bufferSizes"`

	TrafficSteeringRules []TrafficSteeringRule `json:"trafficSteeringRules"`

	QoSEnforcementPolicy QoSEnforcementPolicy `json:"qosEnforcementPolicy"`

	EdgeProximityOptimization bool `json:"edgeProximityOptimization"`

	DataPathOptimization *DataPathOptimization `json:"dataPathOptimization"`

	HardwareAcceleration *HWAccelerationConfig `json:"hardwareAcceleration"`
}

type UPFMetrics

type UPFMetrics struct {
	PacketProcessingLatency time.Duration `json:"packetProcessingLatency"`

	PacketLossRate float64 `json:"packetLossRate"`

	Throughput float64 `json:"throughput"`

	BufferUtilization float64 `json:"bufferUtilization"`

	HardwareAccelerationRatio float64 `json:"hardwareAccelerationRatio"`
}

type UPFSelectionStrategy

type UPFSelectionStrategy string

type UtilizationAnomaly

type UtilizationAnomaly struct {
	Timestamp time.Time `json:"timestamp"`

	Type string `json:"type"`

	Severity string `json:"severity"`

	Value float64 `json:"value"`

	Expected float64 `json:"expected"`

	Deviation float64 `json:"deviation"`

	Description string `json:"description"`
}

type UtilizationTrend

type UtilizationTrend struct {
	Direction string `json:"direction"`

	Rate float64 `json:"rate"`

	Seasonality bool `json:"seasonality"`

	GrowthPattern string `json:"growthPattern"`

	ForecastPeriod time.Duration `json:"forecastPeriod"`

	PredictedValues []float64 `json:"predictedValues"`
}

type ValidationRule

type ValidationRule struct {
	Type ValidationRuleType `json:"type"`

	Expression string `json:"expression"`

	ErrorMessage string `json:"errorMessage"`
}

type ValidationRuleType

type ValidationRuleType string
const (
	ValidationRuleTypeRange ValidationRuleType = "range"

	ValidationRuleTypeExpression ValidationRuleType = "expression"

	ValidationRuleTypeDependency ValidationRuleType = "dependency"

	ValidationRuleTypeCustom ValidationRuleType = "custom"
)

type ValidationStatus

type ValidationStatus string
const (
	ValidationStatusPending ValidationStatus = "pending"

	ValidationStatusValid ValidationStatus = "valid"

	ValidationStatusInvalid ValidationStatus = "invalid"

	ValidationStatusTesting ValidationStatus = "testing"

	ValidationStatusFailed ValidationStatus = "failed"
)

type ValueNetwork

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

ValueNetwork estimates state values for PPO

func NewValueNetwork

func NewValueNetwork(inputSize, hiddenSize int) *ValueNetwork

NewValueNetwork creates a new value network

type VectorDBConfig

type VectorDBConfig struct {
	IndexType string `json:"indexType"`

	Distance string `json:"distance"`

	EfConstruction int `json:"efConstruction"`

	MaxConnections int `json:"maxConnections"`

	ShardingStrategy string `json:"shardingStrategy"`

	CacheSize int64 `json:"cacheSize"`

	CompressionLevel int `json:"compressionLevel"`
}

type VendorAdaptationConfig

type VendorAdaptationConfig struct{}

type VersionCompatibilityConfig

type VersionCompatibilityConfig struct{}

type WasteFactor

type WasteFactor struct {
	Factor string `json:"factor"`

	Impact float64 `json:"impact"`

	Description string `json:"description"`

	Remedy string `json:"remedy"`
}

type WastedResource

type WastedResource struct {
	ResourceName string `json:"resourceName"`

	WasteAmount float64 `json:"wasteAmount"`

	WastePercentage float64 `json:"wastePercentage"`

	EstimatedCostSavings float64 `json:"estimatedCostSavings"`

	RecommendedAction string `json:"recommendedAction"`
}

type WebhookConfig

type WebhookConfig struct {
	URL string `json:"url"`

	Headers map[string]string `json:"headers,omitempty"`

	AuthToken string `json:"authToken,omitempty"`
}

type WorkloadPlacementConfig

type WorkloadPlacementConfig struct{}

type XAppLifecycleConfig

type XAppLifecycleConfig struct{}

type XAppLoadBalancing

type XAppLoadBalancing struct{}

type XAppMetrics

type XAppMetrics struct {
	ProcessingLatency time.Duration `json:"processingLatency"`

	DecisionAccuracy float64 `json:"decisionAccuracy"`

	ResourceUsage float64 `json:"resourceUsage"`

	MessageThroughput float64 `json:"messageThroughput"`
}

type XAppOptimization

type XAppOptimization struct {
	AutoDeployment bool `json:"autoDeployment"`

	LoadBalancing *XAppLoadBalancing `json:"loadBalancing"`

	ResourceManagement *XAppResourceMgmt `json:"resourceManagement"`

	PerformanceMonitoring *XAppPerfMonitoring `json:"performanceMonitoring"`

	InterXAppCommunication *InterXAppCommConfig `json:"interXAppCommunication"`

	LifecycleManagement *XAppLifecycleConfig `json:"lifecycleManagement"`
}

type XAppPerfMonitoring

type XAppPerfMonitoring struct{}

type XAppResourceMgmt

type XAppResourceMgmt struct{}

type XAppSchedulingPolicy

type XAppSchedulingPolicy string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL