NewSplitBrainDetector creates a new split-brain detector.

NotFound creates a 404 error for a specific resource type and identifier.

============================================================================ Utility — condition builders ============================================

ReportPeer updates the status of a peer node.

ScoreTopology calculates a topology score (0-100) for placing a workload on specific GPUs Higher score = better GPU interconnection for the given work

UpdateDrillStep updates the status of a specific drill step.

UpdateUsage updates the current resource usage for a tenant

Analyze GPU metrics using statistical + deep learning ensemble.

Chat completion with JSON output parsing. Parsing strategy (ordered by priority): 1. Try raw text as JSON directly. 2. Ex

doROARequest performs a signed ROA-style API request via the official SDK

Generate predictive scaling recommendations.

readLEB128 reads a LEB128 unsigned integer from a byte slice

============================================================================ Node Scoring ============================================================

severityRank returns a numeric rank for alert severity (higher = more severe).

Add adds a key to the bloom filter.

AddErrorf appends a formatted field validation error.

ApplyDecision applies a scaling decision and records the event.

CheckPassword compares a plaintext password with a bcrypt hash

============================================================================ Incident Retrospective ==================================================

============================================================================ Support Ticket System ===================================================

ErrorCondition creates an Error=True condition.

Evaluate makes a local scheduling decision based on policies and resources.

Get returns the circuit breaker for a service, creating one if needed.

Identity returns this instance's unique identity.

IncrementCounter increments a distributed counter

IngestSnapshot adds a resource snapshot for analysis.

Is implements sentinel error comparison. Two AppErrors are equal if their Code matches.

IsLeader returns true if this instance currently holds the lease.

ListFlags returns all registered feature flags sorted by category then key.

NewClusterReconciler creates a new ClusterReconciler.

NewCostAnalysisEngine creates a new cost analysis engine.

NewHub creates a new WebSocket hub and starts the event loop.

NewManager creates a new cloud provider manager

NewManager creates a new cluster manager

NewMultiLevelCache creates a two-tier cache (L1=memory, L2=Redis).

NewNodeWatchCache creates a new node watch cache.

NewResult creates a new result.

NewService creates a new monitoring service

NewWorkloadReconciler creates a new WorkloadReconciler.

Predict generates interruption prediction for a specific instance type.

RecordError increments the error count for a source.

RecordRequest records a request for budget tracking.

RegisterCluster registers a cluster for capacity planning.

Remediate executes automatic remediation for an incident.

Reset forces the circuit breaker back to Closed state.

Shutdown flushes remaining spans and shuts down the provider.

StartBackup transitions a backup to running state (simulates execution).

Status returns the current status of the Raft node.

String returns a human-readable health status.

============================================================================ Image Verification Operations (cosign) ==================================

WithCause wraps an underlying error.

afterRequest records the result and potentially transitions state.

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

============================================================================ SLOTracker — RecordRequest + Status =====================================

============================================================================ Core Scheduling Logic ===================================================

Check performs split-brain detection. Returns true if split-brain is detected.

============================================================================ Archival Policy Management ==============================================

============================================================================ SLA Management ==========================================================

DefaultAlertConvergenceConfig returns production convergence settings.

DefaultCRDTConfig returns production-ready CRDT defaults

DeletePattern removes all keys matching a glob pattern.

Execute runs a distributed transaction across all involved participants. This is the main entry point for application code.

Get blocks until an item is available, then returns it. The caller MUST call Done() when processing is complete. Returns (Request{}, true) if the queu

GetBudget returns the budget state for a service.

GetCachedNodes returns the cached node list (thread-safe).

GetEventCount returns the total number of stored events.

GetFlag returns a specific flag's state.

GetNodeAutonomyState returns autonomy status for a node

HandleEvent processes an event and transitions state accordingly.

IngestMetrics adds metric samples for analysis.

IngestPriceData adds historical spot price data for analysis.

IngestUsageData adds historical usage data for analysis.

IsTokenRevoked checks if a token has been revoked by its JTI.

JITProvision automatically provisions a local account for a federated identity. If the user already exists (matched by external sub), it updates the l

List returns workloads with pagination and filtering.

New creates a new gRPC server with the given configuration.

NewCRDTSyncEngine creates a new CRDT sync engine

NewManager creates a new audit manager.

NewOptimizationEngine creates a new optimization engine

NumRequeues returns the number of times a request has been requeued.

Publish sends a message to the specified queue.

Reconcile performs a single reconciliation pass for a Workload object. The reconciliation loop drives workloads through their lifecycle: pending → q

============================================================================ Billing & Metering ======================================================

============================================================================ Retry Executor ==========================================================

============================================================================ Token Revocation & Logout ===============================================

============================================================================ Lifecycle ===============================================================

SetFlag updates or creates a feature flag.