Struct ExternalInputEndpointMetrics 

pub struct ExternalInputEndpointMetrics {
    pub total_bytes: u64,
    pub total_records: u64,
    pub buffered_records: u64,
    pub buffered_bytes: u64,
    pub num_transport_errors: u64,
    pub num_parse_errors: u64,
    pub end_of_input: bool,
}

Performance metrics for an input endpoint.

Fields

total_bytes: u64

Total bytes pushed to the endpoint since it was created.

total_records: u64

Total records pushed to the endpoint since it was created.

buffered_records: u64

Number of records currently buffered by the endpoint (not yet consumed by the circuit).

buffered_bytes: u64

Number of bytes currently buffered by the endpoint (not yet consumed by the circuit).

num_transport_errors: u64

Number of transport errors.

num_parse_errors: u64

Number of parse errors.

end_of_input: bool

True if end-of-input has been signaled.

Trait Implementations

impl Default for ExternalInputEndpointMetrics

fn default() -> ExternalInputEndpointMetrics

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExternalInputEndpointMetrics

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExternalInputEndpointMetrics

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 ExternalInputEndpointMetrics

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.