Enum tempest::topology::TopologyFailurePolicy

pub enum TopologyFailurePolicy {
    None,
    BestEffort,
    Retry(usize),
}

Enum for configuring how to process message failures.

Variants

None

Messages with Errors/Timeouts are left unacked. This is used when the message Source has it's own mechanism for dealing with Failures. For example, SQS automatically re-delivers unacked messages after a period of time. This should also be used when the Tempest source client implements it's own way of dealing with failure.

BestEffort

Messages are automatically acked, regardless of msg state (success, error, timeout)

Retry(usize)

Messages are held within the Topology and retried up to this limit The retry interval is automatically every 60s.

Trait Implementations

impl Default for TopologyFailurePolicy

fn default() -> Self

Returns the "default value" for a type.

impl Clone for TopologyFailurePolicy

fn clone(&self) -> TopologyFailurePolicy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl PartialEq<TopologyFailurePolicy> for TopologyFailurePolicy

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl Debug for TopologyFailurePolicy

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.