Struct OperationRetries 

pub struct OperationRetries { /* private fields */ }

How long the client keeps asking for an operation a server has not accepted yet.

The client retries an answer that says “not now” - a broker that is still coming up, a producer or a consumer the topic already has - rather than reporting it, and by default it retries for ever, five seconds apart. That is what waits out a broker restart, and it is also what makes a subscription a server refuses (an Exclusive one another consumer holds) a call that never returns. attempts puts a number on it.

The bound covers every retried operation of the connection, the consumer’s own reconnect included, so a service that shortens it trades waiting out an outage for hearing about it.

Examples

use std::time::Duration;

use ruststream_pulsar::prelude::*;

#[ruststream::app]
fn app() -> impl App {
    // Three tries a second apart, then startup reports what the server said instead of
    // waiting for the holder of the exclusive subscription to leave.
    let retries = OperationRetries::attempts(nonzero!(3u32)).delay(Duration::from_secs(1));
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        PulsarBroker::new("pulsar://localhost:6650").operation_retries(retries),
        |b| {
            b.include(handle);
        },
    )
}

Implementations

impl OperationRetries

pub const fn unbounded() -> Self

Keeps asking for ever, which is the client’s own behaviour.

pub const fn attempts(attempts: NonZeroU32) -> Self

Gives up after attempts tries and reports what the server answered.

One attempt means the first answer is the final one.

pub const fn delay(self, delay: Duration) -> Self

Waits delay between tries. Defaults to five seconds.

pub const fn timeout(self, timeout: Duration) -> Self

Gives one try timeout to be answered at all. Defaults to thirty seconds.

Trait Implementations

impl Clone for OperationRetries

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperationRetries

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

Formats the value using the given formatter.

impl Default for OperationRetries

fn default() -> Self

Returns the “default value” for a type.

impl Eq for OperationRetries

impl From<OperationRetries> for OperationRetryOptions

fn from(retries: OperationRetries) -> Self

The client counts the retries that follow the first try, so a bound of n tries is n - 1 retries.

impl PartialEq for OperationRetries

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for OperationRetries