Struct WorkerSender 

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

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

Fields

inner: Sender<T>

Inner sender that connects to the orker

worker_id: u32

Unique Worker ID

hostname: String

Worker hostname

status: Arc<Mutex<WorkerStatus>>

Status of the Worker (e.g., Listening, Probing, Idle, Connected)

unicast_v4: Option<Address>

Unicast IPv4 address of the Worker (None if unavailable)

unicast_v6: Option<Address>

Unicast IPv6 address of the Worker (None if unavailable)

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 an instruction to the worker. On failure, logs a warning (once) and marks the worker as disconnected.

pub fn try_send(&self, task: T) -> Result<(), TrySendError<T>>

Sends an instruction to the worker without blocking

pub(crate) fn cleanup(&self)

Marks the worker as disconnected

pub fn is_participating(&self) -> bool

pub fn get_status(&self) -> WorkerStatus

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.