loong_kernel/
runtime.rs

1use std::{collections::BTreeMap, sync::Arc};
2
3use async_trait::async_trait;
4
5// Re-export data types from contracts
6pub use loong_contracts::{
7    RuntimeCoreOutcome, RuntimeCoreRequest, RuntimeExtensionOutcome, RuntimeExtensionRequest,
8    RuntimeTier,
9};
10
11use crate::errors::RuntimePlaneError;
12
13#[async_trait]
14pub trait CoreRuntimeAdapter: Send + Sync {
15    fn name(&self) -> &str;
16
17    async fn execute_core(
18        &self,
19        request: RuntimeCoreRequest,
20    ) -> Result<RuntimeCoreOutcome, RuntimePlaneError>;
21}
22
23#[async_trait]
24pub trait RuntimeExtensionAdapter: Send + Sync {
25    fn name(&self) -> &str;
26
27    async fn execute_extension(
28        &self,
29        request: RuntimeExtensionRequest,
30        core: &(dyn CoreRuntimeAdapter + Sync),
31    ) -> Result<RuntimeExtensionOutcome, RuntimePlaneError>;
32}
33
34#[derive(Default)]
35pub struct RuntimePlane {
36    core_adapters: BTreeMap<String, Arc<dyn CoreRuntimeAdapter>>,
37    extension_adapters: BTreeMap<String, Arc<dyn RuntimeExtensionAdapter>>,
38    default_core_adapter: Option<String>,
39}
40
41impl RuntimePlane {
42    #[must_use]
43    pub fn new() -> Self {
44        Self {
45            core_adapters: BTreeMap::new(),
46            extension_adapters: BTreeMap::new(),
47            default_core_adapter: None,
48        }
49    }
50
51    pub fn register_core_adapter<A: CoreRuntimeAdapter + 'static>(&mut self, adapter: A) {
52        let name = adapter.name().to_owned();
53        if self.default_core_adapter.is_none() {
54            self.default_core_adapter = Some(name.clone());
55        }
56        self.core_adapters.insert(name, Arc::new(adapter));
57    }
58
59    pub fn register_extension_adapter<A: RuntimeExtensionAdapter + 'static>(&mut self, adapter: A) {
60        let name = adapter.name().to_owned();
61        self.extension_adapters.insert(name, Arc::new(adapter));
62    }
63
64    pub fn set_default_core_adapter(&mut self, name: &str) -> Result<(), RuntimePlaneError> {
65        if !self.core_adapters.contains_key(name) {
66            return Err(RuntimePlaneError::CoreAdapterNotFound(name.to_owned()));
67        }
68        self.default_core_adapter = Some(name.to_owned());
69        Ok(())
70    }
71
72    #[must_use]
73    pub fn default_core_adapter_name(&self) -> Option<&str> {
74        self.default_core_adapter.as_deref()
75    }
76
77    pub async fn execute_core(
78        &self,
79        core_name: Option<&str>,
80        request: RuntimeCoreRequest,
81    ) -> Result<RuntimeCoreOutcome, RuntimePlaneError> {
82        let resolved_name = if let Some(name) = core_name {
83            name
84        } else {
85            self.default_core_adapter
86                .as_deref()
87                .ok_or(RuntimePlaneError::NoDefaultCoreAdapter)?
88        };
89
90        let adapter = self
91            .core_adapters
92            .get(resolved_name)
93            .ok_or(RuntimePlaneError::CoreAdapterNotFound(
94                resolved_name.to_owned(),
95            ))?
96            .clone();
97
98        return adapter.execute_core(request).await;
99    }
100
101    pub async fn execute_extension(
102        &self,
103        extension_name: &str,
104        core_name: Option<&str>,
105        request: RuntimeExtensionRequest,
106    ) -> Result<RuntimeExtensionOutcome, RuntimePlaneError> {
107        let extension = self
108            .extension_adapters
109            .get(extension_name)
110            .ok_or_else(|| RuntimePlaneError::ExtensionNotFound(extension_name.to_owned()))?
111            .clone();
112
113        let resolved_core_name = if let Some(name) = core_name {
114            name
115        } else {
116            self.default_core_adapter
117                .as_deref()
118                .ok_or(RuntimePlaneError::NoDefaultCoreAdapter)?
119        };
120
121        let core = self
122            .core_adapters
123            .get(resolved_core_name)
124            .ok_or(RuntimePlaneError::CoreAdapterNotFound(
125                resolved_core_name.to_owned(),
126            ))?
127            .clone();
128
129        return extension.execute_extension(request, core.as_ref()).await;
130    }
131}
loong_kernel/runtime.rs

loong_kernel/
runtime.rs
