Struct Worker

pub struct Worker { /* private fields */ }

Implementations

impl Worker

pub fn new( id: String, broker: Arc<RedisBroker>, scheduler: Arc<TaskScheduler>, ) -> Self

pub fn with_task_registry(self, registry: Arc<TaskRegistry>) -> Self

pub fn with_backpressure_config(self, config: WorkerBackpressureConfig) -> Self

pub fn with_max_concurrent_tasks(self, max_tasks: usize) -> Self

pub fn active_task_count(&self) -> usize

Get the current number of active tasks

pub async fn start(self) -> Result<Self, TaskQueueError>

pub async fn stop(self)