Struct WorkerSender

pub struct WorkerSender<T> {
    inner: Sender<T>,
    worker_id: u32,
    hostname: String,
    status: Arc<Mutex<WorkerStatus>>,
    unicast_v4: Option<Address>,
    unicast_v6: Option<Address>,
}

Special Sender struct for workers that sends tasks after a delay (based on the Worker interval).

Fields

• inner - the inner sender that connects to the worker
• worker_id - the unique ID of the worker
• hostname - the hostname of the worker
• status - the status of the worker, used to determine if it is connected or not
• unicast_v4 - the unicast IPv4 address of the worker, if available
• unicast_v6 - the unicast IPv6 address of the worker, if available

Fields

inner: Sender<T>

worker_id: u32

hostname: String

status: Arc<Mutex<WorkerStatus>>

unicast_v4: Option<Address>

unicast_v6: Option<Address>

Implementations

impl<T> WorkerSender<T>

pub fn is_closed(&self) -> bool

Checks if the sender is closed

pub async fn send(&self, task: T) -> Result<(), SendError<T>>

Sends a task after the specified interval

fn cleanup(&self)

pub fn is_probing(&self) -> bool

pub fn get_status(&self) -> String

pub fn finished(&self)

The worker finished its measurement

Trait Implementations

impl<T: Clone> Clone for WorkerSender<T>

fn clone(&self) -> WorkerSender<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for WorkerSender<T>

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

Formats the value using the given formatter.