Struct ExternalInputEndpointStatus 

pub struct ExternalInputEndpointStatus {
    pub endpoint_name: String,
    pub config: InputEndpointConfig,
    pub metrics: ExternalInputEndpointMetrics,
    pub fatal_error: Option<String>,
    pub paused: bool,
    pub barrier: bool,
    pub completed_frontier: Option<ExternalCompletedWatermark>,
}

Input endpoint status information.

Fields

endpoint_name: String

Endpoint name.

config: InputEndpointConfig

Endpoint configuration.

metrics: ExternalInputEndpointMetrics

Performance metrics.

fatal_error: Option<String>

The first fatal error that occurred at the endpoint.

paused: bool

Endpoint has been paused by the user.

barrier: bool

Endpoint is currently a barrier to checkpointing and suspend.

completed_frontier: Option<ExternalCompletedWatermark>

The latest completed watermark.

Trait Implementations

impl Serialize for ExternalInputEndpointStatus

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 ExternalInputEndpointStatus

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.