pub struct PipelineBuilder { /* private fields */ }Expand description
Fluent builder for Pipeline.
Implementations§
Source§impl PipelineBuilder
impl PipelineBuilder
Sourcepub fn add_stage(self, name: &str, kind: StageKind) -> Self
pub fn add_stage(self, name: &str, kind: StageKind) -> Self
Append a new stage with the given name and kind.
Sourcepub fn configure_stage(self, name: &str, key: &str, value: &str) -> Self
pub fn configure_stage(self, name: &str, key: &str, value: &str) -> Self
Set a configuration key/value pair on the most-recently added stage
named name. Does nothing if no stage with that name exists yet.
Sourcepub fn disable_stage(self, name: &str) -> Self
pub fn disable_stage(self, name: &str) -> Self
Disable the stage named name. Does nothing if no such stage exists.
Sourcepub fn fail_fast(self, v: bool) -> Self
pub fn fail_fast(self, v: bool) -> Self
Set whether the pipeline should abort on the first stage error.
Sourcepub fn build(self) -> Result<Pipeline, PipelineError>
pub fn build(self) -> Result<Pipeline, PipelineError>
Consume the builder and produce a Pipeline.
Returns PipelineError::EmptyPipeline if no stages were added.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for PipelineBuilder
impl RefUnwindSafe for PipelineBuilder
impl Send for PipelineBuilder
impl Sync for PipelineBuilder
impl Unpin for PipelineBuilder
impl UnsafeUnpin for PipelineBuilder
impl UnwindSafe for PipelineBuilder
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