Struct HeartbeatState 

pub struct HeartbeatState {
    pub agent_name: String,
    pub status: Arc<Mutex<WorkerStatus>>,
    pub active_task_count: Arc<Mutex<usize>>,
    /* private fields */
}

Heartbeat state shared between the heartbeat task and the main worker

Fields

agent_name: String

status: Arc<Mutex<WorkerStatus>>

active_task_count: Arc<Mutex<usize>>

Implementations

impl HeartbeatState

pub fn new(worker_id: String, agent_name: String) -> Self

pub async fn set_status(&self, status: WorkerStatus)

pub async fn set_task_count(&self, count: usize)

Trait Implementations

impl Clone for HeartbeatState

fn clone(&self) -> HeartbeatState

Returns a duplicate of the value.

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

Performs copy-assignment from source.