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: Direction)

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<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut ReadContext ) -> Pin<Box<dyn Future<Output = Result<(), FilterError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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

fn write<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut WriteContext ) -> Pin<Box<dyn Future<Output = Result<(), FilterError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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, CreationError>

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() -> DynFilterFactory

where Self: 'static,

Creates a new dynamic FilterFactory virtual table.

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

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, CreationError>

impl TryFrom<Config> for Timestamp

type Error = CreationError

The type returned in the event of a conversion error.

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

Performs the conversion.