Struct PgSubscription 

pub struct PgSubscription {
    pub start: StartFrom<PgCursor>,
    pub stop_at: StopAt<PgCursor>,
    pub filter: EventFilter,
    pub batch_size: Option<usize>,
    pub limit: Option<usize>,
    pub partitions: PartitionSelection,
}

Fields

start: StartFrom<PgCursor>

stop_at: StopAt<PgCursor>

filter: EventFilter

batch_size: Option<usize>

limit: Option<usize>

partitions: PartitionSelection

Trait Implementations

impl Clone for PgSubscription

fn clone(&self) -> PgSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PgSubscription

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

Formats the value using the given formatter.

impl Default for PgSubscription

fn default() -> Self

Returns the “default value” for a type.

impl PartitionableSubscription<PgCursor> for PgSubscription

fn with_partitions(self, group: PartitionGroup) -> Self

Restrict this subscription to a validated group of partitions sharing the same partition_count. The reader emits a single SQL query per poll using partition_id = ANY($::bigint[]) instead of one query per partition. Single-partition uses fall through the default trait impl which wraps in a singleton group; partition_id = ANY(ARRAY[$1]) plans identically to partition_id = $1 on modern Postgres.

fn with_partition(self, partition: Partition) -> Self

where Self: Sized,

Restrict the subscription to a single partition. The default impl wraps the partition in a singleton PartitionGroup and delegates to PartitionableSubscription::with_partitions. Backends override only when a single-partition path is materially cheaper than the multi-partition path (rare).

impl StartableSubscription<PgCursor> for PgSubscription

fn with_start(self, start: StartFrom<PgCursor>) -> Self

fn with_starts(self, starts: Vec<StartFrom<C>>) -> Self

where C: Ord,

Seed this subscription with a collection of candidate start positions. Default behavior: pick the smallest StartFrom::After(c) from the vec and delegate to with_start. Other variants (Earliest, Latest, Timestamp) are ignored by the default impl — readers that support fan-in, dual historic+live consumption, or topology-aware resume must override.