Enum PostgresProjectionMode 

#[non_exhaustive]
pub enum PostgresProjectionMode {
    Batch,
    Continuous(CancellationToken),
}

Selects whether a runner stops at its initial catch-up frontier or keeps polling.

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.

Batch

Drain the committed source frontier captured at run start, then return.

Continuous(CancellationToken)

Keep polling after each catch-up frontier until cancellation.

Cancellation is observed only between completed catch-up cycles. It does not interrupt application, a retry delay, commit, or after-commit work already in progress.

Trait Implementations

impl Clone for PostgresProjectionMode

fn clone(&self) -> PostgresProjectionMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresProjectionMode

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

Formats the value using the given formatter.