risingwave_rpc_client

Type Alias SinkCoordinatorStreamHandle

Source 
pub type SinkCoordinatorStreamHandle = BidiStreamHandle<SinkCoordinatorStreamRequest, SinkCoordinatorStreamResponse>;

Aliased Type§

struct SinkCoordinatorStreamHandle {
    pub request_sender: BidiStreamSender<SinkCoordinatorStreamRequest>,
    pub response_stream: BidiStreamReceiver<SinkCoordinatorStreamResponse>,
}

Fields§

§request_sender: BidiStreamSender<SinkCoordinatorStreamRequest>§response_stream: BidiStreamReceiver<SinkCoordinatorStreamResponse>

Implementations§

Source§

impl SinkCoordinatorStreamHandle

Source

pub async fn commit( &mut self, epoch: u64, metadata: Vec<SinkMetadata>, ) -> Result<()>