Struct BasicTransform 

pub struct BasicTransform<M: MapOne> {
    pub inner: M,
    pub on_error: ErrorPolicy,
    /* private fields */
}

Adapter that turns any MapOne into a Transform.

Fields

inner: M

on_error: ErrorPolicy

Implementations

impl<M: MapOne> BasicTransform<M>

pub fn new(inner: M) -> Self

pub fn with_error_policy(self, policy: ErrorPolicy) -> Self

Trait Implementations

impl<M: MapOne + 'static> Transform for BasicTransform<M>

fn id(&self) -> &str

fn set_node_ctx(&mut self, ctx: NodeCtx)

Attach the per-node observability context. Called by spawn_pipeline after the transform is built but before it runs. Default no-op — full-control transforms that want metrics override this and store the ctx; BasicTransform already does so for the common path.

fn run<'async_trait>( self: Box<Self>, rx: Receiver<Envelope>, tx: Sender<Envelope>, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,