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<()>