nebius.aio.token.renewable.Bearer

class documentation

class Bearer(ParentBearer): (source)

Constructor: Bearer(source, max_retries, lifetime_safe_fraction, initial_retry_timeout, ...)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method bg_task Run a coroutine without awaiting or tracking, and log any exceptions.
Async Method close Undocumented
Async Method fetch Undocumented
Method is_renewal_required Undocumented
Method receiver Undocumented
Method request_renewal Undocumented
Method stop Undocumented
Async Method _fetch_once Undocumented
Async Method _run Undocumented
Instance Variable _break_previous_attempt Undocumented
Instance Variable _cache Undocumented
Instance Variable _initial_retry_timeout Undocumented
Instance Variable _is_fresh Undocumented
Instance Variable _is_stopped Undocumented
Instance Variable _lifetime_safe_fraction Undocumented
Instance Variable _max_retries Undocumented
Instance Variable _max_retry_timeout Undocumented
Instance Variable _refresh_request_timeout Undocumented
Instance Variable _refresh_task Undocumented
Instance Variable _renew_requested Undocumented
Instance Variable _renew_synchronous_options Undocumented
Instance Variable _renew_synchronous_timeout Undocumented
Instance Variable _renewal_attempt Undocumented
Instance Variable _renewal_future Undocumented
Instance Variable _retry_timeout_exponent Undocumented
Instance Variable _source Undocumented
Instance Variable _synchronous_can_proceed Undocumented
Instance Variable _tasks Undocumented
def __init__(self, source: ParentBearer, max_retries: int = 2, lifetime_safe_fraction: float = 0.9, initial_retry_timeout: timedelta = timedelta(seconds=1), max_retry_timeout: timedelta = timedelta(minutes=1), retry_timeout_exponent: float = 1.5, refresh_request_timeout: timedelta = timedelta(seconds=5)): (source)

Undocumented

def bg_task(self, coro: Awaitable[T]) -> Task[None]: (source)

Run a coroutine without awaiting or tracking, and log any exceptions.

async def close(self, grace: float | None = None): (source)

Undocumented

async def fetch(self, timeout: float | None = None, options: dict[str, str] | None = None) -> Token: (source)

Undocumented

def is_renewal_required(self) -> bool: (source)

Undocumented

def receiver(self) -> Receiver: (source)
overrides nebius.aio.token.token.Bearer.receiver

Undocumented

def request_renewal(self): (source)

Undocumented

def stop(self): (source)

Undocumented

async def _fetch_once(self) -> Token: (source)

Undocumented

async def _run(self): (source)

Undocumented

_break_previous_attempt = (source)

Undocumented

_cache: Token | None = (source)

Undocumented

_initial_retry_timeout = (source)

Undocumented

_is_fresh = (source)

Undocumented

_is_stopped = (source)

Undocumented

_lifetime_safe_fraction = (source)

Undocumented

_max_retries = (source)

Undocumented

_max_retry_timeout = (source)

Undocumented

_refresh_request_timeout = (source)

Undocumented

_refresh_task: Task[Any] | None = (source)

Undocumented

_renew_requested = (source)

Undocumented

_renew_synchronous_options: dict[str, str] | None = (source)

Undocumented

_renew_synchronous_timeout: float | None = (source)

Undocumented

_renewal_attempt: int = (source)

Undocumented

_renewal_future: Future[Token] | None = (source)

Undocumented

_retry_timeout_exponent = (source)

Undocumented

_source = (source)

Undocumented

_synchronous_can_proceed = (source)

Undocumented

_tasks = (source)

Undocumented