Struct TaskQueueBuilder

pub struct TaskQueueBuilder { /* private fields */ }

Builder for configuring and creating TaskQueue instances

Implementations

impl TaskQueueBuilder

pub fn new(redis_url: impl Into<String>) -> Self

Create a new TaskQueue builder with default configuration

pub fn from_global_config() -> Result<Self, TaskQueueError>

Create a TaskQueue builder from global configuration

pub fn from_config(config: TaskQueueConfig) -> Self

Create a TaskQueue builder from a specific configuration

pub fn auto() -> Result<Self, TaskQueueError>

Create a TaskQueue builder that auto-loads configuration

pub fn redis_url(self, url: impl Into<String>) -> Self

Override Redis URL (useful for testing or special cases)

pub fn autoscaler_config(self, config: AutoScalerConfig) -> Self

Set the auto-scaler configuration

pub fn initial_workers(self, count: usize) -> Self

Set the initial number of workers to start

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

Set a custom task registry

pub fn auto_register_tasks(self) -> Self

Enable automatic task registration using inventory pattern

pub fn disable_auto_register(self) -> Self

Disable automatic task registration

pub fn with_scheduler(self) -> Self

Start the task scheduler automatically

pub fn with_autoscaler(self) -> Self

Start the auto-scaler automatically

pub fn config(self, config: TaskQueueConfig) -> Self

Update the full configuration

pub async fn build(self) -> Result<TaskQueue, TaskQueueError>

Build the TaskQueue instance

Errors

Returns TaskQueueError if Redis connection fails or configuration is invalid