Analyze generates RI recommendations for all tracked instance types.

AnalyzeKVCache computes KV-cache memory requirements and recommends optimizations. KV-cache size formula: Base: 2 * num_layers * num_kv_heads * hea

ApplyProfile enables/disables flags according to the given profile. Flags whose MinProfile <= the target profile are enabled; others disabled. Environ

============================================================================ Quota Management ========================================================

ControllerManager returns the underlying controller manager for reconciler registration.

============================================================================ Disaster Recovery =======================================================

============================================================================ Runbook Automation ======================================================

============================================================================ Tenant Lifecycle ========================================================

DatabaseURL constructs the PostgreSQL connection string

DefaultCacheConfig returns production-ready cache defaults

DefaultConfig returns sensible defaults for the gRPC server.

DefaultCrossAZConfig returns production cross-AZ deployment config.

DefaultEdgeCollabConfig returns production-ready defaults

DefaultFederationConfig returns production-ready defaults

DefaultKVCacheConfig returns production config for 50B model on Jetson Orin.

DefaultOfflineRuntimeConfig returns production-ready defaults.

DefaultPSSConfig returns the default restricted PSS configuration.

DefaultRateLimitConfig returns sensible defaults for API rate limiting.

DefaultRedisSentinelConfig returns production-ready Redis Sentinel configuration.

DefaultSLOs returns the standard SLO definitions for CloudAI Fusion services.

Deploy deploys a Wasm module as function instances via runtime API

DescribeEKSCluster gets detailed info for a specific cluster

DiscoverTopology queries real GPU topology on the current node

Enqueue adds a workload to the priority queue

EstimatedFPRate returns the estimated current false positive rate.

EventCount returns the number of split-brain events detected.

GGUFBitsPerWeight returns the effective bits-per-weight for a GGUF quant type.

============================================================================ Audit Reports ===========================================================

GenerateForecast produces a load forecast for the prediction horizon

GenerateReport creates a comprehensive cost analysis report.

GenerateToken creates a JWT token pair for the given user.

GetAKSCluster retrieves a specific AKS cluster

GetCluster returns a specific cluster (DB-first with cache fallback)

GetCounterValue returns the value of a distributed counter

GetGKECluster retrieves a specific GKE cluster

GetGPUSharingStates returns all GPU sharing states

GetMember retrieves a member cluster by ID.

GetNodeUpgradeStatus returns upgrade status for a node

GetOverallStatus returns the worst health status across all components.

GetSchedule returns a specific schedule.

GetStatistics returns RL optimizer statistics

ImportCluster imports an existing Kubernetes cluster

Increment increases the counter for a node

Init is called once during plugin initialization. The config map is plugin-specific configuration.

InitGPUMemoryState initializes memory tracking for a GPU

Internal creates a 500 error, wrapping the underlying cause.

IsActive returns whether the subscription is still active.

IsReady returns whether the engine is ready to accept requests.

Merge merges another OR-Set

New creates a new Migrator with the given config and migrations.

NewCollector creates a new metrics collector

NewDeploymentManager creates a new deployment manager.

NewEdgeCache creates a new edge cache

NewEdgeCollabHub creates and initializes all edge collaboration subsystems

NewFederationScheduler creates a new federation scheduler

NewGPUResourceFilterPlugin creates the default GPU filter.

NewLocalDecisionEngine creates a new local decision engine.

NewManager creates a new plugin Manager backed by the given Registry.

NewMiddlewareBus wraps an existing EventBus with middleware support.

NewOfflineRuntime creates a new offline runtime for an edge node.

NewResourceCollector creates a new resource collector.

NewSecurityPolicyReconciler creates a new SecurityPolicyReconciler.

NewTaintTolerationFilterPlugin creates the taint filter.

NewWebhookPlugin creates a WebhookPlugin from config.

PredefinedSandboxProfiles returns built-in security profiles

Publish sends an event to all subscribed WebSocket clients.

Reconcile performs a single reconciliation pass for a SecurityPolicy object.

RecordAuditLog records a security audit event to DB and/or memory

RecordDataPoint records a new utilization data point

RecordSLAReport records SLA compliance for a period

Register adds a custom collector to the registry.

============================================================================ RegisterDefaults registers all built-in plugins into a registry =========

RegisterTemplate registers a constraint template

RegisterWebhook registers a new admission webhook

RequestIDFromContext extracts the request ID from context.

RunCISBenchmark executes CIS Kubernetes Benchmark checks via real K8s API

============================================================================ Index Lifecycle Management (ELK) ========================================

SetStore injects a database store for persistent module/instance management

Size returns the current queue size.

Status returns the current status of the control plane.

SubscribeGroup registers a handler in a named consumer group. Within a group, each event is delivered to only one handler (load-balanced).

ToError converts fatal validation errors to a single Go error

TraceIDFromContext extracts the trace ID from context.

URI returns the SPIFFE URI: spiffe://<trust_domain>/<namespace>/<service>

Unregister removes a custom collector.

Unsubscribe removes a subscription by ID.

Safe JSON serialization with fallback.

============================================================================ Statistical Helpers =====================================================

============================================================================ Helpers =================================================================

containsLower checks if s contains substr (case-insensitive via simple ASCII lower)

Build prompt for cost optimization analysis.

Detect anomalies and enhance with LLM threat analysis.

Export SAC actor to ONNX.

============================================================================ Helpers — generate realistic large-scale cluster topology ===============