Method flush

aleph/cache.py:66–76

(self, prefix=None)

        return self.kv.lock(key, timeout=timeout)

    def flush(self, prefix=None):
        prefix = prefix or self.prefix
        keys = []
        for key in self.kv.scan_iter(match="%s*" % prefix):
            log.info("Flush: %s", key)
            keys.append(key)
            if len(keys) > 0 and len(keys) % 1000 == 0:
                self.kv.unlink(*keys)
                keys = []
        if len(keys) > 0:
            self.kv.unlink(*keys)