Struct kahoot_swarm::Swarm

pub struct Swarm {
    code: String,
    base_name: String,
    task_tx: UnboundedSender<TaskMessage>,
    rx: Arc<Mutex<UnboundedReceiver<TaskMessage>>>,
    num_workers: Arc<AtomicU64>,
}

Fields

code: String

base_name: String

task_tx: UnboundedSender<TaskMessage>

rx: Arc<Mutex<UnboundedReceiver<TaskMessage>>>

num_workers: Arc<AtomicU64>

Implementations

impl Swarm

pub fn new(code: String, base_name: String) -> Self

pub async fn add_n_workers<'_>(&'_ self, n: usize) -> KahootResult<()>

pub async fn add_worker<'_>(&'_ self) -> KahootResult<()>

Add a worker

async fn add_worker_with_id<'_>(&'_ self, id: u64) -> KahootResult<()>

pub async fn run<'_>(&'_ self)

Run the swarm

Trait Implementations

impl Clone for Swarm

fn clone(&self) -> Swarm

Returns a copy of the value.

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

Performs copy-assignment from source.