Struct StreamCheckpointOptions 

pub struct StreamCheckpointOptions {
    pub stream_id: String,
    pub consumer_id: String,
    pub offset: Value,
    pub watermark: Option<Value>,
    pub chunk: Option<StreamChunkRef>,
    pub partial_result_ref: Option<String>,
    pub backpressure: State,
    pub metadata: State,
}

Fields

stream_id: String

consumer_id: String

offset: Value

watermark: Option<Value>

chunk: Option<StreamChunkRef>

partial_result_ref: Option<String>

backpressure: State

metadata: State

Trait Implementations

impl Clone for StreamCheckpointOptions

fn clone(&self) -> StreamCheckpointOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamCheckpointOptions

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

Formats the value using the given formatter.

impl Default for StreamCheckpointOptions

fn default() -> StreamCheckpointOptions

Returns the “default value” for a type.