remote

package

v0.15.16 Latest Latest Go to latest Published: Dec 9, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(rawURL string, ctx context.Context, log utils.SimpleLogger, opts ...grpc.DialOption) (*DB, error)

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(start []byte, withUpperBound bool) (db.Iterator, error)

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

func (d *DB) NewTransaction(write bool) (*transaction, error)

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

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

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

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