Struct TransformPipeline 

pub struct TransformPipeline { /* private fields */ }

Implementations

impl TransformPipeline

pub fn add_transform(&mut self, transform: Box<dyn Transform>)

Add a transform to the end of the pipeline (mutating form).

pub fn with<T: Transform + 'static>(self, transform: T) -> Self

Add a transform to the end of the pipeline (fluent builder form).

let pipeline = TransformPipeline::default()
    .with(MaskHashTransform::new(config))
    .with(RouteTransform::new(route_config).unwrap());

pub fn len(&self) -> usize

Number of transforms in the pipeline.

pub fn is_empty(&self) -> bool

Returns true when the pipeline contains no transforms.

pub async fn apply(&self, event: Event) -> Result<Option<Event>>

Trait Implementations

impl Debug for TransformPipeline

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

Formats the value using the given formatter.

impl Default for TransformPipeline

fn default() -> TransformPipeline

Returns the “default value” for a type.