pending

package
v0.0.0-...-9753c4d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Item

type Item interface {
	Key() []byte
	KeyCopy(dst []byte) []byte
	Value(fn func(val []byte) error) error
	IsDeletedOrExpired() bool
	ExpiresAt() uint64
	Version() uint64
}

type IterableMergedWrites

type IterableMergedWrites interface {
	Writes
	MergedIterator(tx *badger.Txn, readTs uint64, opt badger.IteratorOptions) Iterator
}

func New

func New(path string, maxCount, maxSize int64, threshold int, addReadKey func(key []byte)) IterableMergedWrites

func NewWithDB

func NewWithDB(db *badger.DB, addReadKey func(key []byte)) IterableMergedWrites

type Iterator

type Iterator interface {
	Rewind()
	Next()
	Valid() bool
	Seek(key []byte)
	Key() []byte
	Item() Item
	Close()
}

func TxIterator

func TxIterator(i *badger.Iterator, addReadKey func(key []byte)) Iterator

type Writes

type Writes interface {
	Iterator(prefix []byte, readTs uint64, reversed bool) Iterator
	Set(e *badger.Entry)
	Delete(key []byte)
	Replay(fn func(e *badger.Entry) error) error
	Close() error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL