Struct quilkin::filters::Timestamp

pub struct Timestamp { /* private fields */ }

A filter that reads a metadata value as a timestamp to be observed in a histogram.

Implementations

impl Timestamp

pub fn observe(&self, metadata: &DynamicMetadata, direction_label: &'static str)

Observes the duration since a timestamp stored in metadata and now, if present.

Trait Implementations

impl Clone for Timestamp

fn clone(&self) -> Timestamp

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Timestamp

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

Formats the value using the given formatter.

impl Filter for Timestamp

fn read(&self, ctx: &mut ReadContext) -> Option<()>

Filter::read is invoked when the proxy receives data from a downstream connection on the listening port.

fn write(&self, ctx: &mut WriteContext) -> Option<()>

Filter::write is invoked when the proxy is about to send data to a downstream connection via the listening port after receiving it via one of the upstream Endpoints.

impl StaticFilter for Timestamp

const NAME: &'static str = "quilkin.filters.timestamp.v1alpha1.Timestamp"

The globally unique name of the filter.

type Configuration = Config

The human-readable configuration of the filter. Must be serde compatible, have a JSON schema, and be convertible to and from Self::BinaryConfiguration.

type BinaryConfiguration = Timestamp

The binary configuration of the filter. Must be prost compatible, and be convertible to and from Self::Configuration.

fn try_from_config(config: Option<Self::Configuration>) -> Result<Self, Error>

Instantiates a new StaticFilter from the given configuration, if any.

fn from_config(config: Option<Self::Configuration>) -> Self

Instantiates a new StaticFilter from the given configuration, if any.

fn factory() -> DynFilterFactorywhere
    Self: 'static,

Creates a new dynamic FilterFactory virtual table.

fn ensure_config_exists(
    config: Option<Self::Configuration>
) -> Result<Self::Configuration, Error>

Convenience method for providing a consistent error message for filters which require a fully initialized Self::Configuration.

fn as_filter_config(
    config: impl Into<Option<Self::Configuration>>
) -> Result<Filter, Error>

impl TryFrom<Config> for Timestamp

type Error = Error

The type returned in the event of a conversion error.

fn try_from(config: Config) -> Result<Self, Self::Error>

Performs the conversion.