Enum TrackedPublishError 

#[non_exhaustive]
pub enum TrackedPublishError<PublishError> {
    Outbox(OutboxError),
    Publish(PublishError),
}

A publish through wrap that failed: the outbox did not record the message, or the publisher it wraps did not send it.

Examples

use ruststream::runtime::PublishError;
use ruststream_sqlx::outbox::{OutboxError, TrackedPublishError};

pub async fn serve(pool: PgPool) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let tracking = outbox! { pool: pool, "orders" => OrderOutbox };
    let broker = MemoryBroker::new().bindable();
    let egress = broker.bind(Publish);
    let running = RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(broker, |b| {
            b.include(fulfil);
        })
        .start()
        .await?;
    let publisher = tracking.wrap(running.publisher(egress).await?);

    // The status an HTTP endpoint answers an order with.
    let status = match publisher.message(&OrderPlaced { id: 7 }).publish().await {
        Ok(()) => 202,
        // Recorded but not sent: the next startup sends it.
        Err(PublishError::Publish(TrackedPublishError::Publish(_))) => 202,
        // Neither recorded nor sent: the client sends the order again.
        Err(PublishError::Publish(TrackedPublishError::Outbox(OutboxError::Record { .. }))) => 503,
        Err(_) => 500,
    };
    tracing::info!(status, "order answered");

    running.shutdown().await?;
    Ok(())
}

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Outbox(OutboxError)

The record was not written, so the message was not sent.

Publish(PublishError)

The wrapped publisher’s error. The record stays unprocessed, and the next startup publishes it again.

Trait Implementations

impl<PublishError: Debug> Debug for TrackedPublishError<PublishError>

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

Formats the value using the given formatter.

impl<PublishError> Display for TrackedPublishError<PublishError>

where PublishError: Display,

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

Formats the value using the given formatter.

impl<PublishError> Error for TrackedPublishError<PublishError>

where PublishError: Error, Self: Debug + Display,

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.