summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKristofer Hallin <kristofer@sunet.se>2021-10-01 10:34:15 +0200
committerKristofer Hallin <kristofer@sunet.se>2021-10-01 10:34:15 +0200
commit08305c52909fe5edc305ae7bd73d51a33ba5537b (patch)
tree95119534efdf5fd2a38d08e8c876a6c1d45fa57c
parentcd9296707ea547a2a9d9fce6429b8b777311826c (diff)
Removed store.py, not used any more.
-rwxr-xr-xsrc/store.py62
1 files changed, 0 insertions, 62 deletions
diff --git a/src/store.py b/src/store.py
deleted file mode 100755
index bc2c4ff..0000000
--- a/src/store.py
+++ /dev/null
@@ -1,62 +0,0 @@
-#! /usr/bin/env python3
-
-from leveldb import LevelDB, WriteBatch
-import time
-from pathlib import PurePath
-import os
-
-class KVStore:
- """Wraps a Python wrapper for LevelDB in case we want to change wrapper
- """
- def __init__(self, name, basedir='.'):
- os.makedirs(basedir, exist_ok = True)
- path = str(PurePath(basedir).joinpath(name))
- self._db = LevelDB(path)
-
- def get(self, key):
- try:
- val = self._db.Get(key)
- except KeyError:
- val = None # You can thus not store None!
- return val
-
- def put(self, key, val):
- self._db.Put(key, val)
-
- def delete(self, key):
- self._db.Delete(key)
-
- def range_iter(self, key_from=None, key_to=None):
- return self._db.RangeIter(key_from=key_from, key_to=key_to)
-
- def batch(self):
- return WriteBatch()
-
- def write(self, batch):
- self._db.Write(batch, sync=True)
-
- def timestamp_asc():
- return str(time.time()).encode('ascii')
-
-
-def test_store(name):
- # TODO: rm -r name
- db = KVStore(name)
-
- ts0 = KVStore.timestamp_asc()
- db.put(ts0, b'Bar')
- assert(db.get(ts0) == b'Bar')
-
- ts1 = KVStore.timestamp_asc()
- db.put(ts1, b'Foo')
- assert(db.get(ts1) == b'Foo')
-
- assert(list(db.range_iter()) == [(ts0, b'Bar'), (ts1, b'Foo')])
-
- db.delete(ts0)
- assert(db.get(ts0) is None)
-
- return db
-
-if __name__ == '__main__':
- test_store('test_store.db')