Type Alias CoordinatorStreamHandle

pub type CoordinatorStreamHandle = BidiStreamHandle<CoordinateRequest, CoordinateResponse>;

Aliased Type

struct CoordinatorStreamHandle {
    pub request_sender: BidiStreamSender<CoordinateRequest>,
    pub response_stream: BidiStreamReceiver<CoordinateResponse>,
}

Fields

request_sender: BidiStreamSender<CoordinateRequest>

response_stream: BidiStreamReceiver<CoordinateResponse>

Implementations

impl CoordinatorStreamHandle

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