Struct ic_cron::task_scheduler::TaskScheduler

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

Fields

tasks: HashMap<TaskId, ScheduledTask>

task_id_counter: TaskId

queue: TaskExecutionQueue

Implementations

impl TaskScheduler

pub fn enqueue<TaskPayload: CandidType>(
    &mut self,
    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>

Trait Implementations

impl CandidType for TaskScheduler

fn _ty() -> Type

fn id() -> TypeId

fn idl_serialize<__S>(&self, __serializer: __S) -> Result<(), __S::Error> where
    __S: Serializer, 

fn ty() -> Type

impl Clone for TaskScheduler

fn clone(&self) -> TaskScheduler

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskScheduler

fn default() -> TaskScheduler

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TaskScheduler

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.