Struct TokenInformation 

pub struct TokenInformation { /* private fields */ }

A class representing delegation token details.

Corresponds to org.apache.kafka.common.security.token.delegation.TokenInformation.

Implementations

impl TokenInformation

pub fn new( token_id: impl Into<String>, owner: KafkaPrincipal, renewers: Vec<KafkaPrincipal>, issue_timestamp: i64, max_timestamp: i64, expiry_timestamp: i64, ) -> Self

Creates token information where the owner is also the requester.

Mirrors the TokenInformation(tokenId, owner, renewers, ...) constructor.

pub fn with_token_requester( token_id: impl Into<String>, owner: KafkaPrincipal, token_requester: KafkaPrincipal, renewers: Vec<KafkaPrincipal>, issue_timestamp: i64, max_timestamp: i64, expiry_timestamp: i64, ) -> Self

Creates token information with a distinct token requester.

Mirrors the TokenInformation(tokenId, owner, tokenRequester, renewers, ...) constructor.

pub fn owner(&self) -> &KafkaPrincipal

Returns the token owner.

Mirrors TokenInformation.owner.

pub fn owner_as_string(&self) -> String

Returns the token owner as a type:name string.

Mirrors TokenInformation.ownerAsString.

pub fn token_requester(&self) -> &KafkaPrincipal

Returns the token requester.

Mirrors TokenInformation.tokenRequester.

pub fn token_requester_as_string(&self) -> String

Returns the token requester as a type:name string.

Mirrors TokenInformation.tokenRequesterAsString.

pub fn renewers(&self) -> &[KafkaPrincipal]

Returns the renewers.

Mirrors TokenInformation.renewers.

pub fn renewers_as_string(&self) -> Vec<String>

Returns the renewers as type:name strings.

Mirrors TokenInformation.renewersAsString.

pub fn issue_timestamp(&self) -> i64

Returns the issue timestamp.

Mirrors TokenInformation.issueTimestamp.

pub fn expiry_timestamp(&self) -> i64

Returns the expiry timestamp.

Mirrors TokenInformation.expiryTimestamp.

pub fn set_expiry_timestamp(&mut self, expiry_timestamp: i64)

Sets the expiry timestamp.

Mirrors TokenInformation.setExpiryTimestamp.

pub fn token_id(&self) -> &str

Returns the token id.

Mirrors TokenInformation.tokenId.

pub fn max_timestamp(&self) -> i64

Returns the maximum timestamp.

Mirrors TokenInformation.maxTimestamp.

pub fn owner_or_renewer(&self, principal: &KafkaPrincipal) -> bool

Returns true if the given principal is the owner, the token requester, or one of the renewers.

Mirrors TokenInformation.ownerOrRenewer.

Trait Implementations

impl Clone for TokenInformation

fn clone(&self) -> TokenInformation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TokenInformation

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

Formats the value using the given formatter.

impl Display for TokenInformation

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

Formats the value using the given formatter.

impl Hash for TokenInformation

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for TokenInformation

fn eq(&self, other: &Self) -> 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 Eq for TokenInformation