Struct SqliteSubscription 

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

Fields

start: StartFrom<SqliteCursor>

stop_at: StopAt<SqliteCursor>

filter: EventFilter

partitions: PartitionSelection

batch_size: Option<usize>

limit: Option<usize>

Implementations

impl SqliteSubscription

pub 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 IN (?, ?, ...) instead of one query per partition.

Trait Implementations

impl Clone for SqliteSubscription

fn clone(&self) -> SqliteSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteSubscription

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

Formats the value using the given formatter.

impl Default for SqliteSubscription

fn default() -> Self

Returns the “default value” for a type.

impl PartitionableSubscription<SqliteCursor> for SqliteSubscription

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

impl StartableSubscription<SqliteCursor> for SqliteSubscription

fn with_start(self, start: StartFrom<SqliteCursor>) -> 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.