Struct cyfs_task_manager::TaskManager

pub struct TaskManager { /* private fields */ }

Implementations

impl TaskManager

pub async fn new(
    task_manager_store: Arc<dyn TaskManagerStore>,
    task_store: Arc<dyn TaskStore>
) -> BuckyResult<Arc<Self>>

pub fn register_task_factory(&self, factory: impl TaskFactory) -> BuckyResult<()>

pub async fn resume_task(&self) -> BuckyResult<()>

pub async fn create_task<P: RawEncode>(
    &self,
    dec_id: ObjectId,
    source: DeviceId,
    task_type: TaskType,
    task_param: P
) -> BuckyResult<TaskId>

pub async fn start_task(&self, task_id: &TaskId) -> BuckyResult<()>

pub async fn check_and_waiting_stop(&self, task_id: &TaskId)

pub async fn get_task_detail_status(
    &self,
    task_id: &TaskId
) -> BuckyResult<Vec<u8>>

pub async fn pause_task(&self, task_id: &TaskId) -> BuckyResult<()>

pub async fn stop_task(&self, task_id: &TaskId) -> BuckyResult<()>

pub async fn remove_task(
    &self,
    dec_id: &ObjectId,
    source: &DeviceId,
    task_id: &TaskId
) -> BuckyResult<()>

pub async fn remove_task_by_task_id(&self, task_id: &TaskId) -> BuckyResult<()>

pub async fn get_tasks_by_task_id(
    &self,
    task_id_list: &[TaskId]
) -> BuckyResult<Vec<(TaskId, TaskType, TaskStatus, Vec<u8>, Vec<u8>)>>

pub async fn get_tasks_by_category(
    &self,
    category: TaskCategory
) -> BuckyResult<Vec<(TaskId, TaskType, TaskStatus, Vec<u8>, Vec<u8>)>>