pub struct Pipeline {
pub config: PipelineConfig,
}Expand description
A constructed, immutable processing pipeline.
Fields§
§config: PipelineConfigThe resolved configuration.
Implementations§
Source§impl Pipeline
impl Pipeline
Sourcepub fn run(&self, input: &str) -> Result<Vec<StageResult>, PipelineError>
pub fn run(&self, input: &str) -> Result<Vec<StageResult>, PipelineError>
Run the pipeline on input, returning ordered results for each enabled stage.
Stage semantics:
- Preprocess: trim whitespace; if
config["lowercase"] == "true", convert to lowercase. - Validate: return a
PipelineError::StageErrorif the current text is empty. - Enrich: prepend
config["prefix"](if set). - Transform: truncate to
config["max_len"]characters (if set and parseable). - Postprocess: append
config["suffix"](if set).
Auto Trait Implementations§
impl Freeze for Pipeline
impl RefUnwindSafe for Pipeline
impl Send for Pipeline
impl Sync for Pipeline
impl Unpin for Pipeline
impl UnsafeUnpin for Pipeline
impl UnwindSafe for Pipeline
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request