Struct quilkin::filters::concatenate::Concatenate

pub struct Concatenate { /* private fields */ }

The Concatenate filter’s job is to add a byte packet to either the beginning or end of each UDP packet that passes through. This is commonly used to provide an auth token to each packet, so they can be routed appropriately.

Implementations

impl Concatenate

pub fn new(config: Config) -> Self

Trait Implementations

impl Filter for Concatenate

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 Concatenate

const NAME: &'static str = "quilkin.filters.concatenate.v1alpha1.Concatenate"

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

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>

fn as_labeled_filter_config( config: impl Into<Option<Self::Configuration>>, label: String ) -> Result<Filter, CreationError>