risingwave_object_store::object

Type Alias StreamingUploaderImpl

source
pub type StreamingUploaderImpl = ObjectStoreEnum<MonitoredStreamingUploader<<InMemObjectStore as ObjectStore>::StreamingUploader>, MonitoredStreamingUploader<<OpendalObjectStore as ObjectStore>::StreamingUploader>, MonitoredStreamingUploader<<S3ObjectStore as ObjectStore>::StreamingUploader>>;

Aliased Type§

enum StreamingUploaderImpl {
    InMem(MonitoredStreamingUploader<InMemStreamingUploader>),
    Opendal(MonitoredStreamingUploader<OpendalStreamingUploader>),
    S3(MonitoredStreamingUploader<S3StreamingUploader>),
}

Variants§

Implementations§

source§

impl StreamingUploaderImpl

source

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

source

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

source

pub fn get_memory_usage(&self) -> u64