Documentation
¶
Index ¶
- Constants
- type A1InterfaceConfig
- type AIConfigurationTuner
- type AITunerConfig
- type AMFConfig
- type AMFMetrics
- type AccessPattern
- type AcquisitionFunction
- type AcquisitionOptimizer
- type AdmissionControlConfig
- type AffinityConfig
- type AlgorithmPerformanceTracker
- type AnalysisConfig
- type AnalysisType
- type AnomalyType
- type AuditEntry
- type AuditLogger
- type AutomatedOptimizationPipeline
- func (pipeline *AutomatedOptimizationPipeline) GetOptimizationStatus() string
- func (pipeline *AutomatedOptimizationPipeline) GetPipelineState() *PipelineState
- func (pipeline *AutomatedOptimizationPipeline) PauseOptimizations()
- func (pipeline *AutomatedOptimizationPipeline) RequestOptimization(ctx context.Context, recommendations []*OptimizationRecommendation, ...) string
- func (pipeline *AutomatedOptimizationPipeline) ResumeOptimizations()
- func (pipeline *AutomatedOptimizationPipeline) Start(ctx context.Context) error
- func (pipeline *AutomatedOptimizationPipeline) Stop()
- type AutomationConfig
- type AutomationLevel
- type AvailabilityMetric
- type BatchConfig
- type BayesianOptimization
- type BeamformingConfig
- type BenchmarkComparison
- type BenchmarkEnvironment
- type BottleneckPredictor
- type BottleneckSolution
- type BufferSizeConfig
- type CacheConfig
- type CacheOptimizationStrategy
- type CachingStrategy
- type CapacityOptimization
- type CapacityPrediction
- type ChargingOptimization
- type ChartDataSeries
- type ChartsData
- type ComparisonOperator
- type ComplexityLevel
- type ComplianceCheckConfig
- type ComplianceHistoryEntry
- type ComplianceRequirement
- type ComponentAnalysis
- type ComponentAnalysisConfig
- type ComponentHealth
- type ComponentOptimizer
- type ComponentOptimizerRegistry
- type ComponentPerformanceMetrics
- type ComponentType
- type ConfidenceInterval
- type ConfigurationConstraint
- type ConfigurationSpace
- type ConflictResolutionPolicy
- type ConnectivityOptConfig
- type ConstraintImpact
- type ConstraintType
- type ConstraintViolation
- type ConvergenceTracker
- type CoreNetworkConfig
- type CoreNetworkOptimizer
- type CostAnalysis
- type CoverageOptimization
- type DashboardConfig
- type DashboardData
- type DashboardOverview
- type DashboardPerformanceMetrics
- type DashboardRecommendation
- type DataPathOptimization
- type DataPoint
- type DependencyCondition
- type E2InterfaceConfig
- type EdgeCachingConfig
- type EdgeConfig
- type EdgeDeploymentOptimizer
- type EdgeMetrics
- type EdgeNodeSelectionConfig
- type EdgeResourceMgmtConfig
- type EfficiencyMetric
- type EmailAuthConfig
- type EmailConfig
- type EmbeddingConfig
- type EnergyEfficiencyConfig
- type ErrorMetrics
- type EstimatedImprovement
- type ExecutionProgress
- type ExecutionStatus
- type ExpectedBenefits
- type ExpectedImpact
- type ExperienceBuffer
- type ExperimentManager
- type ExtendedOptimizationRecommendation
- type FailedOptimization
- type ForecastData
- type ForecastPoint
- type GaussianProcess
- type HAConfig
- type HWAccelerationConfig
- type HandoverOptimization
- type HealthStatus
- type HistogramData
- type HistoricalData
- type HistoricalDataStore
- type HistoricalOptimization
- type HyperparameterStrategy
- type ImpactLevel
- type ImpactPredictor
- type ImplementationStep
- type IndexOptimizationRule
- type InefficientResource
- type IntegrationTestConfig
- type InterXAppCommConfig
- type InterferenceManagement
- type InteropConfig
- type InteropMetrics
- type InteropOptimizer
- type IssueCategory
- type IssueResolution
- type K8sOptimizerConfig
- type Kernel
- type KernelType
- type KubernetesOptimizer
- func (opt *KubernetesOptimizer) GetOptimizationStrategies() []RecommendationStrategy
- func (opt *KubernetesOptimizer) OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)
- func (opt *KubernetesOptimizer) RollbackOptimization(ctx context.Context, result *OptimizationResult) error
- func (opt *KubernetesOptimizer) ValidateOptimization(ctx context.Context, result *OptimizationResult) error
- type LLMOptimizerConfig
- type LLMProcessorOptimizer
- func (opt *LLMProcessorOptimizer) GetOptimizationStrategies() []RecommendationStrategy
- func (opt *LLMProcessorOptimizer) OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)
- func (opt *LLMProcessorOptimizer) RollbackOptimization(ctx context.Context, result *OptimizationResult) error
- func (opt *LLMProcessorOptimizer) ValidateOptimization(ctx context.Context, result *OptimizationResult) error
- type LatencyMetrics
- type LatencyOptimizationConfig
- type LearningIteration
- type LoadBalancingStrategy
- type MLMetrics
- type MLModelMetadata
- type MLOptimizationEngine
- func (m *MLOptimizationEngine) AddExperience(state NetworkState, action OptimizationAction, reward float64, ...)
- func (m *MLOptimizationEngine) GetMetrics() MLMetrics
- func (m *MLOptimizationEngine) PredictAction(state NetworkState) (OptimizationAction, float64, error)
- func (m *MLOptimizationEngine) Stop() error
- func (m *MLOptimizationEngine) TrainModel() error
- type MLOptimizationModel
- type MessageRoutingConfig
- type MetricAnalysis
- type MetricAnomaly
- type MetricConfig
- type MetricCorrelation
- type MetricForecast
- type MetricStatistics
- type MetricTrend
- type MetricsCache
- type MetricsStore
- type MitigationStrategy
- type ModelPerformance
- type NSSFConfig
- type NearRTRICConfig
- type NetworkConfig
- type NetworkOptimizationProfile
- type NetworkSliceConfig
- type NetworkSliceOptimizer
- type NetworkState
- type NonRTRICConfig
- type NotificationConfig
- type ObjectivePriority
- type ObjectiveType
- type Observation
- type OpportunityPriority
- type OpportunityRiskAssessment
- type OpportunityRiskFactor
- type OptimizationAction
- type OptimizationAlgorithm
- type OptimizationAlgorithmType
- type OptimizationBestPractice
- type OptimizationCategory
- type OptimizationDashboard
- type OptimizationEngine
- func (oe *OptimizationEngine) Initialize(space *ConfigurationSpace, objectives []OptimizationObjective) error
- func (oe *OptimizationEngine) SuggestConfiguration(ctx context.Context, history []*LearningIteration) (*SystemConfiguration, error)
- func (oe *OptimizationEngine) UpdateModel(ctx context.Context, iteration *LearningIteration) error
- type OptimizationExecution
- type OptimizationHistoryEntry
- type OptimizationKnowledgeBase
- type OptimizationMetricsCollector
- type OptimizationObjective
- type OptimizationOpportunity
- type OptimizationPriority
- type OptimizationQueue
- type OptimizationRanker
- type OptimizationRecommendation
- type OptimizationRecommendationEngine
- type OptimizationRequest
- type OptimizationResult
- type OptimizationRiskAssessment
- type OptimizationRollbackManager
- type OptimizationRuleAction
- type OptimizationRuleCondition
- type OptimizationSolution
- type OptimizationStats
- type OptimizationStatusData
- type OptimizationStrategy
- type OptimizationStrategyConfig
- type OptimizationValidator
- type OptimizerManager
- type PacketProcessingMode
- type ParameterDependency
- type ParameterDependencyType
- type ParameterOptimizer
- type ParameterPriority
- type ParameterRange
- type ParameterSpace
- type ParameterType
- type PatternDetector
- type PatternType
- type PerfNormalizationConfig
- type PerformanceAnalysisEngine
- type PerformanceAnalysisResult
- type PerformanceAnalyzer
- type PerformanceBaseline
- type PerformanceBenchmark
- type PerformanceBottleneck
- type PerformanceForecaster
- type PerformanceIssue
- type PerformanceMetric
- type PerformanceMetrics
- type PerformancePattern
- type PerformancePredictor
- type PerformanceTrend
- type PieChartData
- type PipelineState
- type PipelineStatistics
- type PipelineStatus
- type PolicyEngineConfig
- type PolicyNetwork
- type PredictedBottleneck
- type ProtocolTranslationConfig
- type QoSClass
- type QoSClassMetrics
- type QoSConfig
- type QoSDifferentiationConfig
- type QoSEnforcementPolicy
- type QoSFlowOptimization
- type QoSMetrics
- type QoSOptimizer
- type QoSParameters
- type QoSViolationConfig
- type QualityGate
- type QueryOptimizationRule
- type RAGOptimizerConfig
- type RAGSystemOptimizer
- func (opt *RAGSystemOptimizer) GetOptimizationStrategies() []RecommendationStrategy
- func (opt *RAGSystemOptimizer) OptimizeConfiguration(ctx context.Context, analysis *ComponentAnalysis) (*OptimizationResult, error)
- func (opt *RAGSystemOptimizer) RollbackOptimization(ctx context.Context, result *OptimizationResult) error
- func (opt *RAGSystemOptimizer) ValidateOptimization(ctx context.Context, result *OptimizationResult) error
- type RANConfig
- type RANMetrics
- type RANOptimizer
- type RICConfig
- type RICMetrics
- type RICOptimizer
- type RICResourceAllocation
- type RICServicesConfig
- type ROIAnalysis
- type ROICalculator
- type RecommendationMitigationStrategy
- type RecommendationRiskFactor
- type RecommendationStrategy
- type RecommendationStrategyType
- type RecommendationsSummary
- type ReliabilityMetric
- type ResolutionStatus
- type ResourceAllocation
- type ResourceAllocationPolicy
- type ResourceConstraint
- type ResourceConsumption
- type ResourceEfficiencyAnalysis
- type ResourceMetric
- type ResourceMetrics
- type ResourceOptimizationRule
- type ResourcePoolingConfig
- type ResourceThreshold
- type ResourceType
- type ResourceUsage
- type ResourceUsageMetrics
- type ResourceUtilization
- type ResourceWasteAnalysis
- type ResultsAnalyzer
- type RetrievalConfig
- type RetryPolicy
- type RewardFunctionType
- type RiskAssessment
- type RiskAssessor
- type RiskCategory
- type RiskImpactAnalysis
- type RiskLevel
- type RollbackEntry
- type RollbackManager
- type RootCauseAnalysis
- type RunningOptimization
- type SLABoundaries
- type SLAComplianceMetric
- type SLAMonitoringConfig
- type SMFConfig
- type SMFMetrics
- type SafetyChecks
- type SafetyConstraints
- type ScalabilityMetric
- type ScalingPolicyConfig
- type ScenarioCondition
- type SchedulingPolicy
- type SearchHint
- type SearchStrategy
- type SecurityOptimizationPolicy
- type SelectionStrategy
- type ServiceMeshConfig
- type SessionOptimization
- type SessionStateConfig
- type SeverityLevel
- type SlackConfig
- type SliceAutoScalingConfig
- type SliceIsolationConfig
- type SliceIsolationLevel
- type SliceMetrics
- type SliceOptimizationStrategy
- type SlicePerformanceConfig
- type SliceSelectionCriterion
- type SliceTemplate
- type SliceType
- type StorageConfig
- type SystemConfiguration
- type SystemHealthStatus
- type SystemInfo
- type SystemOptimizer
- type TTLRule
- type TelecomMetrics
- type TelecomMetricsCollector
- type TelecomOptimizationCategory
- type TelecomOptimizationRule
- type TelecomOptimizationStrategy
- type TelecomOptimizerConfig
- type TelecomPerformanceAnalysis
- type TelecomPerformanceOptimizer
- type ThroughputMetrics
- type TimePeriod
- type TokenRange
- type TolerationConfig
- type TopologySpreadConfig
- type TrafficShapingConfig
- type TrafficSteeringRule
- type TrendAnalysis
- type TrendData
- type TrendDirection
- type TrendType
- type UPFConfig
- type UPFMetrics
- type UPFSelectionStrategy
- type UtilizationAnomaly
- type UtilizationTrend
- type ValidationRule
- type ValidationRuleType
- type ValidationStatus
- type ValueNetwork
- type VectorDBConfig
- type VendorAdaptationConfig
- type VersionCompatibilityConfig
- type WasteFactor
- type WastedResource
- type WebhookConfig
- type WorkloadPlacementConfig
- type XAppLifecycleConfig
- type XAppLoadBalancing
- type XAppMetrics
- type XAppOptimization
- type XAppPerfMonitoring
- type XAppResourceMgmt
- type XAppSchedulingPolicy
Constants ¶
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 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 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 BatchConfig ¶
type BayesianOptimization ¶
type BayesianOptimization struct {
// contains filtered or unexported fields
}
type BeamformingConfig ¶
type BeamformingConfig struct{}
type BenchmarkComparison ¶
type BenchmarkEnvironment ¶
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 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 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 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 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 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 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 DependencyCondition ¶
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 ¶
func (optimizer *EdgeDeploymentOptimizer) OptimizeEdge(ctx context.Context, metrics *TelecomMetrics, analysis *PerformanceAnalysisResult) ([]*OptimizationRecommendation, error)
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 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 EnergyEfficiencyConfig ¶
type EnergyEfficiencyConfig struct{}
type ErrorMetrics ¶
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 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 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 GaussianProcess ¶
type GaussianProcess struct {
// contains filtered or unexported fields
}
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 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 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 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 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 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 ¶
func (m *MLOptimizationEngine) PredictAction(state NetworkState) (OptimizationAction, float64, error)
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 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 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 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 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 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
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 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 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" 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 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 QoSClassMetrics ¶
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 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 QueryOptimizationRule ¶
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 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 ResourceType ¶
type ResourceType string
const ( ResourceTypeCPU ResourceType = "cpu" ResourceTypeMemory ResourceType = "memory" ResourceTypeNetwork ResourceType = "network" ResourceTypeStorage ResourceType = "storage" ResourceTypeCompute ResourceType = "compute" )
type ResourceUsage ¶
type ResourceUsageMetrics ¶
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 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 RollbackEntry ¶
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"`
AnalysisTimestamp time.Time `json:"analysisTimestamp"`
}
type RunningOptimization ¶
type SLABoundaries ¶
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 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 StorageConfig ¶
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 TimePeriod ¶
type TokenRange ¶
type TolerationConfig ¶
type TopologySpreadConfig ¶
type TrafficShapingConfig ¶
type TrafficShapingConfig struct{}
type TrafficSteeringRule ¶
type TrafficSteeringRule struct{}
type TrendAnalysis ¶
type TrendDirection ¶
type TrendDirection string
const ( TrendDirectionIncreasing TrendDirection = "increasing" TrendDirectionDecreasing TrendDirection = "decreasing" TrendDirectionStable TrendDirection = "stable" TrendDirectionVolatile TrendDirection = "volatile" )
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 UtilizationTrend ¶
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 WastedResource ¶
type WebhookConfig ¶
type WorkloadPlacementConfig ¶
type WorkloadPlacementConfig struct{}
type XAppLifecycleConfig ¶
type XAppLifecycleConfig struct{}
type XAppLoadBalancing ¶
type XAppLoadBalancing struct{}
type XAppMetrics ¶
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