RestrictiveValidator

Struct RestrictiveValidator 

Source
pub struct RestrictiveValidator {
    pub reserved_prefixes: Vec<String>,
    pub max_levels: Option<usize>,
    pub max_topic_length: Option<usize>,
    pub prohibited_chars: Vec<char>,
}
Expand description

Restrictive validator with additional constraints

This validator extends the standard MQTT rules with additional restrictions such as reserved topic prefixes, maximum topic levels, and custom character sets.

Fields§

§reserved_prefixes: Vec<String>

Reserved topic prefixes that should be rejected

§max_levels: Option<usize>

Maximum number of topic levels (separated by ‘/’)

§max_topic_length: Option<usize>

Maximum topic length (overrides MQTT spec if smaller)

§prohibited_chars: Vec<char>

Prohibited characters beyond MQTT spec requirements

Implementations§

Source§

impl RestrictiveValidator

Source

pub fn new() -> Self

Creates a new restrictive validator

Source

pub fn with_reserved_prefix(self, prefix: impl Into<String>) -> Self

Adds a reserved topic prefix

Source

pub fn with_max_levels(self, max_levels: usize) -> Self

Sets the maximum number of topic levels

Source

pub fn with_max_topic_length(self, max_length: usize) -> Self

Sets the maximum topic length

Source

pub fn with_prohibited_char(self, ch: char) -> Self

Adds a prohibited character

Trait Implementations§

Source§

impl Clone for RestrictiveValidator

Source§

fn clone(&self) -> RestrictiveValidator

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for RestrictiveValidator

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for RestrictiveValidator

Source§

fn default() -> RestrictiveValidator

Returns the “default value” for a type. Read more
Source§

impl TopicValidator for RestrictiveValidator

Source§

fn validate_topic_name(&self, topic: &str) -> Result<()>

Validates a topic name for publishing Read more
Source§

fn validate_topic_filter(&self, filter: &str) -> Result<()>

Validates a topic filter for subscriptions Read more
Source§

fn is_reserved_topic(&self, topic: &str) -> bool

Checks if a topic is reserved and should be restricted Read more
Source§

fn description(&self) -> &'static str

Gets a human-readable description of the validator

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more