Struct TopicAuth 

pub struct TopicAuth { /* private fields */ }

Topic authorization engine.

Holds a set of rules that map topic patterns to access policies. When checking access, the first matching rule wins. If no rule matches, a configurable default policy applies (defaults to Public for subscribe, Authenticated for publish).

Implementations

impl TopicAuth

pub fn with_defaults() -> Self

Create with default rules for the standard topic namespaces.

Default rules:

• system/# — subscribe: Authenticated, publish: never (internal only)
• plugin/# — subscribe: Public, publish: Authenticated
• custom/# — subscribe: Public, publish: Authenticated

pub fn new() -> Self

Create with no rules (everything falls through to defaults).

pub fn with_rules(rules: Vec<AuthRule>) -> Self

Create with custom rules.

pub fn set_default_subscribe(&mut self, policy: Policy)

Override the default subscribe policy.

pub fn set_default_publish(&mut self, policy: Policy)

Override the default publish policy.

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

Add a rule.

pub fn check_subscribe(&self, topic: &str, ctx: &AuthContext) -> bool

Check if the given context is allowed to subscribe to topic.

pub fn check_publish(&self, topic: &str, ctx: &AuthContext) -> bool

Check if the given context is allowed to publish to topic.

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

Return the list of rules.

Trait Implementations

impl Clone for TopicAuth

fn clone(&self) -> TopicAuth

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicAuth

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

Formats the value using the given formatter.

impl Default for TopicAuth

fn default() -> Self

Returns the “default value” for a type.