Struct Principal 

pub struct Principal {
    pub name: String,
    pub auth_method: AuthMethod,
    pub groups: Vec<String>,
}

Fields

name: String

auth_method: AuthMethod

groups: Vec<String>

OAuth-derived group memberships from the listener’s groupsClaim. Empty vec for non-OAuth principals (PLAIN/SCRAM/ mTLS/anonymous) and for OAuth principals whose listener has no groupsClaim configured. No broker-side authorizer reads this yet; populated as scaffolding + for observability.

Implementations

impl Principal

pub fn to_kafka(&self) -> KafkaPrincipal

Project a runtime session Principal onto the Kafka wire-level KafkaPrincipal (principalType:name) used by ACLs and delegation-token records. All authenticated callers ride under principal_type = "User", matching Kafka’s DefaultKafkaPrincipalBuilder.

Trait Implementations

impl Clone for Principal

fn clone(&self) -> Principal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Principal

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

Formats the value using the given formatter.

impl Eq for Principal

impl PartialEq for Principal

fn eq(&self, other: &Principal) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Principal