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,
    pub processing_latency_p99_micros: Option<u64>,
}

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.

processing_latency_p99_micros: Option<u64>

99th percentile processing latency (from ingesting a batch to finishing processing it) in microseconds.

The time from ingesting a batch of records off the wire to the circuit finishing processing them, covering parsing, queuing, and the circuit step.

Does not account for completion latency.

Taken over the endpoint’s sliding histogram, which holds the 10,000 most recent samples spanning at most 10 minutes, whichever bound is reached first. One sample is recorded per completed batch. An endpoint that stops ingesting keeps reporting its last known latency instead of dropping to None.

None until the endpoint records its first sample.

Trait Implementations

impl Debug for ExternalInputEndpointMetrics

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

Formats the value using the given formatter.

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.