pebblev2

package

v0.15.13 Latest Latest Go to latest Published: Nov 28, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrDiscardedTransaction = errors.New("discarded transaction")
	ErrReadOnlyTransaction  = errors.New("read-only transaction")
)

func New(path string, options ...Option) (db.KeyValueStore, error)

New opens a new database at the given path with default options

func NewBatch(dbBatch *pebble.Batch, db *DB, listener db.EventListener) *batch

func NewSnapshot(db *pebble.DB, listener db.EventListener) *snapshot

type DB struct {
	// contains filtered or unexported fields
}

func (d *DB) Close() error

func (d *DB) Delete(key []byte) error

func (d *DB) DeleteRange(start, end []byte) error

func (d *DB) Get(key []byte, cb func(value []byte) error) error

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

func (d *DB) Impl() any

func (d *DB) NewBatch() db.Batch

func (d *DB) NewBatchWithSize(size int) db.Batch

func (d *DB) NewIndexedBatch() db.IndexedBatch

func (d *DB) NewIndexedBatchWithSize(size int) db.IndexedBatch

func (d *DB) NewIterator(prefix []byte, withUpperBound bool) (db.Iterator, error)

func (d *DB) NewSnapshot() db.Snapshot

func (d *DB) Put(key, val []byte) error

func (d *DB) Update(fn func(w db.IndexedBatch) error) error

func (d *DB) View(fn func(r db.Snapshot) error) error

func (d *DB) WithListener(listener db.EventListener) db.KeyValueStore

type Item struct {
	Count uint
	Size  utils.DataSize
}

func CalculatePrefixSize(ctx context.Context, pDB *DB, prefix []byte, withUpperBound bool) (*Item, error)

type Option = func(*pebble.Options) error

func WithCacheSize(cacheSizeMB uint) Option

func WithCompression(compression *block.CompressionProfile) Option

func WithLogger(colouredLogger bool) Option

func WithMaxOpenFiles(maxOpenFiles int) Option