dQj JddlZddlmZddlmZmZmZedGddZedd d d Zed d dd Z edddd Z ddedeedefdZ d dede fdZ dedefdZdedefdZdedefdZdedeefdZde dededegefdeeee ff dZy)!N) dataclass)AnyCallableOptionalT)frozencReZdZUdZeed<eed<eed<dZeed<dZeed<dZ y ) BackoffaRetry backoff parameters. This maps 1:1 to ``k8s.io/apimachinery/pkg/util/wait.Backoff`` for the fields used by client-go retry helpers. ``steps`` is the maximum number of times the operation is called, including the first call. ``duration`` is the first delay in seconds, ``factor`` is multiplied into the next delay after every failed attempt, and ``jitter`` adds up to that fraction of the current delay. ``cap`` limits increased delay values. stepsdurationfactorjittercapc|jdkr td|jdkr td|jdkr td|jdkr td|j dkr tdy)Nzsteps must be at least 1rzduration must be non-negativezfactor must be non-negativezjitter must be non-negativezcap must be non-negative)r ValueErrorr r rr)selfs e/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/kubernetes/aio/utils/_retry_base.py __post_init__zBackoff.__post_init__-s{ ::>78 8 ==1 <= = ;;?:; ; ;;?:; ; 88a<78 8 N) __name__ __module__ __qualname____doc__int__annotations__floatrrrrrr r s1 JO MFEC 9rr g{Gz?g@g?)r r r rg? r retriesbackoffreturnc|t}||Stt|dz|j|j|j |j S)aReturn the client-go REST Retry-After backoff for ``retries``. ``backoff`` supplies the retry delay parameters. If ``retries`` is not ``None``, it is interpreted as the retry ceiling and overrides ``backoff.steps``. ``False`` and ``0`` disable retries by returning a single-attempt backoff. Integer values and urllib3-style Retry objects with a ``total`` value are treated as retry ceilings. aiohttp-retry-style options with an ``attempts`` value are treated as request attempt ceilings. r)r r r rr)DEFAULT_RETRY_AFTER_BACKOFFr retry_after_max_retriesr r rr)r"r#s rretry_after_backoffr(FsP- %g.2!!~~~~ KK  rcD|y|dury|duryt|tr td|St|dr5t |dd}|dury|dus|yt|tr td|St |dd}|dury|duryt|trtd|dz Sy) z4Return the client-go REST Retry-After retry ceiling.N FrTtotalattemptsr) isinstancermaxhasattrgetattr)r"r+r,s rr'r'bs%$'31gw $/ E> D=EM eS !q%= w D1H54(C 1hl## rerrorc"t|dddk(S)zBReturn True if ``error`` represents an HTTP 409 Conflict response.statusNir0r1s r is_conflictr6 5(D )S 00rc"t|dddk(S)z?Return True if ``error`` represents HTTP 429 Too Many Requests.r3Nr4r5s ris_too_many_requestsr:r7rcPt|dd}|dk7r||dkryt|duS)z=Return True if ``error`` should be retried after Retry-After.r3Nr9iF)r0retry_after_seconds)r1r3s ris_retry_after_responser=s6UHd +F }&.FSL u %T 11rct|ddxsi}d}|jD]\}}|jdk(s|}n|yt|j }t j d|sytt|S)zReturn the Retry-After delay in seconds, if ``error`` provides one. client-go accepts integer seconds. Invalid, missing, or negative values return ``None`` so callers can fall back to their normal backoff. headersNz retry-afterz^[0-9]+$) r0itemslowerstrstriprematchrr)r1r?valuekey header_values rr<r<seY-3G E$]]_\ 99;- ' E  } J   E 88K ' U rr r random_funcc|dz}|jdk(r|}n;||jz}|jdkDr||jkDr|j}d}|}|jr|||jz|zz }|||fS)Nrr)r rr)r r r#rI next_durationdelays r_delayrMs  QJE~~  7>>1 ;;?}w{{:#KKME E~~ /%77 - &&r)NN)N)rD dataclassesrtypingrrrr DEFAULT_BACKOFF DEFAULT_RETRYr&r(rr' Exceptionboolr6r:r=rr<tuplerMrrrrUsB !** $999>DSIa$s3G & s3s4 !%  g  8SC>1y1T1 1 1d1 2922yXe_,' '''"e)$ '  5%  'r