nebius.aio.token.exchangeable.Receiver

class documentation

class Receiver(ParentReceiver): (source)

Constructor: Receiver(requester, service, max_retries)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method can_retry Undocumented
Async Method _fetch Undocumented
Method _raise_request_error Undocumented
Instance Variable _max_retries Undocumented
Instance Variable _requester Undocumented
Instance Variable _status Undocumented
Instance Variable _svc Undocumented
Instance Variable _trial Undocumented

Inherited from Receiver:

Async Method fetch Undocumented
Property latest Undocumented
Instance Variable _latest Undocumented
def __init__(self, requester: TokenRequester, service: TokenExchangeServiceStub, max_retries: int = 2): (source)

Undocumented

def can_retry(self, err: Exception, options: dict[str, str] | None = None) -> bool: (source)
overrides nebius.aio.token.token.Receiver.can_retry

Undocumented

async def _fetch(self, timeout: float | None = None, options: dict[str, str] | None = None) -> Token: (source)
overrides nebius.aio.token.token.Receiver._fetch

Undocumented

def _raise_request_error(self, err: AioRpcError): (source)

Undocumented

_max_retries = (source)

Undocumented

_requester = (source)

Undocumented

_status = (source)

Undocumented

_svc = (source)

Undocumented

_trial: int = (source)

Undocumented