risingwave_pb::stream_service

Type Alias PbBarrierCompleteResponse

source 
pub type PbBarrierCompleteResponse = BarrierCompleteResponse;
Expand description

Alias for BarrierCompleteResponse.

Aliased Type§

struct PbBarrierCompleteResponse {
    pub request_id: String,
    pub status: Option<Status>,
    pub create_mview_progress: Vec<CreateMviewProgress>,
    pub synced_sstables: Vec<LocalSstableInfo>,
    pub worker_id: u32,
    pub table_watermarks: HashMap<u32, TableWatermarks>,
    pub old_value_sstables: Vec<SstableInfo>,
    pub partial_graph_id: u64,
    pub epoch: u64,
}

Fields§

§request_id: String§status: Option<Status>§create_mview_progress: Vec<CreateMviewProgress>§synced_sstables: Vec<LocalSstableInfo>§worker_id: u32§table_watermarks: HashMap<u32, TableWatermarks>§old_value_sstables: Vec<SstableInfo>§partial_graph_id: u64§epoch: u64

prev_epoch of barrier