Error implements the error interface.

Add adds a request to the queue (deduplication: if already queued, skip).

NowUTC returns current time in UTC

Set stores a value in the cache with a TTL.

JSON returns the version information as a JSON string.

============================================================================ Utility Functions =======================================================

Contains checks if an element is in the set (add_tags - rem_tags non-empty)

Done marks a request as done processing. If the request was re-added while being processed, it will be enqueued again.

Get retrieves a value from the cache. Returns (nil, nil) if the key is not found (cache miss).

Add queues a record for batch insert. Flushes automatically when buffer is full.

Close releases resources.

Lifecycle

Metadata returns the plugin's metadata.

RequirePermission returns middleware that checks for specific permission

Stop gracefully shuts down the plugin.

ServeHTTP starts an HTTP health check server.

NewEngine creates a new scheduling engine.

SuccessResult returns a success result for the given plugin.

IsZero returns true if the result indicates no requeue is needed.

Query retrieves time-series data matching the query parameters.

Close releases cache resources.

HasErrors returns true if there are validation errors.

Run starts the leader election loop. Blocks until ctx is cancelled. Calls the OnStartedLeading callback when this instance becomes the leader.

Error implements the error interface.

IsSuccess returns true if the result indicates success.

NewResult creates a new empty validation result.

DefaultSelfHealConfig returns sensible defaults.

Add adds an element with a unique tag

============================================================================ Constructor & Core Operations ===========================================

SetCondition adds or updates a condition in the status.

============================================================================ Controller Manager tests ================================================

============================================================================ Registration ============================================================

Start is called after Init to begin the plugin's operation.

NewCycleState creates an empty CycleState.

State returns the current circuit breaker state.

Write writes metric samples to the time-series database.

============================================================================ Registry Tests ==========================================================

Delete removes a key from the cache.

NewEvent creates a new event with the given topic, type, source, and payload.

NewManager creates a new feature flag manager with built-in defaults. Load order (later overrides earlier): 1. Built-in defaults (ProfileStandard) 2.

NewRegistry creates an empty Registry.

Stats returns cache statistics.

min returns the smaller of two ints.

Close shuts down the event bus and releases resources.

DefaultAutoscaleConfig returns sensible defaults.

WithContext returns a logrus.Entry enriched with trace/request IDs from context.

DefaultManagerConfig returns sensible defaults.

NewManager creates a new observability manager.

NewPredictiveAutoscaler creates a new predictive auto-scaler.

Use adds a middleware to the bus.

DefaultManagerConfig returns sensible defaults.

Execute runs fn through the circuit breaker. Returns ErrCircuitOpen if the circuit is open.

New creates a new control plane service.

NewBasePlugin creates a BasePlugin with the given metadata.

NewManager creates a new multi-cluster manager.

Create creates a new workload.

newTestRouter creates a router wired with all mock services.

AddError appends a field validation error.

DefaultCanaryConfig returns production-grade canary defaults.

============================================================================ State / Action Encoding =================================================

GetByExtension returns all plugins registered for the given extension point, ordered by priority (ascending).

DB returns the underlying GORM DB (for advanced queries)

NewCanaryController creates a new canary deployment controller.

NewMemoryCache creates an in-memory LRU cache.

RegisterReconciler adds a reconciler to the manager. Must be called before Start().

SubmitWorkload adds a workload directly to the scheduling queue (for programmatic use / tests).

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

Pod operations

NewManager creates a new security manager with real sub-engines

NewRouter creates the main API router with all routes configured

============================================================================ NewTestRouterConfig returns a RouterConfig with all mocks pre-populated.

RecordEvent stores an audit event.

RegisterEventTrigger maps an event bus topic to a controller name. When an event matching the topic arrives, the control plane will enqueue a reconcil

Tracer returns the named tracer.

Reset environment to initial state.

Count returns total stored events.

============================================================================ Application Lifecycle ===================================================

============================================================================ Backup Operations =======================================================

DefaultCapacityPlanConfig returns sensible defaults.

DefaultManagerConfig returns sensible defaults.