PATH: //usr/lib/python3.9/site-packages/redis
FILE_BARU
CREATE
FOLDER_BARU
MKDIR
UPLOAD_FILE
GO
[ .. KEMBALI ]
📄 __init__.py
↓
X
📁 __pycache__/
X
📁 asyncio/
X
📄 backoff.py
↓
X
📄 client.py
↓
X
📄 cluster.py
↓
X
📁 commands/
X
📄 compat.py
↓
X
📄 connection.py
↓
X
📄 crc.py
↓
X
📄 exceptions.py
↓
X
📄 lock.py
↓
X
📄 ocsp.py
↓
X
📄 retry.py
↓
X
📄 sentinel.py
↓
X
📄 typing.py
↓
X
📄 utils.py
↓
X
SAVING...
BERHASIL DIUBAH!
EDITING: backoff.py
import random from abc import ABC, abstractmethod class AbstractBackoff(ABC): """Backoff interface""" def reset(self): """ Reset internal state before an operation. `reset` is called once at the beginning of every call to `Retry.call_with_retry` """ pass @abstractmethod def compute(self, failures): """Compute backoff in seconds upon failure""" pass class ConstantBackoff(AbstractBackoff): """Constant backoff upon failure""" def __init__(self, backoff): """`backoff`: backoff time in seconds""" self._backoff = backoff def compute(self, failures): return self._backoff class NoBackoff(ConstantBackoff): """No backoff upon failure""" def __init__(self): super().__init__(0) class ExponentialBackoff(AbstractBackoff): """Exponential backoff upon failure""" def __init__(self, cap, base): """ `cap`: maximum backoff time in seconds `base`: base backoff time in seconds """ self._cap = cap self._base = base def compute(self, failures): return min(self._cap, self._base * 2**failures) class FullJitterBackoff(AbstractBackoff): """Full jitter backoff upon failure""" def __init__(self, cap, base): """ `cap`: maximum backoff time in seconds `base`: base backoff time in seconds """ self._cap = cap self._base = base def compute(self, failures): return random.uniform(0, min(self._cap, self._base * 2**failures)) class EqualJitterBackoff(AbstractBackoff): """Equal jitter backoff upon failure""" def __init__(self, cap, base): """ `cap`: maximum backoff time in seconds `base`: base backoff time in seconds """ self._cap = cap self._base = base def compute(self, failures): temp = min(self._cap, self._base * 2**failures) / 2 return temp + random.uniform(0, temp) class DecorrelatedJitterBackoff(AbstractBackoff): """Decorrelated jitter backoff upon failure""" def __init__(self, cap, base): """ `cap`: maximum backoff time in seconds `base`: base backoff time in seconds """ self._cap = cap self._base = base self._previous_backoff = 0 def reset(self): self._previous_backoff = 0 def compute(self, failures): max_backoff = max(self._base, self._previous_backoff * 3) temp = random.uniform(self._base, max_backoff) self._previous_backoff = min(self._cap, temp) return self._previous_backoff
SIMPAN PERUBAHAN