zapdb

Jul 31, 2026

Changes in this version

type Database

+ func (d *Database) DropPrefix(prefixes ...[]byte) error

+ func (d *Database) GetSequence(key []byte, bandwidth uint64) (database.Sequence, error)

May 18, 2026

Changes in this version

type Database

+ func (d *Database) PutWithTTL(key, value []byte, ttl time.Duration) error

+ func (d *Database) Update(fn func(txn database.Txn) error) error

+ func (d *Database) View(fn func(txn database.Txn) error) error

Apr 10, 2026

Changes in this version

type Database

+ func (d *Database) StartReplicator(ctx context.Context) error

+ type GPUCacheConfig struct

+ Backend string

+ DeviceIndex int

+ EvictionThreshold float32

+ GPUMemoryBudget uint64

+ InitialCapacity uint32

+ MaxKeySize uint32

+ MaxValueSize uint32

+ PromoteOnMiss bool

+ WriteThrough bool

+ func DefaultGPUCacheConfig() GPUCacheConfig

+ func ParseGPUConfig(configBytes []byte) GPUCacheConfig

+ func (c *GPUCacheConfig) Enabled() bool

Apr 9, 2026

Changes in this version

+ const Name

+ type Config struct

+ BlockCacheSize int64

+ BloomFalsePositive float64

+ Compression string

+ IndexCacheSize int64

+ MemTableSize int64

+ NumCompactors int

+ NumMemtables int

+ SyncWrites bool

+ ValueLogFileSize int64

+ ValueLogMaxEntries uint32

+ ValueThreshold int

+ ZSTDCompressionLevel int

+ type Database struct

+ func New(file string, configBytes []byte, namespace string, metrics metric.Registerer) (*Database, error)

+ func NewWithGPU(file string, configBytes []byte, namespace string, metrics metric.Registerer, ...) (*Database, error)

+ func (d *Database) Backup(w io.Writer, since uint64) (uint64, error)

+ func (d *Database) Close() error

+ func (d *Database) Compact(start []byte, limit []byte) error

+ func (d *Database) Delete(key []byte) error

+ func (d *Database) Empty() (bool, error)

+ func (d *Database) FlushGPUCache() error

+ func (d *Database) GPUCacheEnabled() bool

+ func (d *Database) GPUCacheStats() *gpuCacheStats

+ func (d *Database) Get(key []byte) ([]byte, error)

+ func (d *Database) GetSnapshot() (database.Database, error)

+ func (d *Database) Has(key []byte) (bool, error)

+ func (d *Database) HealthCheck(ctx context.Context) (interface{}, error)

+ func (d *Database) InvalidateGPUCache()

+ func (d *Database) Len() (int, error)

+ func (d *Database) Load(r io.Reader) error

+ func (d *Database) NewBatch() database.Batch

+ func (d *Database) NewIterator() database.Iterator

+ func (d *Database) NewIteratorWithPrefix(prefix []byte) database.Iterator

+ func (d *Database) NewIteratorWithStart(start []byte) database.Iterator

+ func (d *Database) NewIteratorWithStartAndPrefix(start, prefix []byte) database.Iterator

+ func (d *Database) Put(key []byte, value []byte) error

+ func (d *Database) Sync() error