risingwave_rpc_client

Type Alias SinkWriterStreamHandle

Source 
pub type SinkWriterStreamHandle<REQ = SinkWriterStreamRequest> = BidiStreamHandle<REQ, SinkWriterStreamResponse>;

Aliased Type§

struct SinkWriterStreamHandle<REQ = SinkWriterStreamRequest> {
    pub request_sender: BidiStreamSender<REQ>,
    pub response_stream: BidiStreamReceiver<SinkWriterStreamResponse>,
}

Fields§

§request_sender: BidiStreamSender<REQ>§response_stream: BidiStreamReceiver<SinkWriterStreamResponse>

Implementations§

Source§

impl<REQ: From<SinkWriterStreamRequest>> SinkWriterStreamHandle<REQ>

Source

pub async fn write_batch( &mut self, epoch: u64, batch_id: u64, payload: Payload, ) -> Result<()>

Source

pub async fn barrier(&mut self, epoch: u64) -> Result<()>

Source

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