Type Alias SinkCoordinatorStreamHandle 

pub type SinkCoordinatorStreamHandle = BidiStreamHandle<SinkCoordinatorStreamRequest, SinkCoordinatorStreamResponse>;

Aliased Type

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

Fields

request_sender: BidiStreamSender<SinkCoordinatorStreamRequest>

response_stream: BidiStreamReceiver<SinkCoordinatorStreamResponse>

Implementations

impl SinkCoordinatorStreamHandle

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