Struct ic_cron::task_scheduler::TaskScheduler

pub struct TaskScheduler {
    pub tasks: HashMap<TaskId, Task>,
    pub task_id_counter: TaskId,
    pub queue: TaskExecutionQueue,
}

Fields

tasks: HashMap<TaskId, Task>

task_id_counter: TaskId

queue: TaskExecutionQueue

Implementations

impl TaskScheduler

pub fn enqueue<Tuple: ArgumentEncoder>(
    &mut self,
    endpoint: RemoteCallEndpoint,
    args: Tuple,
    cycles: u64,
    scheduling_interval: SchedulingInterval,
    timestamp: u64
) -> CandidResult<TaskId>

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

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

pub fn is_empty(&self) -> bool

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

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

Trait Implementations

impl Default for TaskScheduler

fn default() -> TaskScheduler

Returns the “default value” for a type.