Struct pravega_client_auth::DelegationTokenProvider

pub struct DelegationTokenProvider { /* fields omitted */ }

A client-side proxy for obtaining a delegation token from the server.

Note: Delegation tokens are used by Segment Store services to authorize requests. They are created by Controller at client’s behest.

The implementation is JWT based.

Implementations

impl DelegationTokenProvider

pub fn new(stream: ScopedStream) -> Self

pub async fn retrieve_token(&self, controller: &dyn ControllerClient) -> String

Returns the delegation token. It returns an existing delegation token if it is not close to expiry. If the token is close to expiry, it obtains a new delegation token and returns that one instead.

pub async fn populate(&self, delegation_token: DelegationToken)

Populate the cached token. An empty token can be used when auth is disabled.

pub fn signal_token_expiry(&self)

Mark the token as expired. Token may be marked as invalid by segmentstore due to a time skew between client and segmentstore host. In that case, mark the token as expired so that next time a new token could be fetched from controller.