Struct TaskManager

pub(super) struct TaskManager {
    tasks: HashMap<UploadingTaskId, TaskEntry>,
    task_order: VecDeque<UploadingTaskId>,
    next_task_id: usize,
}

Fields

tasks: HashMap<UploadingTaskId, TaskEntry>

task_order: VecDeque<UploadingTaskId>

next_task_id: usize

Implementations

impl TaskManager

fn add_task( &mut self, task: UploadingTask, status: UploadingTaskStatus, ) -> &UploadingTaskStatus

fn poll_task( &mut self, cx: &mut Context<'_>, task_id: UploadingTaskId, ) -> Poll<Result<Arc<StagingSstableInfo>, (SyncId, HummockError)>>

fn get_next_task_id(&mut self) -> UploadingTaskId

pub(super) fn poll_task_result( &mut self, cx: &mut Context<'_>, ) -> Poll<Option<(UploadingTaskId, UploadingTaskStatus, Result<Arc<StagingSstableInfo>, (SyncId, HummockError)>)>>

pub(super) fn abort_all_tasks(self)

pub(super) fn abort_task( &mut self, task_id: UploadingTaskId, ) -> Option<UploadingTaskStatus>

pub(super) fn spill( &mut self, context: &UploaderContext, table_ids: HashSet<TableId>, imms: HashMap<LocalInstanceId, Vec<UploaderImm>>, ) -> (UploadingTaskId, usize, &HashSet<TableId>)

pub(super) fn remove_table_spill_tasks( &mut self, table_id: TableId, task_ids: impl Iterator<Item = UploadingTaskId>, )

pub(super) fn sync( &mut self, context: &UploaderContext, sync_id: SyncId, unflushed_payload: HashMap<LocalInstanceId, Vec<UploaderImm>>, spill_task_ids: impl Iterator<Item = UploadingTaskId>, sync_table_ids: &HashSet<TableId>, ) -> Option<UploadingTaskId>

pub(super) fn tasks( &self, ) -> impl Iterator<Item = (UploadingTaskId, &UploadingTaskStatus)>

Trait Implementations

impl Debug for TaskManager

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

Formats the value using the given formatter.

impl Default for TaskManager

fn default() -> TaskManager

Returns the “default value” for a type.