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>)>>