Struct RouterBuilder 

pub struct RouterBuilder { /* private fields */ }

Builder for creating routers with fluent API

Implementations

impl RouterBuilder

pub fn new() -> Self

Create a new router builder

pub fn route_glob(self, pattern: &str, queue: &str) -> Self

Add a rule that routes tasks matching a glob pattern to a queue

pub fn route_regex(self, pattern: &str, queue: &str) -> Result<Self, Error>

Add a rule that routes tasks matching a regex pattern to a queue

Errors

Returns an error if the regex pattern is invalid.

pub fn route_exact(self, task_name: &str, queue: &str) -> Self

Add a rule that routes a specific task to a queue

pub fn direct_route(self, task_name: &str, queue: &str) -> Self

Add a direct route for a specific task

pub fn route_with_args( self, matcher: PatternMatcher, queue: &str, condition: ArgumentCondition, ) -> Self

Add a rule that routes tasks based on argument conditions

Example

use celers_core::router::{RouterBuilder, PatternMatcher, ArgumentCondition};

let router = RouterBuilder::new()
    .route_with_args(
        PatternMatcher::glob("process.*"),
        "high_priority",
        ArgumentCondition::kwarg_equals("priority", serde_json::json!("high")),
    )
    .route_with_args(
        PatternMatcher::glob("process.*"),
        "low_priority",
        ArgumentCondition::kwarg_equals("priority", serde_json::json!("low")),
    )
    .default_queue("default")
    .build();

pub fn route_with_args_priority( self, matcher: PatternMatcher, queue: &str, condition: ArgumentCondition, priority: i32, ) -> Self

Add a rule with both priority and argument condition

pub fn default_queue(self, queue: &str) -> Self

Set the default queue for unmatched tasks

pub fn build(self) -> Router

Build the router

Trait Implementations

impl Debug for RouterBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RouterBuilder

fn default() -> RouterBuilder

Returns the “default value” for a type.