Struct Discard 

pub struct Discard;

The mark of a dropped record: outbox::Discard.

Examples

use ruststream_sqlx::dialect::Column;
use ruststream_sqlx::outbox::spec::own;
use ruststream_sqlx::outbox::{self, OutboxSpec, OutboxTable};
use sqlx::{PgConnection, PgPool, Postgres};

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

impl OutboxTable for OrderEvent {
    type Id = i64;
    type Table = OutboxSpec<(own::Discard,)>;
    const TABLE: Self::Table = OutboxSpec::new(
        "outbox",
        Column::new("id"),
        Column::new("name"),
        Column::new("payload"),
    )
    .own::<own::Discard>();
}

// A dropped record moves to a table the operators review.
impl outbox::Discard<Postgres> for OrderEvent {
    async fn discard(conn: &mut PgConnection, id: &i64) -> sqlx::Result<()> {
        sqlx::query(
            "WITH dropped AS (DELETE FROM outbox WHERE id = $1 RETURNING *) \
             INSERT INTO outbox_dropped SELECT * FROM dropped",
        )
        .bind(id)
        .execute(conn)
        .await?;
        Ok(())
    }
}

Trait Implementations

impl Debug for Discard

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

Formats the value using the given formatter.

impl Declaration for Discard

type Headers = Unset

The headers column: Headers.

type ProcessedAt = Unset

The time a record was processed: ProcessedAt.

type OwnFetch = Unset

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

type OwnAck = Unset

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

type OwnRetry = Unset

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

type OwnDiscard = Set<Discard>

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

type OwnRecover = Unset

The record’s own recovery: own::Recover.

impl OwnEvent for Discard