a3s-box-runtime 3.2.0

MicroVM runtime engine — VM lifecycle, OCI images, attestation, networking
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

//! Scale Manager — Tracks instances per service and processes scale requests.
//!
//! Manages the mapping between services and their running instances,
//! handles scale-up/scale-down decisions, and emits instance state events.

use a3s_box_core::scale::{InstanceHealth, InstanceState};
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

mod api;
mod authority;
mod catalog;
mod endpoints;
mod manager;
mod reconciler;
mod registry;

#[cfg(test)]
mod tests;

// Re-export public types
pub use api::{scale_router, serve_scale_api, ScaleApiState, SharedScaleAuthority};
pub use authority::{DurableScaleAuthority, ScaleAuthorityError};
pub use catalog::{
    ScaleCatalogError, ScaleServiceCatalog, SCALE_GUEST_PORT_LABEL, SCALE_MANAGED_LABEL,
    SCALE_SERVICE_LABEL, SCALE_SLOT_LABEL, SCALE_TEMPLATE_DIGEST_LABEL,
};
pub use endpoints::{ScaleEndpointConfig, ScaleEndpointConfigError};
pub use manager::ScaleManager;
pub use reconciler::{
    LocalScaleReconciler, ScaleReconcileError, ScaleReconcileObservation, ScaleReconcileReport,
};
pub use registry::InstanceRegistry;

/// Instances belonging to a single service.
#[derive(Debug, Clone)]
pub(super) struct ServiceInstances {
    /// Target replica count
    pub(super) target_replicas: u32,
    /// Active instances
    pub(super) instances: Vec<TrackedInstance>,
}

/// A tracked instance with its current state.
#[derive(Debug, Clone)]
pub(super) struct TrackedInstance {
    pub(super) id: String,
    pub(super) state: InstanceState,
    pub(super) created_at: DateTime<Utc>,
    pub(super) ready_at: Option<DateTime<Utc>>,
    pub(super) endpoint: Option<String>,
    pub(super) health: InstanceHealth,
}

/// Aggregated health metrics for a service.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct ServiceHealth {
    /// Number of active instances (Ready + Busy)
    pub active_instances: u32,
    /// Number of Ready instances
    pub ready_instances: u32,
    /// Number of Busy instances
    pub busy_instances: u32,
    /// Average CPU usage across active instances
    pub avg_cpu_percent: Option<f32>,
    /// Total memory usage across all active instances
    pub total_memory_bytes: u64,
    /// Total in-flight requests across all active instances
    pub total_inflight_requests: u32,
    /// Number of unhealthy instances
    pub unhealthy_instances: u32,
}