Module dyer::plugin::pipeline

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