Enum HistogramName 

pub enum HistogramName {
    ComponentReceivedEventsCount,
    ComponentReceivedBytes,
    BufferSendDurationSeconds,
    ComponentLatencySeconds,
    SourceLagTimeSeconds,
    SourceSendLatencySeconds,
    SourceSendBatchLatencySeconds,
    AdaptiveConcurrencyAveragedRtt,
    AdaptiveConcurrencyBackPressure,
    AdaptiveConcurrencyInFlight,
    AdaptiveConcurrencyLimit,
    AdaptiveConcurrencyObservedRtt,
    AdaptiveConcurrencyPastRttMean,
    AdaptiveConcurrencyReachedLimit,
    S3ObjectProcessingSucceededDurationSeconds,
    S3ObjectProcessingFailedDurationSeconds,
    CollectDurationSeconds,
    CommandExecutionDurationSeconds,
    GrpcServerHandlerDurationSeconds,
    HttpServerHandlerDurationSeconds,
    HttpClientRttSeconds,
    HttpClientResponseRttSeconds,
    HttpClientErrorRttSeconds,
    SourceBufferUtilization,
    TransformBufferUtilization,
}

Canonical list of all per-component internal histogram metric names emitted by Vector.

Variants

ComponentReceivedEventsCount

A histogram of the number of events passed in each internal batch in Vector’s internal topology.

Note that this is separate than sink-level batching. It is mostly useful for low level debugging performance issues in Vector due to small internal batches.

ComponentReceivedBytes

The size in bytes of each event received by the source.

BufferSendDurationSeconds

The duration spent sending a payload to this buffer.

ComponentLatencySeconds

The elapsed time, in fractional seconds, that an event spends in a single transform.

This includes both the time spent queued in the transform’s input buffer and the time spent executing the transform itself.

SourceLagTimeSeconds

The difference between the timestamp recorded in each event and the time when it was ingested, expressed as fractional seconds.

SourceSendLatencySeconds

The time elapsed blocking on the downstream channel to accept a single chunk from a batch of events received at the source.

SourceSendBatchLatencySeconds

The time elapsed blocking on the downstream channel to accept an entire batch of events received at the source.

AdaptiveConcurrencyAveragedRtt

The average round-trip time (RTT) for the current window.

AdaptiveConcurrencyBackPressure

A boolean sample (1.0 if back pressure was observed during the current window, 0.0 otherwise).

AdaptiveConcurrencyInFlight

The number of outbound requests currently awaiting a response.

AdaptiveConcurrencyLimit

The concurrency limit that the adaptive concurrency feature has decided on for this current window.

AdaptiveConcurrencyObservedRtt

The observed round-trip time (RTT) for requests.

AdaptiveConcurrencyPastRttMean

The mean round-trip time (RTT) from past windows, used as the baseline for adaptive concurrency decisions.

AdaptiveConcurrencyReachedLimit

A boolean sample (1.0 if the concurrency limit was reached during the most recent limit update, 0.0 otherwise).

S3ObjectProcessingSucceededDurationSeconds

The time taken to process an S3 object that succeeded, in seconds.

S3ObjectProcessingFailedDurationSeconds

The time taken to process an S3 object that failed, in seconds.

CollectDurationSeconds

The duration spent collecting metrics for this component.

CommandExecutionDurationSeconds

The command execution duration in seconds.

GrpcServerHandlerDurationSeconds

The duration spent handling a gRPC request.

HttpServerHandlerDurationSeconds

The duration spent handling an HTTP request.

HttpClientRttSeconds

The round-trip time (RTT) of HTTP requests.

HttpClientResponseRttSeconds

The round-trip time (RTT) of HTTP requests, tagged with the response code.

HttpClientErrorRttSeconds

The round-trip time (RTT) of HTTP requests that resulted in an error.

SourceBufferUtilization

The utilization level of the source buffer. The outputs of the source send data to this buffer.

TransformBufferUtilization

The utilization level of the buffer that feeds into a transform.

Implementations

impl HistogramName

pub const fn as_str(self) -> &'static str

Trait Implementations

impl AsRef<str> for HistogramName

fn as_ref(&self) -> &str

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for HistogramName

fn clone(&self) -> HistogramName

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Configurable for HistogramName

fn referenceable_name() -> Option<&'static str>

Gets the referenceable name of this value, if any.

fn metadata() -> Metadata

Gets the metadata for this value.

fn generate_schema( schema_gen: &RefCell<SchemaGenerator>, ) -> Result<SchemaObject, GenerateError>

Generates the schema for this value.

fn is_optional() -> bool

where Self: Sized,

Whether or not this value is optional.

fn validate_metadata(_metadata: &Metadata) -> Result<(), GenerateError>

where Self: Sized,

Validates the given metadata against this type.

fn as_configurable_ref() -> ConfigurableRef

where Self: Sized + 'static,

Create a new configurable reference table.

impl Debug for HistogramName

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HistogramName

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for HistogramName

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

Formats the value using the given formatter.

impl Hash for HistogramName

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl IntoEnumIterator for HistogramName

type Iterator = HistogramNameIter

fn iter() -> HistogramNameIter

impl PartialEq for HistogramName

fn eq(&self, other: &HistogramName) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for HistogramName

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToValue for HistogramName

fn to_value(&self) -> Value

Convert this value into a serde_json::Value. Must not fail.

impl Copy for HistogramName

impl Eq for HistogramName

impl StructuralPartialEq for HistogramName