Enum tempest::topology::TopologyFailurePolicy

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

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 every 60s.

Trait Implementations

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 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 Debug for TopologyFailurePolicy

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

Formats the value using the given formatter.