risingwave_pb::connector_service

Type Alias PbGetEventStreamRequest

source 
pub type PbGetEventStreamRequest = GetEventStreamRequest;
Expand description

Alias for GetEventStreamRequest.

Aliased Type§

struct PbGetEventStreamRequest {
    pub source_id: u64,
    pub source_type: i32,
    pub start_offset: String,
    pub properties: BTreeMap<String, String>,
    pub snapshot_done: bool,
    pub is_source_job: bool,
}

Fields§

§source_id: u64§source_type: i32§start_offset: String§properties: BTreeMap<String, String>§snapshot_done: bool§is_source_job: bool