Struct DefaultAuthorizationContext 

pub struct DefaultAuthorizationContext { /* private fields */ }

Default authorization context containing all information needed for authorization decisions.

This struct contains:

• Subject: who is performing the action (user, role, service account)
• Resource: what is being accessed (topic, group, cluster)
• Actions: what operations are being performed (PUB, SUB, CREATE, etc.)
• Source IP: where the request originates from
• Channel ID: unique identifier for the communication channel
• RPC code: the RocketMQ request code
• Extended info: additional context-specific metadata

Implementations

impl DefaultAuthorizationContext

pub fn of( subject_key: impl Into<String>, subject_type: SubjectType, resource: Resource, action: Action, source_ip: impl Into<String>, ) -> Self

Create a new authorization context with basic information.

Arguments

• subject_key - The subject key performing the operation
• subject_type - The type of the subject
• resource - The resource being accessed
• action - The action being performed
• source_ip - Source IP address of the request

pub fn of_multi_actions( subject_key: impl Into<String>, subject_type: SubjectType, resource: Resource, actions: Vec<Action>, source_ip: impl Into<String>, ) -> Self

Create a new authorization context with multiple actions.

Arguments

• subject_key - The subject key performing the operation
• subject_type - The type of the subject
• resource - The resource being accessed
• actions - List of actions being performed
• source_ip - Source IP address of the request

pub fn builder() -> DefaultAuthorizationContextBuilder

Create a builder for constructing authorization contexts.

pub fn subject_key(&self) -> Option<&str>

Get the subject key (unique identifier for the subject).

pub fn subject_type(&self) -> Option<SubjectType>

Get the subject type.

pub fn resource_key(&self) -> Option<String>

Get the resource key (unique identifier for the resource).

pub fn subject(&self) -> Option<&SubjectWrapper>

pub fn resource(&self) -> Option<&Resource>

pub fn actions(&self) -> &[Action]

pub fn source_ip(&self) -> Option<&str>

pub fn channel_id(&self) -> Option<&str>

pub fn rpc_code(&self) -> Option<&str>

pub fn ext_info(&self) -> &HashMap<String, String>

pub fn set_subject( &mut self, subject_key: impl Into<String>, subject_type: SubjectType, )

pub fn set_resource(&mut self, resource: Resource)

pub fn set_actions(&mut self, actions: Vec<Action>)

pub fn set_source_ip(&mut self, source_ip: impl Into<String>)

pub fn set_channel_id(&mut self, channel_id: impl Into<String>)

pub fn set_rpc_code(&mut self, rpc_code: impl Into<String>)

pub fn set_ext_info(&mut self, ext_info: HashMap<String, String>)

pub fn add_ext_info(&mut self, key: impl Into<String>, value: impl Into<String>)

Trait Implementations

impl Clone for DefaultAuthorizationContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultAuthorizationContext

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

Formats the value using the given formatter.

impl Default for DefaultAuthorizationContext

fn default() -> Self

Returns the “default value” for a type.