lenso_contracts/
runtime.rs

1//! Pure-data runtime declarations for module manifests.
2//!
3//! These declarations describe runtime behavior a module can provide without
4//! carrying executable handlers. Loading sources decide how to bind them later.
5
6use serde::{Deserialize, Serialize};
7use serde_json::Value;
8use utoipa::ToSchema;
9
10#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize, ToSchema)]
11pub struct RuntimeSurface {
12    #[serde(default)]
13    pub functions: Vec<RuntimeFunctionDeclaration>,
14    #[serde(default)]
15    pub schedules: Vec<ScheduledFunctionDeclaration>,
16}
17
18#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize, ToSchema)]
19pub struct RuntimeFunctionDeclaration {
20    /// Stable function name used by `runtime.function_runs`.
21    pub name: String,
22    /// Version for the declared function contract.
23    pub version: u16,
24    /// Queue name the host should use when registering the function.
25    pub queue: String,
26    /// Optional schema identifier for the function input payload.
27    #[serde(default, skip_serializing_if = "Option::is_none")]
28    pub input_schema: Option<String>,
29    /// Optional retry policy requested by the module. The host still owns
30    /// enforcement and may clamp values when behavior registration is added.
31    #[serde(default, skip_serializing_if = "Option::is_none")]
32    pub retry_policy: Option<RuntimeRetryPolicyDeclaration>,
33    #[serde(default, skip_serializing_if = "Option::is_none")]
34    pub operation: Option<crate::ServiceOperationMetadata>,
35}
36
37#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize, ToSchema)]
38pub struct RuntimeRetryPolicyDeclaration {
39    pub max_attempts: u32,
40    pub initial_delay_ms: u64,
41}
42
43#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize, ToSchema)]
44pub struct ScheduledFunctionDeclaration {
45    /// Stable schedule name scoped to the owning module.
46    pub name: String,
47    /// Runtime function enqueued when this schedule is due.
48    pub function_name: String,
49    /// Standard 5-field cron expression in UTC.
50    pub cron: String,
51    #[serde(default)]
52    pub input: Value,
53}
lenso_contracts/runtime.rs

lenso_contracts/
runtime.rs
