Struct ic_cron::task_scheduler::TaskScheduler

pub struct TaskScheduler {
    pub is_running: bool,
    pub tasks: HashMap<TaskId, ScheduledTask>,
    pub task_id_counter: TaskId,
    pub queue: TaskExecutionQueue,
}

Fields

is_running: bool

tasks: HashMap<TaskId, ScheduledTask>

task_id_counter: TaskId

queue: TaskExecutionQueue

Implementations

impl TaskScheduler

pub fn enqueue<TaskPayload: CandidType>(
    &mut self,
    kind: u8,
    payload: TaskPayload,
    scheduling_interval: SchedulingInterval,
    timestamp: u64
) -> CandidResult<TaskId>

pub fn iterate(&mut self, timestamp: u64) -> Vec<ScheduledTask>

pub fn dequeue(&mut self, task_id: TaskId) -> Option<ScheduledTask>

pub fn is_empty(&self) -> bool

pub fn get_task_by_id(&self, task_id: &TaskId) -> Option<ScheduledTask>

pub fn get_tasks(&self) -> Vec<ScheduledTask>

pub fn try_start(&mut self) -> bool

pub fn try_stop(&mut self) -> bool

Trait Implementations

impl Default for TaskScheduler

fn default() -> TaskScheduler

Returns the “default value” for a type.