Struct TopicValidator 

pub struct TopicValidator;

Implementations

impl TopicValidator

pub const AUTO_CREATE_TOPIC_KEY_TOPIC: &'static str = "TBW102"

pub const RMQ_SYS_SCHEDULE_TOPIC: &'static str = "SCHEDULE_TOPIC_XXXX"

pub const RMQ_SYS_BENCHMARK_TOPIC: &'static str = "BenchmarkTest"

pub const RMQ_SYS_TRANS_HALF_TOPIC: &'static str = "RMQ_SYS_TRANS_HALF_TOPIC"

pub const RMQ_SYS_TRACE_TOPIC: &'static str = "RMQ_SYS_TRACE_TOPIC"

pub const RMQ_SYS_TRANS_OP_HALF_TOPIC: &'static str = "RMQ_SYS_TRANS_OP_HALF_TOPIC"

pub const RMQ_SYS_TRANS_CHECK_MAX_TIME_TOPIC: &'static str = "TRANS_CHECK_MAX_TIME_TOPIC"

pub const RMQ_SYS_SELF_TEST_TOPIC: &'static str = "SELF_TEST_TOPIC"

pub const RMQ_SYS_OFFSET_MOVED_EVENT: &'static str = "OFFSET_MOVED_EVENT"

pub const RMQ_SYS_ROCKSDB_OFFSET_TOPIC: &'static str = "CHECKPOINT_TOPIC"

pub const SYSTEM_TOPIC_PREFIX: &'static str = "rmq_sys_"

pub const SYNC_BROKER_MEMBER_GROUP_PREFIX: &'static str = "rmq_sys_SYNC_BROKER_MEMBER_"

impl TopicValidator

pub fn is_topic_or_group_illegal(name: &str) -> bool

Check if topic or group name contains illegal characters

Performance

Uses pre-computed bitmap for O(1) character validation

pub fn validate_topic(topic: &str) -> ValidateTopicResult

Validate topic name according to RocketMQ rules

Rules

• Cannot be blank
• Must contain only: 0-9, a-z, A-Z, %, -, _, |
• Length must not exceed TOPIC_MAX_LENGTH (127)

pub fn is_system_topic(topic: &str) -> bool

pub fn is_not_allowed_send_topic(topic: &str) -> bool

pub fn add_system_topic(system_topic: impl Into<CheetahString>)

pub fn get_system_topic_set() -> Vec<CheetahString>

pub fn get_not_allowed_send_topic_set() -> Vec<CheetahString>