Struct quilkin::filters::Match

pub struct Match { /* private fields */ }

Trait Implementations

impl Filter for Match

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 Match

const NAME: &'static str = "quilkin.filters.match.v1alpha1.Match"

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 = Match

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>