oxios_kernel/

lib.rs

//! Oxios kernel: supervisor, event bus, state store.
//!
//! The kernel is the core of the Oxios Agent OS. Everything passes
//! through here: agent lifecycle, inter-agent communication, and
//! persistent state management.

#![warn(missing_docs)]

// ─── Lifecycle ──────────────────────────────────────────────────────
// Agent 생성, 실행, 종료. OS의 init + process management.
pub mod agent_group;
pub mod agent_lifecycle;
pub mod agent_runtime;
pub mod a2a_circuit_breaker;
pub mod daemon;
pub mod supervisor;

// ─── Orchestration ──────────────────────────────────────────────────
// 작업 조율, 스케줄링, 예산 관리.
pub mod orchestrator;
pub mod scheduler;
pub mod cron;
pub mod budget;
pub mod circuit_breaker;

// ─── Security ───────────────────────────────────────────────────────
// 접근 제어, 인증, 권한, 감사.
pub mod access_manager;
pub mod auth;
pub mod capability;
pub mod credential;
pub mod audit_trail;

// ─── Communication ──────────────────────────────────────────────────
// 이벤트, 메시징, 외부 프로토콜.
pub mod event_bus;
pub mod a2a;
pub mod mcp;

// ─── Intelligence ───────────────────────────────────────────────────
// 메모리, 임베딩, 페르소나, 온보딩.
pub mod memory;
pub mod embedding;
pub mod persona;
pub mod persona_manager;
pub mod persona_store;
pub mod onboarding;

// ─── Tools & Programs ──────────────────────────────────────────────
// 에이전트가 사용하는 도구, 프로그램, 스킬.
pub mod tools;
pub mod host_tools;
pub mod program;
pub mod skill;
#[cfg(feature = "wasm-sandbox")]
pub mod wasm_sandbox;

// ─── State & Config ─────────────────────────────────────────────────
// 영속 상태, 설정, 백업, 리소스 모니터링.
pub mod state_store;
pub mod config;
pub mod backup;
pub mod git_layer;
pub mod resource_monitor;
pub mod space;

// ─── Infrastructure ─────────────────────────────────────────────────
// 엔진, 에러, 타입, 메트릭, 텔레메트리.
pub mod engine;
pub mod error;
pub mod types;
pub mod metrics;
#[cfg(feature = "otel")]
pub mod telemetry_otel;
#[cfg(feature = "otel")]
pub use telemetry_otel as telemetry;
#[cfg(not(feature = "otel"))]
pub mod telemetry_stub;
#[cfg(not(feature = "otel"))]
pub use telemetry_stub as telemetry;

// ─── API Surface ────────────────────────────────────────────────────
// 외부에 노출하는 typed facade.
pub mod kernel_handle;

// ─────────────────────────────────────────────────────────────────────
// Re-exports (같은 섹션 순서)
// ─────────────────────────────────────────────────────────────────────

// ─── Lifecycle ──────────────────────────────────────────────────────
pub use agent_group::{OxiosAgentGroup, OxiosAgentGroupStatus, OxiosGroupAgent};
pub use agent_lifecycle::AgentLifecycleManager;
pub use agent_runtime::AgentRuntime;
pub use daemon::{DaemonManager, DaemonStatus};
pub use supervisor::{BasicSupervisor, Supervisor};

// ─── Orchestration ──────────────────────────────────────────────────
pub use orchestrator::{AgentRole, OrchestrationResult, Orchestrator, SubTask};
pub use scheduler::{AgentScheduler, Priority, ScheduledTask, SchedulerStats, TaskStatus};
pub use cron::{CronJob, CronJobResult, CronJobUpdate, CronScheduler, JobSource};
pub use budget::{BudgetExceeded, BudgetInfo, BudgetKind, BudgetLimit, BudgetManager};
pub use circuit_breaker::CircuitBreaker;

// ─── Security ───────────────────────────────────────────────────────
pub use access_manager::{
    AccessManager, Action, AgentPermissions, ApprovalStatus, PendingApproval, RbacAuditEntry,
    RbacManager, RbacPolicy, Role, Subject,
};
pub use auth::{AuthManager, KeyMeta};
pub use capability::template::CapabilityTemplate;
pub use capability::{CSpace, Capability, CapabilityId, Issuer, ResourceRef, Rights};
pub use credential::CredentialStore;
pub use audit_trail::{
    AgentId as AuditAgentId, AuditAction, AuditEntry, AuditError, AuditTrail, HashDigest,
};

