| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- from lakesuperior.cy_include cimport cylmdb as lmdb
- ctypedef char DbLabel[8]
- cdef:
- int rc
- size_t i
- lmdb.MDB_val key_v, data_v
- lmdb.MDB_dbi dbi
- void _check(int rc, str message=*) except *
- cdef class BaseLmdbStore:
- cdef:
- readonly bint is_txn_open
- readonly bint is_txn_rw
- public bint _open
- unsigned int _readers
- readonly str env_path
- lmdb.MDB_dbi *dbis
- lmdb.MDB_env *dbenv
- lmdb.MDB_txn *txn
- lmdb.MDB_cursor **curs
- void _clear_stale_readers(self) except *
- void _cur_close(self, lmdb.MDB_cursor *cur) except *
- void _init_dbis(self, create=*) except *
- void _txn_begin(self, write=*, lmdb.MDB_txn *parent=*) except *
- void _txn_commit(self) except *
- void _txn_abort(self) except *
- inline bint _key_exists(
- self, unsigned char *key, unsigned char klen, DbLabel dblabel=*
- ) except -1
- size_t _txn_id(self) except -1
- lmdb.MDB_cursor *_cur_open(
- self, DbLabel dblabel=*, lmdb.MDB_txn *txn=*
- ) except *
- lmdb.MDB_dbi get_dbi(
- self, DbLabel dblabel=*, lmdb.MDB_txn *txn=*)
- void _put(
- self, unsigned char *key, size_t key_size, unsigned char *data,
- size_t data_size, DbLabel dblabel=*,
- lmdb.MDB_txn *txn=*, unsigned int flags=*) except *
- void _get_data(
- self, unsigned char *key, size_t klen, lmdb.MDB_val *rv,
- DbLabel dblabel=*) except *
- void _delete(
- self, unsigned char *key, size_t klen,
- DbLabel dblabel=*) except *
- dict _stats(self)
- #int _reader_list_callback(self, const unsigned char *msg, void *str_)
- cpdef void close_env(self, bint commit_pending_transaction=*) except *
- cpdef void destroy(self, _path=*) except *
- #cpdef get_dup_data(self, unsigned char *key, db=*)
- #cpdef get_all_pairs(self, db=*)
- cpdef bytes get_data(self, key, DbLabel dblabel=*)
- cpdef dict stats(self)
- cpdef int txn_id(self)
- #cpdef str reader_list(self)
|
