Struct RingKernelContext 

pub struct RingKernelContext { /* private fields */ }

Unified runtime context managing all enterprise features.

This is the main entry point for using RingKernel’s enterprise features. It instantiates and manages:

• Health checking and circuit breakers
• Prometheus metrics exporter
• Multi-GPU coordination
• Kernel migration infrastructure
• Background monitoring tasks

Lifecycle

The runtime goes through these states:

• Initializing → Running → Draining → ShuttingDown → Stopped

Use start_monitoring() to begin background health checks and watchdog scans. Use shutdown() for graceful termination.

Implementations

impl RingKernelContext

pub fn config(&self) -> &RingKernelConfig

Get the configuration.

pub fn health_checker(&self) -> Arc<HealthChecker>

Get the health checker.

pub fn watchdog(&self) -> Arc<KernelWatchdog>

Get the kernel watchdog.

pub fn circuit_breaker(&self) -> Arc<CircuitBreaker>

Get the circuit breaker.

pub fn degradation_manager(&self) -> Arc<DegradationManager>

Get the degradation manager.

pub fn prometheus_exporter(&self) -> Arc<PrometheusExporter>

Get the Prometheus exporter.

pub fn observability(&self) -> Arc<ObservabilityContext>

Get the observability context.

pub fn multi_gpu_coordinator(&self) -> Arc<MultiGpuCoordinator>

Get the multi-GPU coordinator.

pub fn migrator(&self) -> Arc<KernelMigrator>

Get the kernel migrator.

pub fn checkpoint_storage(&self) -> Arc<dyn CheckpointStorage>

Get the checkpoint storage.

pub fn is_running(&self) -> bool

Check if the runtime is running.

pub fn uptime(&self) -> Duration

Get runtime uptime.

pub fn stats(&self) -> RuntimeStatsSnapshot

Get runtime statistics.

pub fn record_kernel_launch(&self)

Record a kernel launch.

pub fn record_messages(&self, count: u64)

Record messages processed.

pub fn record_migration(&self)

Record a migration completion.

pub fn record_checkpoint(&self)

Record a checkpoint creation.

pub fn record_health_check(&self)

Record a health check run.

pub fn record_circuit_trip(&self)

Record a circuit breaker trip.

pub fn lifecycle_state(&self) -> LifecycleState

Get the current lifecycle state.

pub fn is_shutdown_requested(&self) -> bool

Check if shutdown has been requested.

pub fn is_accepting_work(&self) -> bool

Check if the runtime is accepting new work.

pub fn start(&self) -> Result<()>

Transition to running state.

Call this after initialization is complete to start accepting work.

pub fn run_health_check_cycle(&self) -> HealthCycleResult

Run a single health check cycle.

This performs one round of health checks and updates the circuit breaker and degradation manager based on the results.

Note: This is a synchronous method that uses cached circuit breaker state. For full async health checks, use the HealthChecker directly.

pub fn run_watchdog_cycle(&self) -> WatchdogResult

Run a single watchdog scan cycle.

This checks for stale kernels and takes appropriate action.

pub fn flush_metrics(&self) -> String

Flush metrics to Prometheus.

This renders current metrics to the Prometheus exporter format.

pub fn background_task_status(&self) -> BackgroundTaskStatus

Get background task status.

pub fn start_monitoring( self: &Arc<Self>, config: MonitoringConfig, ) -> MonitoringHandles

Start background monitoring loops.

This spawns async tasks for:

• Health check loop (runs at configured interval)
• Watchdog loop (checks for stale kernels)
• Metrics flush loop (exports Prometheus metrics)

Returns handles that can be used to stop the monitoring tasks.

Example

let runtime = RuntimeBuilder::new().production().build()?;
runtime.start()?;

let config = MonitoringConfig::new()
    .health_check_interval(Duration::from_secs(5))
    .watchdog_interval(Duration::from_secs(2));

let handles = runtime.start_monitoring(config).await;

// ... runtime runs ...

// Graceful shutdown
handles.signal_shutdown();
handles.wait_for_shutdown().await;

pub fn start_monitoring_default(self: &Arc<Self>) -> MonitoringHandles

Start monitoring with default configuration.

pub fn request_shutdown(&self) -> Result<()>

Request graceful shutdown.

This signals background tasks to stop and transitions to draining state. Returns immediately; use wait_for_shutdown() to block until complete.

pub fn complete_shutdown(&self) -> Result<ShutdownReport>

Complete the shutdown process.

This performs final cleanup and transitions to stopped state.

pub fn shutdown(&self) -> Result<()>

Shutdown the runtime gracefully (legacy method).

This is equivalent to request_shutdown() followed by complete_shutdown().

pub fn app_info(&self) -> AppInfo

Get application info.

impl RingKernelContext

pub fn export_metrics(&self) -> String

Export Prometheus metrics.

pub fn metrics_snapshot(&self) -> ContextMetrics

Create a metrics snapshot for the runtime context.