// ─── Communication ──────────────────────────────────────────────────
pub use event_bus::{EventBus, KernelEvent};
pub use a2a::{
    A2AMessage, A2AProtocol, A2ARequest, A2AResponse, AgentCard, AgentCardRegistry,
    DelegationHandler, TaskPriority, TaskSpec,
};
pub use mcp::{
    McpBridge, McpCapabilities, McpServer, McpTool, McpToolCallResult as CallToolResult,
};

// ─── Intelligence ───────────────────────────────────────────────────
pub use memory::auto_memory_bridge::{
    AutoMemoryBridge, ExportResult, GuidancePattern, ImportResult, InsightCategory, MemoryInsight,
    SyncDirection, SyncResult,
};
pub use memory::flash_attention::{
    BenchmarkResult as AttentionBenchmarkResult, FlashAttention, FlashAttentionConfig,
    MemoryEstimate,
};
pub use memory::hyperbolic::{
    batch_euclidean_to_poincare, euclidean_to_poincare, hyperbolic_distance, mobius_add,
    mobius_scalar_mul, HyperbolicConfig, HyperbolicEmbedding,
};
pub use memory::{
    chunk_fixed, chunk_paragraphs, content_hash, cosine_similarity_f32, l2_normalize_f32,
    l2_normalize_f64, ChunkConfig, CurationCandidate, CurationReport, HnswIndex, HnswMemoryIndex,
    MemoryBudget, MemoryEntry, MemoryGraph, MemoryManager, MemoryType, SemanticHit, TextChunk,
    TextVector,
};
pub use embedding::{EmbeddingProvider, EmbeddingVector, TfIdfEmbeddingProvider};
pub use persona::{default_personas, Persona};
pub use persona_manager::PersonaManager;
pub use persona_store::PersonaStore;

// ─── Tools & Programs ──────────────────────────────────────────────
#[cfg(feature = "browser")]
pub use tools::BrowserTool;
pub use tools::{ExecTool, ProgramTool};
pub use host_tools::{common as host_tools_common, HostToolStatus, HostToolValidator};
pub use program::{
    ArgumentDef, HostRequirementsCheck, InstallSource, Program, ProgramManager, ProgramMeta,
    ToolDef,
};
pub use skill::{Skill, SkillMeta, SkillStore};
#[cfg(feature = "wasm-sandbox")]
pub use wasm_sandbox::{ResourceKind, WasmConfig, WasmError, WasmSandbox};

// ─── State & Config ─────────────────────────────────────────────────
pub use state_store::{AgentResponse, Session, SessionId, SessionSummary, StateStore};
pub use config::{
    BrowserConfig, ChannelsConfig, CronConfig, DaemonConfig, EngineConfig, ExecConfig, ExecMode, GitConfig,
    InlineCronJob, McpConfig, McpServerDef, MemoryConfig, OrchestratorConfig, OxiosConfig, PersonaConfig,
    TelegramChannelConfig,
};
pub use backup::{BackupManifest, BackupSection};
pub use git_layer::{CommitInfo, GitLayer, LogEntry};
pub use resource_monitor::{OverloadThreshold, ResourceMonitor, ResourceSnapshot};
pub use space::{
    extract_filesystem_path, match_keywords, ConversationBuffer, ConversationTurn, CrossRefEntry,
    KnowledgeBridge, KnowledgeFlow, PathMatcher, Space, SpaceId, SpaceManager, SpaceManagerError,
    SpaceSource,
};

// ─── Infrastructure ─────────────────────────────────────────────────
pub use engine::{EngineProvider, OxiEngineProvider, OxiosEngine};
pub use error::{HttpStatus, KernelError, KernelResult};
pub use types::{AgentId, AgentInfo, AgentStatus};
pub use metrics::{get_metrics, register_builtin_metrics, registry};

// ─── API Surface ────────────────────────────────────────────────────
pub use kernel_handle::KernelHandle;
pub use kernel_handle::{
    A2aApi, AgentApi, BrowserApi, ExecApi, ExtensionApi, InfraApi, McpApi, PersonaApi, SecurityApi,
    SpaceApi, StateApi,
};

// ─── oxi-sdk re-exports ─────────────────────────────────────────────
//
// Only types that are actually USED by kernel modules are re-exported.
// Dead re-exports were removed (see audit 2026-05-16).
//
// When oxi-sdk adds full re-exports of oxi-ai/oxi-agent types,
// we can drop direct oxi-ai/oxi-agent dependencies entirely.
// See ../oxi/docs/proposals/sdk-consumer-requirements.md
pub use oxi_sdk::{
    AgentEvent,
    AgentLoop,
    InterAgentMessage,
    KernelToolContext,
    KernelToolProvider,
    MessageBus,
    Model,
    Oxi,
    OxiBuilder,
    Provider,
    StreamOptions,
};