Struct Router 

pub struct Router { /* private fields */ }

Task router for directing tasks to appropriate queues

Implementations

impl Router

pub fn new() -> Self

Create a new empty router

pub fn with_default_queue(queue: impl Into<String>) -> Self

Create a router with a default queue

pub fn add_rule(&mut self, rule: RouteRule)

Add a routing rule

Rules are sorted by priority (higher priority rules are evaluated first)

pub fn add_direct_route( &mut self, task_name: impl Into<String>, result: RouteResult, )

Add a direct route for a specific task

Direct routes take precedence over pattern-based rules

pub fn set_default_queue(&mut self, queue: impl Into<String>)

Set the default queue for unmatched tasks

pub fn route(&self, task_name: &str) -> Option<String>

Route a task to a queue

Returns None if no matching rule and no default queue

pub fn route_full(&self, task_name: &str) -> Option<RouteResult>

Route a task and get full routing information

Returns None if no matching rule and no default queue

pub fn route_with_args( &self, task_name: &str, args: &[Value], kwargs: &Map<String, Value>, ) -> Option<String>

Route a task with arguments to a queue

This method considers both task name patterns and argument conditions. Returns None if no matching rule and no default queue.

pub fn route_full_with_args( &self, task_name: &str, args: &[Value], kwargs: &Map<String, Value>, ) -> Option<RouteResult>

Route a task with arguments and get full routing information

This method considers both task name patterns and argument conditions. Returns None if no matching rule and no default queue.

pub fn has_route(&self, task_name: &str) -> bool

Check if a task has any matching route

pub fn rules(&self) -> &[RouteRule]

Get all registered rules

pub fn remove_rules_by_queue(&mut self, queue: &str)

Remove all rules matching a pattern

pub fn clear(&mut self)

Clear all rules

Trait Implementations

impl Debug for Router

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

Formats the value using the given formatter.

impl Default for Router

fn default() -> Router

Returns the “default value” for a type.