Struct RetryAfter 

pub struct RetryAfter;

The service’s own RetryAfter: set by InboxSpec::own.

Examples

use std::time::Duration;

use chrono::{DateTime, Utc};
use ruststream_sqlx::dialect::Column;
use ruststream_sqlx::spec::{self, Payload, own};
use ruststream_sqlx::{InboxSpec, InboxTable, RetryAfter};
use sqlx::{PgConnection, Postgres};

#[derive(sqlx::FromRow)]
pub struct QuoteJob {
    id: i64,
    payload: Vec<u8>,
}

impl InboxTable for QuoteJob {
    type Id = i64;
    type Table = InboxSpec<(spec::RetryAfter<DateTime<Utc>>, Payload, own::RetryAfter)>;
    const TABLE: Self::Table = InboxSpec::new("quote_jobs", Column::new("id").generated())
        .retry_after(Column::new("retry_after").generated())
        .payload(Column::new("payload"))
        .own::<own::RetryAfter>();

    fn id(&self) -> &i64 {
        &self.id
    }
}

// The wait doubles with every delayed retry of the row, starting from the handler's delay.
impl RetryAfter<Postgres> for QuoteJob {
    async fn retry_after(
        conn: &mut PgConnection,
        id: &i64,
        delay: Duration,
    ) -> Result<(), sqlx::Error> {
        sqlx::query(
            "UPDATE quote_jobs SET delays = delays + 1, \
             retry_after = now() + make_interval(secs => $2 * power(2, delays)) WHERE id = $1",
        )
        .bind(id)
        .bind(delay.as_secs_f64())
        .execute(conn)
        .await?;
        Ok(())
    }
}

Trait Implementations

impl Debug for RetryAfter

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

Formats the value using the given formatter.

impl Declaration for RetryAfter

type Form = Unset

The form: Lease or Advisory; unset for the row lock form.

type Message = Unset

The message mode: Payload; unset for row mode.

type Key = Unset

The partition key: Key.

type Attempt = Unset

The attempt count: Attempt.

type Headers = Unset

The delivery’s headers: Headers or HeaderFields.

type RetryAfter = Unset

The time a retried row is due: RetryAfter.

type ProcessedAt = Unset

The time a row was processed: ProcessedAt.

type Clock = Unset

The clock: Clock; unset for SystemClock.

type Opening = Unset

What the table’s transactions open at: Opens; unset for the database’s default.

type Fifo = Unset

Groups kept in order: Fifo.

type OwnClaim = Unset

The service’s own claim: own::Claim.

type OwnFetch = Unset

The service’s own fetch: own::Fetch.

type OwnAck = Unset

The service’s own ack: own::Ack.

type OwnRetry = Unset

The service’s own retry: own::Retry.

type OwnRetryAfter = Set<RetryAfter>

The service’s own delayed retry: own::RetryAfter.

type OwnDiscard = Unset

The service’s own discard: own::Discard.

type OwnDeadLetter = Unset

The service’s own dead letter: own::DeadLetter.

type OwnExtend = Unset

The service’s own lease extension: own::Extend.

type OwnLock = Unset

The service’s own lock: own::Lock.

type OwnUnlock = Unset

The service’s own unlock: own::Unlock.

impl OwnEvent for RetryAfter