Struct SubscribeCommittedOptions 

pub struct SubscribeCommittedOptions<'a> {
    pub from_offset: u64,
    pub cf: Option<u32>,
    pub key_prefix: Vec<u8>,
    pub include_values: bool,
    pub subscription_id: Option<String>,
    pub checkpoint: Option<&'a dyn CheckpointStore>,
    pub auto_commit: bool,
    pub shard_id: u64,
}

Configuration for crate::StateletClient::subscribe_committed.

cf uses Option<u32> so that None means “the client’s default CF” while Some(0) selects CF 0 (matching the Python keyword default of cf=None).

Fields

from_offset: u64

First Raft offset to deliver when no checkpoint applies (0 = live-only).

cf: Option<u32>

key_prefix: Vec<u8>

include_values: bool

subscription_id: Option<String>

checkpoint: Option<&'a dyn CheckpointStore>

auto_commit: bool

shard_id: u64

Trait Implementations

impl<'a> Default for SubscribeCommittedOptions<'a>

fn default() -> Self

Returns the “default value” for a type.