Struct 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: SchedulingOptions, 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(&self, task_id: &TaskId) -> Option<&ScheduledTask>

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

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

pub fn get_tasks_cloned(&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 duplicate 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.