risingwave_pb::connector_service

Type Alias PbGetEventStreamResponse

Source 
pub type PbGetEventStreamResponse = GetEventStreamResponse;

Aliased Type§

struct PbGetEventStreamResponse {
    pub source_id: u64,
    pub events: Vec<CdcMessage>,
    pub control: Option<ControlInfo>,
}

Fields§

§source_id: u64§events: Vec<CdcMessage>§control: Option<ControlInfo>