Struct RealtimeConnectOptions 

pub struct RealtimeConnectOptions {
    pub since: Option<DateTime<Utc>>,
    pub since_per_partition: Option<HashMap<String, DateTime<Utc>>>,
    pub partitions: Option<Vec<u32>>,
    pub offsets: Option<HashMap<String, u64>>,
}

Realtime connection options.

Fields

since: Option<DateTime<Utc>>

Global since timestamp

since_per_partition: Option<HashMap<String, DateTime<Utc>>>

Per-partition resume (critical for reconnect without data loss)

partitions: Option<Vec<u32>>

Which partitions to connect to

offsets: Option<HashMap<String, u64>>

Per-partition offsets for resume

Implementations

impl RealtimeConnectOptions

pub fn since(timestamp: DateTime<Utc>) -> Self

Create new options with just a global since timestamp.

pub fn since_per_partition(partitions: HashMap<String, DateTime<Utc>>) -> Self

Create new options with per-partition resume.

pub fn with_partitions(self, partitions: Vec<u32>) -> Self

Set specific partitions to connect to.

pub fn with_offsets(self, offsets: HashMap<String, u64>) -> Self

Set per-partition offsets for resume.

Trait Implementations

impl Clone for RealtimeConnectOptions

fn clone(&self) -> RealtimeConnectOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RealtimeConnectOptions

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

Formats the value using the given formatter.

impl Default for RealtimeConnectOptions

fn default() -> RealtimeConnectOptions

Returns the “default value” for a type.