Struct ExternalControllerStatus 

pub struct ExternalControllerStatus {
    pub global_metrics: ExternalGlobalControllerMetrics,
    pub suspend_error: Option<SuspendError>,
    pub checkpoint_activity: Option<CheckpointActivity>,
    pub permanent_checkpoint_errors: Option<Vec<PermanentSuspendError>>,
    pub inputs: Vec<ExternalInputEndpointStatus>,
    pub outputs: Vec<ExternalOutputEndpointStatus>,
}

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.

Fields

global_metrics: ExternalGlobalControllerMetrics

Global controller metrics.

suspend_error: Option<SuspendError>

Reason why the pipeline cannot be suspended or checkpointed (if any).

checkpoint_activity: Option<CheckpointActivity>

Current checkpoint activity (idle, delayed, or in-progress). None when the pipeline binary predates checkpoint activity tracking.

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.

inputs: Vec<ExternalInputEndpointStatus>

Input endpoint configs and metrics.

outputs: Vec<ExternalOutputEndpointStatus>

Output endpoint configs and metrics.

Trait Implementations

impl Debug for ExternalControllerStatus

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

Formats the value using the given formatter.

impl Default for ExternalControllerStatus

fn default() -> ExternalControllerStatus

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExternalControllerStatus

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExternalControllerStatus

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for ExternalControllerStatus

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.