Crate omega_runtime

Crate omega_runtime 

Source
Expand description

§Omega Runtime

Integrated runtime environment for the ExoGenesis Omega system. Coordinates all subsystems including AgentDB, Memory, Loops, and Meta-SONA.

§Overview

The Omega Runtime provides a unified orchestration layer for all Omega subsystems:

  • AgentDB: Agent lifecycle and persistence management
  • Memory System: Multi-tier memory with working, short-term, and long-term storage
  • Loop Engine: Cognitive loops (conscious, subconscious, meta, unconscious)
  • Meta-SONA: Self-organizing neural architectures and evolution

§Features

  • Event System: Comprehensive event bus for system-wide notifications
  • State Management: Robust state machine with lifecycle management
  • Configuration: Flexible, validated configuration system
  • API: High-level API for all subsystem operations
  • Health Monitoring: Built-in health checks for all components

§Example

use omega_runtime::{OmegaRuntime, OmegaConfig, OmegaAPI};
use std::sync::Arc;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create runtime with default configuration
    let config = OmegaConfig::default();
    let runtime = Arc::new(OmegaRuntime::new(config).await?);

    // Start all subsystems
    runtime.start().await?;

    // Create API for high-level operations
    let api = OmegaAPI::new(runtime.clone());

    // Use the API...

    // Shutdown gracefully
    runtime.stop().await?;
    Ok(())
}

Re-exports§

pub use api::Architecture;
pub use api::CycleInput;
pub use api::CycleOutput;
pub use api::Intelligence;
pub use api::IntelligenceSpec;
pub use api::LoopInfo;
pub use api::LoopStatus;
pub use api::Memory;
pub use api::OmegaAPI;
pub use api::RuntimeMetrics;
pub use circuit_breaker::CircuitBreaker;
pub use circuit_breaker::CircuitBreakerConfig;
pub use circuit_breaker::CircuitBreakerError;
pub use circuit_breaker::CircuitState;
pub use config::AgentDBConfig;
pub use config::LoopsConfig;
pub use config::MemoryConfig;
pub use config::MetaSONAConfig;
pub use config::OmegaConfig;
pub use degradation::DegradationError;
pub use degradation::DegradationManager;
pub use degradation::FeatureInfo;
pub use error::APIError;
pub use error::APIResult;
pub use error::ConfigError;
pub use error::ConfigResult;
pub use error::RuntimeError;
pub use error::RuntimeResult;
pub use events::ArchitectureId;
pub use events::EventBus;
pub use events::EventHandler;
pub use events::IntelligenceId;
pub use events::LoopType;
pub use events::MemoryTier;
pub use events::OmegaEvent;
pub use health::HealthError;
pub use health::HealthMonitor;
pub use health::HealthMonitorConfig;
pub use health::HealthStatus;
pub use health::SubsystemHealth;
pub use retry::RetryConfig;
pub use retry::RetryConfigBuilder;
pub use retry::RetryError;
pub use retry::RetryPolicy;
pub use runtime::OmegaRuntime;
pub use runtime::RuntimeHealth;
pub use runtime::RuntimeState;

Modules§

api
High-level API for interacting with the Omega Runtime
circuit_breaker
Circuit Breaker Pattern Implementation
config
Runtime configuration for the Omega system
degradation
Feature Degradation Management
error
Error types for the Omega Runtime
events
Event system for the Omega Runtime
health
Health Monitoring System
retry
Retry Policy Implementation
runtime
Main runtime orchestrator for the Omega system