pub struct ProcessingStep {
pub matcher: Arc<dyn Matcher>,
pub mailet: Arc<dyn Mailet>,
pub config: MailetConfig,
}Expand description
Matcher-Mailet pair with optional per-step configuration
Fields§
§matcher: Arc<dyn Matcher>§mailet: Arc<dyn Mailet>§config: MailetConfigPer-step mailet configuration (timeout, error policy)
Implementations§
Source§impl ProcessingStep
impl ProcessingStep
Sourcepub fn new(matcher: Arc<dyn Matcher>, mailet: Arc<dyn Mailet>) -> Self
pub fn new(matcher: Arc<dyn Matcher>, mailet: Arc<dyn Mailet>) -> Self
Create a new processing step with a default config derived from the mailet name
Sourcepub fn new_with_config(
matcher: Arc<dyn Matcher>,
mailet: Arc<dyn Mailet>,
config: MailetConfig,
) -> Self
pub fn new_with_config( matcher: Arc<dyn Matcher>, mailet: Arc<dyn Mailet>, config: MailetConfig, ) -> Self
Create a new processing step with an explicit configuration
Auto Trait Implementations§
impl Freeze for ProcessingStep
impl !RefUnwindSafe for ProcessingStep
impl Send for ProcessingStep
impl Sync for ProcessingStep
impl Unpin for ProcessingStep
impl UnsafeUnpin for ProcessingStep
impl !UnwindSafe for ProcessingStep
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
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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