Struct OpendalStreamingUploaderExecute

struct OpendalStreamingUploaderExecute {
    metrics: Arc<ObjectStoreMetrics>,
    media_type: &'static str,
}

Fields

metrics: Arc<ObjectStoreMetrics>

To record metrics for uploading part.

media_type: &'static str

Implementations

impl OpendalStreamingUploaderExecute

const STREAMING_UPLOAD_TYPE: OperationType = OperationType::StreamingUpload

fn new(metrics: Arc<ObjectStoreMetrics>, media_type: &'static str) -> Self

Trait Implementations

impl Execute for OpendalStreamingUploaderExecute

fn execute(&self, f: BoxedStaticFuture<()>)

Execute async task in background.

fn timeout(&self) -> Option<Pin<Box<dyn Future<Output = ()> + Send>>>

Return a future that will be resolved after the given timeout.