mirror of
https://github.com/nxshock/zkv.git
synced 2024-11-27 11:21:02 +05:00
2.0 KiB
2.0 KiB
zkv
Simple key-value store for single-user applications.
Pros
- Simple one file structure
- Internal Zstandard compression by klauspost/compress/zstd
- Threadsafe operations through
sync.RWMutex
Cons
- Index stored in memory (
map[key hash (28 bytes)]file offset (int64)
) - average 200-250 Mb of RAM per 1M keys - Need to read the whole file on store open to create file index (you can use index file options to avoid this)
- No way to recover disk space from deleted records
- Write/Delete operations block Read and each other operations
Usage
Create or open existing file:
db, err := zkv.Open("path to file")
Data operations:
// Write data
err = db.Set(key, value) // key and value can be any of type
// Read data
var value ValueType
err = db.Get(key, &value)
// Delete data
err = db.Delete(key)
Other methods:
// Flush data to disk
err = db.Flush()
// Backup data to another file
err = db.Backup("new/file/path")
Store options
type Options struct {
// Maximum number of concurrent reads
MaxParallelReads int
// Compression level
CompressionLevel zstd.EncoderLevel
// Memory write buffer size in bytes
MemoryBufferSize int
// Disk write buffer size in bytes
DiskBufferSize int
// Use index file
UseIndexFile bool
}
File structure
Record is encoding/gob
structure:
Field | Description | Size |
---|---|---|
Type | Record type | uint8 |
KeyHash | Key hash | 28 bytes |
ValueBytes | Value gob-encoded bytes | variable |
File is log stuctured list of commands:
Field | Description | Size |
---|---|---|
Length | Record body bytes length | int64 |
Body | Gob-encoded record | variable |
TODO
- Add recovery previous state of store file on write error