Module pipeline

Source
Expand description

the end of data flow, plugin that consume the extracted Entity, In general, the default method does nothing, and customization is requird to store the data. An example:

pub struct E;
pub struct C;

// to initialize a `PipeLine`
let pipeline = PipeLine::<E,C>::builder()
    .initializer(&pl_close)
    .disposer(&pl_close)
    .entity(&pl_item)
    .yerr(&pl_yerr)
    .build("pipeline_id_here".into());
// pipeline is created with default `rank` 0
// if you want it has higher privilege to be executed
// increase it
assert_eq!(pipeline.rank(), 0);

Structsยง

PipeLine
Represents a medium that manipulates the collected data structure of App
PipeLineBuilder
Serve as an medium to create an instance of PipeLine