Struct TopicPattern 

pub struct TopicPattern { /* private fields */ }

Topic pattern matcher for AMQP-style topic routing

Supports wildcards:

• * (star) matches exactly one word
• # (hash) matches zero or more words
• Words are separated by dots (.)

Examples

use celers_core::router::TopicPattern;

let pattern = TopicPattern::new("user.*.created");
assert!(pattern.matches("user.email.created"));
assert!(pattern.matches("user.profile.created"));
assert!(!pattern.matches("user.created"));  // No middle word
assert!(!pattern.matches("user.email.verified.created"));  // Too many words

let pattern = TopicPattern::new("user.#");
assert!(pattern.matches("user.email"));
assert!(pattern.matches("user.email.created"));
assert!(pattern.matches("user.email.verified.sent"));
assert!(!pattern.matches("admin.email"));  // Doesn't start with "user"

Implementations

impl TopicPattern

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

Create a new topic pattern

pub fn matches(&self, routing_key: &str) -> bool

Check if a routing key matches this topic pattern

pub fn pattern(&self) -> &str

Get the original pattern string

pub const fn complexity(&self) -> usize

Get pattern complexity (number of segments)

pub fn has_wildcards(&self) -> bool

Check if pattern contains wildcards

pub fn is_exact(&self) -> bool

Check if pattern is exact (no wildcards)

Trait Implementations

impl Clone for TopicPattern

fn clone(&self) -> TopicPattern

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TopicPattern

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

Formats the value using the given formatter.