Struct TaskDistributor 

pub struct TaskDistributor {
    pub pending_tasks: HashMap<String, MiningTask>,
}

Distributes mining tasks to available miners (from .AI3).

Fields

pending_tasks: HashMap<String, MiningTask>

Task id -> task.

Implementations

impl TaskDistributor

pub fn new() -> Self

Creates an empty distributor.

pub fn add_task(&mut self, task: MiningTask)

Adds a task to the pending set.

pub fn get_pending_tasks(&self) -> Vec<&MiningTask>

Returns all pending tasks.

pub fn remove_task(&mut self, task_id: &str) -> Option<MiningTask>

Removes and returns a task by id.

pub fn cleanup_expired_tasks(&mut self)

Removes expired tasks from the pending set.

Trait Implementations

impl Debug for TaskDistributor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskDistributor

fn default() -> TaskDistributor

Returns the “default value” for a type.