Struct WorkerServerState 

pub struct WorkerServerState {
    pub heartbeat_state: Option<Arc<HeartbeatState>>,
    pub connected: Arc<Mutex<bool>>,
    pub worker_id: Arc<Mutex<Option<String>>>,
    /* private fields */
}

Worker server state shared across handlers

Fields

heartbeat_state: Option<Arc<HeartbeatState>>

Heartbeat state from the worker (used to determine readiness)

connected: Arc<Mutex<bool>>

Whether the SSE stream is currently connected

worker_id: Arc<Mutex<Option<String>>>

Worker ID for identification

Implementations

impl WorkerServerState

pub fn new() -> Self

pub async fn set_task_notification_channel(&self, tx: Sender<String>)

Set the task notification channel (called from worker)

pub async fn notify_new_task(&self, task_id: &str)

Notify worker of a new task (called from /task endpoint)

pub fn with_heartbeat(self, state: Option<Arc<HeartbeatState>>) -> Self

pub async fn set_heartbeat_state(&self, state: Arc<HeartbeatState>)

Set the heartbeat state (called from worker)

pub async fn heartbeat_state(&self) -> Arc<HeartbeatState>

Get the heartbeat state (for HTTP server)

pub async fn set_connected(&self, connected: bool)

pub async fn set_worker_id(&self, worker_id: String)

pub async fn worker_id(&self) -> String

pub async fn is_connected(&self) -> bool

pub async fn is_ready(&self) -> bool

Trait Implementations

impl Clone for WorkerServerState

fn clone(&self) -> WorkerServerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.