Struct InputEndpointMetrics 

pub struct InputEndpointMetrics {
    pub buffered_bytes: i64,
    pub buffered_records: i64,
    pub end_of_input: bool,
    pub num_parse_errors: i64,
    pub num_transport_errors: i64,
    pub total_bytes: i64,
    pub total_records: i64,
}

Performance metrics for an input endpoint.

JSON schema

{
 "description": "Performance metrics for an input endpoint.",
 "type": "object",
 "required": [
   "buffered_bytes",
   "buffered_records",
   "end_of_input",
   "num_parse_errors",
   "num_transport_errors",
   "total_bytes",
   "total_records"
 ],
 "properties": {
   "buffered_bytes": {
     "description": "Number of bytes currently buffered by the endpoint (not yet consumed by the circuit).",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "buffered_records": {
     "description": "Number of records currently buffered by the endpoint (not yet consumed by the circuit).",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "end_of_input": {
     "description": "True if end-of-input has been signaled.",
     "type": "boolean"
   },
   "num_parse_errors": {
     "description": "Number of parse errors.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "num_transport_errors": {
     "description": "Number of transport errors.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_bytes": {
     "description": "Total bytes pushed to the endpoint since it was created.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_records": {
     "description": "Total records pushed to the endpoint since it was created.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   }
 }
}

Fields

buffered_bytes: i64

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

buffered_records: i64

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

end_of_input: bool

True if end-of-input has been signaled.

num_parse_errors: i64

Number of parse errors.

num_transport_errors: i64

Number of transport errors.

total_bytes: i64

Total bytes pushed to the endpoint since it was created.

total_records: i64

Total records pushed to the endpoint since it was created.

Implementations

impl InputEndpointMetrics

pub fn builder() -> InputEndpointMetrics

Trait Implementations

impl Clone for InputEndpointMetrics

fn clone(&self) -> InputEndpointMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InputEndpointMetrics

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InputEndpointMetrics

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&InputEndpointMetrics> for InputEndpointMetrics

fn from(value: &InputEndpointMetrics) -> Self

Converts to this type from the input type.

impl From<InputEndpointMetrics> for InputEndpointMetrics

fn from(value: InputEndpointMetrics) -> Self

Converts to this type from the input type.

impl Serialize for InputEndpointMetrics

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<InputEndpointMetrics> for InputEndpointMetrics

type Error = ConversionError

The type returned in the event of a conversion error.

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

Performs the conversion.