Struct Worker 

pub struct Worker { /* private fields */ }

Worker node for executing distributed tasks.

Implementations

impl Worker

pub fn new(config: WorkerConfig) -> Self

Create a new worker.

pub fn worker_id(&self) -> &str

Get the worker ID.

pub fn status(&self) -> WorkerStatus

Get the current status.

pub fn metrics(&self) -> WorkerMetrics

Get the current metrics.

pub fn is_available(&self) -> bool

Check if the worker is available for new tasks.

pub async fn execute_task( &self, task: Task, data: Arc<RecordBatch>, ) -> Result<TaskResult>

Execute a task.

pub async fn start_heartbeat(&self, heartbeat_tx: Sender<String>) -> Result<()>

Start the worker’s heartbeat loop.

pub async fn shutdown(&self) -> Result<()>

Initiate graceful shutdown.

pub fn health_check(&self) -> WorkerHealthCheck

Get health check information.