Struct FailurePolicies 

#[non_exhaustive]
pub struct FailurePolicies {
    pub panic: FailurePolicy,
    pub decode: FailurePolicy,
}

The pair of failure policies a subscriber carries: one for a handler panic, one for a decode failure. Threaded from the def to the dispatch loop alongside the Workers policy.

Examples

use ruststream::memory::prelude::*;
use serde::Deserialize;

#[derive(Deserialize)]
struct Order {
    id: u64,
}

#[subscriber]
async fn ingest(order: &Order) -> HandlerOutcome {
    tracing::info!(order.id, "ingested");
    HandlerOutcome::ack()
}

fn app() -> RustStream {
    RustStream::new(AppInfo::new("ingest", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        // An untrusted topic: a malformed payload is requeued, a handler bug still stops the
        // service (the default panic policy).
        b.include(
            ingest
                .name("ingest")
                .on_failure(FailurePolicies::default().with_decode(FailurePolicy::Retry)),
        );
    })
}

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

panic: FailurePolicy

What to do when the handler panics. Defaults to FailurePolicy::FailFast.

decode: FailurePolicy

What to do when a delivery’s typed view cannot be materialized: the codec fails to decode the payload, a Headers contract fails to parse, the delivery carries no value (Carries), or the broker reports that it could not read the delivery (IncomingMessage::decode_error). One policy covers all four - each is the same class of bad external input as a payload that does not decode. Defaults to FailurePolicy::Drop.

Implementations

impl FailurePolicies

pub fn with_panic(self, policy: FailurePolicy) -> FailurePolicies

Overrides the handler-panic policy, leaving the decode policy unchanged. The builder the #[subscriber] macro uses to fill in the keys named in on_failure(..).

pub fn with_decode(self, policy: FailurePolicy) -> FailurePolicies

Overrides the decode-failure policy, leaving the panic policy unchanged.

Trait Implementations

impl Clone for FailurePolicies

fn clone(&self) -> FailurePolicies

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for FailurePolicies

impl Debug for FailurePolicies

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for FailurePolicies

fn default() -> FailurePolicies

Returns the “default value” for a type.

impl Eq for FailurePolicies

impl PartialEq for FailurePolicies

fn eq(&self, other: &FailurePolicies) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FailurePolicies