Struct PipelineStage 

pub struct PipelineStage {
    pub label: String,
    pub handler: Arc<dyn Fn(Value) -> Result<Value, String> + Send + Sync>,
}

A single pipeline stage with its handler.

Fields

label: String

Human-readable label for this stage.

handler: Arc<dyn Fn(Value) -> Result<Value, String> + Send + Sync>

Handler function: takes item JSON, returns processed JSON or error. This is the bridge between the Rust pipeline framework and the Lua SDK.

Implementations

impl PipelineStage

pub fn new<F>(label: &str, handler: F) -> Self

where F: Fn(Value) -> Result<Value, String> + Send + Sync + 'static,

Trait Implementations

impl Clone for PipelineStage

fn clone(&self) -> PipelineStage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineStage

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

Formats the value using the given formatter.