dbreader

package

v0.0.0-...-0ebafaf Latest Latest Go to latest Published: Mar 4, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/fzhedu/unistore

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewIterator(txn *badger.Txn, reverse bool, startKey, endKey []byte) *badger.Iterator
type BatchGetFunc
type DBReader
- func NewDBReader(startKey, endKey []byte, txn *badger.Txn) *DBReader
type ScanFunc
type ScanProcessor

Constants ¶

This section is empty.

Variables ¶

View Source

var ScanBreak = errors.New("scan break")

ScanBreak is returnd by ScanFunc to break the scan loop.

Functions ¶

func NewIterator ¶

func NewIterator(txn *badger.Txn, reverse bool, startKey, endKey []byte) *badger.Iterator

Types ¶

type BatchGetFunc ¶

type BatchGetFunc = func(key, value []byte, err error)

type DBReader ¶

type DBReader struct {
	StartKey []byte
	EndKey   []byte
	// contains filtered or unexported fields
}

DBReader reads data from DB, for read-only requests, the locks must already be checked before DBReader is created.

func NewDBReader ¶

func NewDBReader(startKey, endKey []byte, txn *badger.Txn) *DBReader

func (*DBReader) BatchGet ¶

func (r *DBReader) BatchGet(keys [][]byte, startTS uint64, f BatchGetFunc)

func (*DBReader) Close ¶

func (r *DBReader) Close()

func (*DBReader) Get ¶

func (r *DBReader) Get(key []byte, startTS uint64) ([]byte, error)

func (*DBReader) GetExtraIter ¶

func (r *DBReader) GetExtraIter() *badger.Iterator

func (*DBReader) GetIter ¶

func (r *DBReader) GetIter() *badger.Iterator

func (*DBReader) GetKeyByStartTs ¶

func (r *DBReader) GetKeyByStartTs(startKey, endKey []byte, startTs uint64) ([]byte, error)

func (*DBReader) GetMvccInfoByKey ¶

func (r *DBReader) GetMvccInfoByKey(key []byte, isRowKey bool, mvccInfo *kvrpcpb.MvccInfo) error

GetMvccInfoByKey fills MvccInfo reading committed keys from db

func (*DBReader) GetTxn ¶

func (r *DBReader) GetTxn() *badger.Txn

func (*DBReader) ReverseScan ¶

func (r *DBReader) ReverseScan(startKey, endKey []byte, limit int, startTS uint64, proc ScanProcessor) error

ReverseScan implements the MVCCStore interface. The search range is [startKey, endKey).

func (*DBReader) Scan ¶

func (r *DBReader) Scan(startKey, endKey []byte, limit int, startTS uint64, proc ScanProcessor) error

type ScanFunc ¶

type ScanFunc = func(key, value []byte) error

ScanFunc accepts key and value, should not keep reference to them. Returns ScanBreak will break the scan loop.

type ScanProcessor ¶

type ScanProcessor interface {
	// Process accepts key and value, should not keep reference to them.
	// Returns ScanBreak will break the scan loop.
	Process(key, value []byte) error
	// SkipValue returns if we can skip the value.
	SkipValue() bool
}

ScanProcessor process the key/value pair.

Source Files ¶

View all Source files

db_reader.go

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