Struct BidiStreamHandle

pub struct BidiStreamHandle<REQ, RSP> {
    pub request_sender: BidiStreamSender<REQ>,
    pub response_stream: BidiStreamReceiver<RSP>,
}

Fields

request_sender: BidiStreamSender<REQ>

response_stream: BidiStreamReceiver<RSP>

Implementations

impl<REQ: From<SinkWriterStreamRequest>> BidiStreamHandle<REQ, SinkWriterStreamResponse>

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

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

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

impl BidiStreamHandle<SinkCoordinatorStreamRequest, SinkCoordinatorStreamResponse>

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

impl BidiStreamHandle<CoordinateRequest, CoordinateResponse>

pub async fn new( client: SinkCoordinationRpcClient, param: PbSinkParam, vnode_bitmap: Bitmap, ) -> Result<Self, RpcError>

pub async fn new_with_init_stream<F, St, Fut>( param: PbSinkParam, vnode_bitmap: Bitmap, init_stream: F, ) -> Result<Self, RpcError>

where F: FnOnce(Receiver<CoordinateRequest>) -> Fut + Send, St: Stream<Item = Result<CoordinateResponse, Status>> + Send + Unpin + 'static, Fut: Future<Output = Result<Response<St>, Status>> + Send,

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

pub async fn update_vnode_bitmap(&mut self, vnode_bitmap: &Bitmap) -> Result<()>

pub async fn stop(&mut self) -> Result<()>

impl<REQ, RSP> BidiStreamHandle<REQ, RSP>

pub fn for_test( request_sender: Sender<REQ>, response_stream: BoxStream<'static, Result<RSP>>, ) -> Self

pub async fn initialize<F: FnOnce(Receiver<REQ>) -> Fut, St: Stream<Item = Result<RSP>> + Send + Unpin + 'static, Fut: Future<Output = Result<St>> + Send, R: Into<REQ>>( first_request: R, init_stream_fn: F, ) -> Result<(Self, RSP)>

pub async fn next_response(&mut self) -> Result<RSP>

pub async fn send_request(&mut self, request: REQ) -> Result<()>

Trait Implementations

impl<REQ, RSP> Debug for BidiStreamHandle<REQ, RSP>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.