Expand description
Worker Control Commands
This module provides the protocol for remote worker control and inspection. It enables clients to query worker state, inspect running tasks, and send control commands to workers.
§Example
use celers_core::control::{ControlCommand, InspectCommand, InspectResponse};
// Create an inspect active tasks command
let cmd = ControlCommand::Inspect(InspectCommand::Active);
// Serialize for sending to worker
let json = serde_json::to_string(&cmd).unwrap();Structs§
- Active
Task Info - Information about an actively executing task
- Broker
Stats - Broker connection statistics
- Delivery
Info - Delivery information for a task
- Pool
Stats - Worker pool statistics
- Queue
Stats - Queue statistics
- Request
Info - Request information for a task
- Reserved
Task Info - Information about a reserved (prefetched) task
- Scheduled
Task Info - Information about a scheduled task (with ETA or countdown)
- Worker
Conf - Worker configuration
- Worker
Report - Worker report (comprehensive status)
- Worker
Stats - Worker statistics
Enums§
- Control
Command - Control commands that can be sent to workers
- Control
Response - Response to a control command
- Inspect
Command - Inspection sub-commands
- Inspect
Response - Response data from inspect commands
- Queue
Command - Queue control sub-commands
- Queue
Response - Response to queue control commands