nebius.aio.token.file_cache.async_renewable_bearer.AsynchronousRenewableFileCacheBearer

class documentation

class AsynchronousRenewableFileCacheBearer(ParentBearer): (source)

Constructor: AsynchronousRenewableFileCacheBearer(source, max_retries, initial_safety_margin, retry_safety_margin, ...)

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
Instance Variable safety_margin Undocumented
Property wrapped Return the wrapped bearer.
Async Method _fetch_once Undocumented
Async Method _run Undocumented
Instance Variable _break_previous_attempt Undocumented
Instance Variable _file_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_safety_margin Undocumented
Instance Variable _retry_timeout_exponent Undocumented
Instance Variable _source Undocumented
Instance Variable _synchronous_can_proceed Undocumented
Instance Variable _tasks Undocumented

Inherited from Bearer:

Property name Undocumented
def __init__(self, source: ParentBearer, max_retries: int = 2, initial_safety_margin: timedelta | float | None = timedelta(hours=2), retry_safety_margin: timedelta = timedelta(hours=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), file_cache_throttle: timedelta | float = timedelta(minutes=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)
overrides nebius.aio.token.token.Bearer.close

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) -> AsynchronousRenewableFileCacheReceiver: (source)
overrides nebius.aio.token.token.Bearer.receiver

Undocumented

def request_renewal(self): (source)

Undocumented

def stop(self): (source)

Undocumented

safety_margin = (source)

Undocumented

wrapped: ParentBearer | None = (source)
overrides nebius.aio.token.token.Bearer.wrapped

Return the wrapped bearer.

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

Undocumented

async def _run(self, wait_for_timeout: bool = False): (source)

Undocumented

_break_previous_attempt = (source)

Undocumented

_file_cache = (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_safety_margin = (source)

Undocumented

_retry_timeout_exponent = (source)

Undocumented

_source = (source)

Undocumented

_synchronous_can_proceed = (source)

Undocumented

_tasks = (source)

Undocumented