kubernetes.aio.utils.retry module

async kubernetes.aio.utils.retry.on_error(backoff: ~kubernetes.aio.utils._retry_base.Backoff, retriable: ~typing.Callable[[Exception], bool], fn: ~typing.Callable[[], ~typing.Awaitable[~kubernetes.aio.utils.retry.T]], sleep_func: ~typing.Callable[[float], ~typing.Awaitable[None]] = <function sleep>, random_func: ~typing.Callable[[], float] = <built-in method random of Random object>) → T

Async 1:1 implementation of client-go retry.OnError.

async kubernetes.aio.utils.retry.on_retry_after_error(backoff: ~kubernetes.aio.utils._retry_base.Backoff, retriable: ~typing.Callable[[Exception], bool], fn: ~typing.Callable[[], ~typing.Awaitable[~kubernetes.aio.utils.retry.T]], sleep_func: ~typing.Callable[[float], ~typing.Awaitable[None]] = <function sleep>, random_func: ~typing.Callable[[], float] = <built-in method random of Random object>) → T

Async implementation of client-go REST Retry-After sleep semantics.

async kubernetes.aio.utils.retry.retry_on_conflict(fn: ~typing.Callable[[], ~typing.Awaitable[~kubernetes.aio.utils.retry.T]], backoff: ~kubernetes.aio.utils._retry_base.Backoff = Backoff(steps=5, duration=0.01, factor=1.0, jitter=0.1, cap=0.0), sleep_func: ~typing.Callable[[float], ~typing.Awaitable[None]] = <function sleep>, random_func: ~typing.Callable[[], float] = <built-in method random of Random object>) → T

Async 1:1 implementation of client-go retry.RetryOnConflict.