Struct ControllerStatus 

pub struct ControllerStatus {
    pub checkpoint_activity: Option<CheckpointActivity>,
    pub global_metrics: GlobalControllerMetrics,
    pub inputs: Vec<InputEndpointStatus>,
    pub outputs: Vec<OutputEndpointStatus>,
    pub permanent_checkpoint_errors: Option<Vec<PermanentSuspendError>>,
    pub suspend_error: Option<SuspendError>,
}

Complete pipeline statistics returned by the /stats endpoint.

This schema definition matches the serialized JSON structure from adapters::controller::ControllerStatus. The actual implementation with atomics and mutexes lives in the adapters crate, which uses ExternalControllerStatus to register this OpenAPI schema, making it available to pipeline-manager without requiring a direct dependency on the adapters crate.

JSON schema

{
 "description": "Complete pipeline statistics returned by the `/stats` endpoint.\n\nThis schema definition matches the serialized JSON structure from\n`adapters::controller::ControllerStatus`. The actual implementation with\natomics and mutexes lives in the adapters crate, which uses ExternalControllerStatus to\nregister this OpenAPI schema, making it available to pipeline-manager\nwithout requiring a direct dependency on the adapters crate.",
 "type": "object",
 "required": [
   "global_metrics",
   "inputs",
   "outputs"
 ],
 "properties": {
   "checkpoint_activity": {
     "allOf": [
       {
         "$ref": "#/components/schemas/CheckpointActivity"
       }
     ]
   },
   "global_metrics": {
     "$ref": "#/components/schemas/GlobalControllerMetrics"
   },
   "inputs": {
     "description": "Input endpoint configs and metrics.",
     "type": "array",
     "items": {
       "$ref": "#/components/schemas/InputEndpointStatus"
     }
   },
   "outputs": {
     "description": "Output endpoint configs and metrics.",
     "type": "array",
     "items": {
       "$ref": "#/components/schemas/OutputEndpointStatus"
     }
   },
   "permanent_checkpoint_errors": {
     "description": "If the pipeline fundamentally cannot checkpoint (e.g. storage is not\nconfigured, or an input endpoint does not support suspend), the reasons\nare listed here.  Unlike a checkpoint failure, this means *no*\ncheckpoint can succeed until the pipeline configuration changes.",
     "type": [
       "array",
       "null"
     ],
     "items": {
       "$ref": "#/components/schemas/PermanentSuspendError"
     }
   },
   "suspend_error": {
     "allOf": [
       {
         "$ref": "#/components/schemas/SuspendError"
       }
     ]
   }
 }
}

Fields

checkpoint_activity: Option<CheckpointActivity>

global_metrics: GlobalControllerMetrics

inputs: Vec<InputEndpointStatus>

Input endpoint configs and metrics.

outputs: Vec<OutputEndpointStatus>

Output endpoint configs and metrics.

permanent_checkpoint_errors: Option<Vec<PermanentSuspendError>>

If the pipeline fundamentally cannot checkpoint (e.g. storage is not configured, or an input endpoint does not support suspend), the reasons are listed here. Unlike a checkpoint failure, this means no checkpoint can succeed until the pipeline configuration changes.

suspend_error: Option<SuspendError>

Implementations

impl ControllerStatus

pub fn builder() -> ControllerStatus

Trait Implementations

impl Clone for ControllerStatus

fn clone(&self) -> ControllerStatus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ControllerStatus

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ControllerStatus

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&ControllerStatus> for ControllerStatus

fn from(value: &ControllerStatus) -> Self

Converts to this type from the input type.

impl From<ControllerStatus> for ControllerStatus

fn from(value: ControllerStatus) -> Self

Converts to this type from the input type.

impl Serialize for ControllerStatus

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<ControllerStatus> for ControllerStatus

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: ControllerStatus) -> Result<Self, ConversionError>

Performs the conversion.