risingwave_object_store::object

Trait StreamingUploader

source
pub trait StreamingUploader: Send {
    // Required methods
    async fn write_bytes(&mut self, data: Bytes) -> ObjectResult<()>;
    async fn finish(self) -> ObjectResult<()>;
    fn get_memory_usage(&self) -> u64;
}

Required Methods§

source

async fn write_bytes(&mut self, data: Bytes) -> ObjectResult<()>

source

async fn finish(self) -> ObjectResult<()>

source

fn get_memory_usage(&self) -> u64

Object Safety§

This trait is not object safe.

Implementors§