Rate Limiter public methods.py

    def log(self, client_id: str, resource_id: str) -> bool:
        lock_name = self._get_lock_name(client_id, resource_id)
        with self._con_pool.lock(name=lock_name, timeout=self._lock_timeout):
            if self.is_allowed(client_id, resource_id):
                log_name = self._generate_log_name(client_id, resource_id)
                self._con_pool.setex(
                    name=log_name,
                    time=self._time_bound,
                    value=self._log_value
                )
                return True
        return False

    def is_allowed(self, client_id: str, resource_id: str) -> bool:
        num_logs = self.count_logs(client_id, resource_id)
        return num_logs <= self._number_of_requests

    def count_logs(self, client_id: str, resource_id: str) -> int:
        log_pattern = self._get_log_pattern(client_id, resource_id)
        return len(self._con_pool.keys(log_pattern))

    def flush_logs(self, client_id: str, resource_id: str) -> None:
        log_pattern = self._get_log_pattern(client_id, resource_id)
        self._con_pool.delete(log_pattern)