Struct UploadingTask

struct UploadingTask {
    task_id: UploadingTaskId,
    input: HashMap<LocalInstanceId, Vec<UploaderImm>>,
    join_handle: JoinHandle<HummockResult<UploadTaskOutput>>,
    task_info: UploadTaskInfo,
    spawn_upload_task: SpawnUploadTask,
    task_size_guard: GenericGauge<AtomicU64>,
    task_count_guard: IntGauge,
}

A wrapper for a uploading task that compacts and uploads the imm payload. Task context are stored so that when the task fails, it can be re-tried.

Fields

task_id: UploadingTaskId

input: HashMap<LocalInstanceId, Vec<UploaderImm>>

join_handle: JoinHandle<HummockResult<UploadTaskOutput>>

task_info: UploadTaskInfo

spawn_upload_task: SpawnUploadTask

task_size_guard: GenericGauge<AtomicU64>

task_count_guard: IntGauge

Implementations

impl UploadingTask

const LOG_THRESHOLD_FOR_UPLOAD_TASK_SIZE: usize = 52_428_800usize

fn input_to_payload( input: &HashMap<LocalInstanceId, Vec<UploaderImm>>, ) -> UploadTaskPayload

fn new( task_id: UploadingTaskId, input: HashMap<LocalInstanceId, Vec<UploaderImm>>, context: &UploaderContext, ) -> Self

fn poll_result( &mut self, cx: &mut Context<'_>, ) -> Poll<HummockResult<Arc<StagingSstableInfo>>>

Poll the result of the uploading task

fn poll_ok_with_retry( &mut self, cx: &mut Context<'_>, ) -> Poll<Arc<StagingSstableInfo>>

Poll the uploading task until it succeeds. If it fails, we will retry it.

pub fn get_task_info(&self) -> &UploadTaskInfo

Trait Implementations

impl Debug for UploadingTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for UploadingTask

fn drop(&mut self)

Executes the destructor for this type.