1use meerkat_core::lifecycle::{InputId, RunId};
6use serde::{Deserialize, Serialize};
7
8use crate::accept::AcceptOutcome;
9use crate::identifiers::LogicalRuntimeId;
10use crate::input::Input;
11use crate::input_state::{InputLifecycleState, InputState, StoredInputState};
12use crate::runtime_event::RuntimeEventEnvelope;
13use crate::runtime_state::RuntimeState;
14
15#[derive(Debug, Clone, thiserror::Error)]
17#[non_exhaustive]
18pub enum RuntimeDriverError {
19 #[error("Runtime not ready: {state}")]
21 NotReady { state: RuntimeState },
22
23 #[error("Runtime not found: {runtime_id}")]
30 NotFound { runtime_id: LogicalRuntimeId },
31
32 #[error("Input validation failed: {reason}")]
34 ValidationFailed { reason: String },
35
36 #[error("Runtime destroyed")]
38 Destroyed,
39
40 #[error("Recovery corruption: {reason}")]
42 RecoveryCorruption { reason: String },
43
44 #[error("Internal error: {0}")]
46 Internal(String),
47}
48
49#[derive(Debug, Clone, thiserror::Error)]
51#[non_exhaustive]
52pub enum RuntimeControlPlaneError {
53 #[error("Runtime not found: {0}")]
55 NotFound(LogicalRuntimeId),
56
57 #[error("Invalid state for operation: {state}")]
59 InvalidState { state: RuntimeState },
60
61 #[error("Store error: {0}")]
63 StoreError(String),
64
65 #[error("Internal error: {0}")]
67 Internal(String),
68}
69
70#[derive(Debug, Clone, Serialize, Deserialize)]
72pub struct RecoveryReport {
73 pub inputs_recovered: usize,
75 pub inputs_abandoned: usize,
77 pub inputs_requeued: usize,
79 #[serde(default, skip_serializing_if = "Vec::is_empty")]
81 pub details: Vec<String>,
82}
83
84#[derive(Debug, Clone, Serialize, Deserialize)]
86pub struct RetireReport {
87 pub inputs_abandoned: usize,
89 #[serde(default)]
91 pub inputs_pending_drain: usize,
92}
93
94#[derive(Debug, Clone, Serialize, Deserialize)]
96pub struct ResetReport {
97 pub inputs_abandoned: usize,
99}
100
101#[derive(Debug, Clone, Serialize, Deserialize)]
103pub struct RecycleReport {
104 pub inputs_transferred: usize,
106}
107
108#[derive(Debug, Clone, Serialize, Deserialize)]
110pub struct DestroyReport {
111 pub inputs_abandoned: usize,
113}
114
115#[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
120#[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
121pub trait RuntimeDriver: Send + Sync {
122 async fn accept_input(&mut self, input: Input) -> Result<AcceptOutcome, RuntimeDriverError>;
124
125 async fn on_runtime_event(
127 &mut self,
128 event: RuntimeEventEnvelope,
129 ) -> Result<(), RuntimeDriverError>;
130
131 async fn recover(&mut self) -> Result<RecoveryReport, RuntimeDriverError>;
133
134 fn runtime_state(&self) -> RuntimeState;
136
137 fn input_state(&self, input_id: &InputId) -> Option<&InputState>;
139
140 fn input_phase(&self, input_id: &InputId) -> Option<InputLifecycleState>;
142
143 fn input_last_run_id(&self, input_id: &InputId) -> Option<RunId>;
145
146 fn input_last_boundary_sequence(&self, input_id: &InputId) -> Option<u64>;
148
149 fn stored_input_state(&self, input_id: &InputId) -> Option<StoredInputState>;
151
152 fn active_input_ids(&self) -> Vec<InputId>;
154}
155
156#[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
158#[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
159pub trait RuntimeControlPlane: Send + Sync {
160 async fn ingest(
162 &self,
163 runtime_id: &LogicalRuntimeId,
164 input: Input,
165 ) -> Result<AcceptOutcome, RuntimeControlPlaneError>;
166
167 async fn publish_event(
169 &self,
170 event: RuntimeEventEnvelope,
171 ) -> Result<(), RuntimeControlPlaneError>;
172
173 async fn retire(
175 &self,
176 runtime_id: &LogicalRuntimeId,
177 ) -> Result<RetireReport, RuntimeControlPlaneError>;
178
179 async fn recycle(
181 &self,
182 runtime_id: &LogicalRuntimeId,
183 ) -> Result<RecycleReport, RuntimeControlPlaneError>;
184
185 async fn reset(
187 &self,
188 runtime_id: &LogicalRuntimeId,
189 ) -> Result<ResetReport, RuntimeControlPlaneError>;
190
191 async fn recover(
193 &self,
194 runtime_id: &LogicalRuntimeId,
195 ) -> Result<RecoveryReport, RuntimeControlPlaneError>;
196
197 async fn runtime_state(
199 &self,
200 runtime_id: &LogicalRuntimeId,
201 ) -> Result<RuntimeState, RuntimeControlPlaneError>;
202
203 async fn destroy(
205 &self,
206 runtime_id: &LogicalRuntimeId,
207 ) -> Result<DestroyReport, RuntimeControlPlaneError>;
208
209 async fn load_boundary_receipt(
211 &self,
212 runtime_id: &LogicalRuntimeId,
213 run_id: &RunId,
214 sequence: u64,
215 ) -> Result<Option<meerkat_core::lifecycle::RunBoundaryReceipt>, RuntimeControlPlaneError>;
216}
217
218#[cfg(test)]
219#[allow(clippy::unwrap_used)]
220mod tests {
221 use super::*;
222
223 fn _assert_driver_object_safe(_: &dyn RuntimeDriver) {}
225 fn _assert_control_plane_object_safe(_: &dyn RuntimeControlPlane) {}
226
227 #[test]
228 fn runtime_driver_error_display() {
229 let err = RuntimeDriverError::NotReady {
230 state: RuntimeState::Initializing,
231 };
232 assert!(err.to_string().contains("initializing"));
233
234 let err = RuntimeDriverError::ValidationFailed {
235 reason: "bad input".into(),
236 };
237 assert!(err.to_string().contains("bad input"));
238 }
239
240 #[test]
241 fn runtime_control_plane_error_display() {
242 let err = RuntimeControlPlaneError::NotFound(LogicalRuntimeId::new("missing"));
243 assert!(err.to_string().contains("missing"));
244 }
245
246 #[test]
247 fn recovery_report_serde() {
248 let report = RecoveryReport {
249 inputs_recovered: 5,
250 inputs_abandoned: 1,
251 inputs_requeued: 3,
252 details: vec!["requeued 3 staged inputs".into()],
253 };
254 let json = serde_json::to_value(&report).unwrap();
255 let parsed: RecoveryReport = serde_json::from_value(json).unwrap();
256 assert_eq!(parsed.inputs_recovered, 5);
257 }
258}