Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 Changes in this version + var GenWithResultLastKey = ScanStartKeyPolicy(1) + var None = ScanStartKeyPolicy(0) + var UseShardEnd = ScanStartKeyPolicy(2) + type DataStorageScanner interface + Scan func(shard meta.Shard, handler func(key, value []byte) error, options ...ScanOption) (completed bool, nextKeyPolicy ScanStartKeyPolicy, err error) + func NewKVBasedDataStorageScanner(kv storage.KVStorage) DataStorageScanner + type ScanOption func(*scanOptions) + func WithScanBuffer(buffer *buf.ByteBuf) ScanOption + func WithScanBytesLimit(value uint64) ScanOption + func WithScanCountLimit(value uint64) ScanOption + func WithScanEndKey(endKey []byte) ScanOption + func WithScanFilterFunc(filterFunc func([]byte) bool) ScanOption + func WithScanStartKey(startKey []byte) ScanOption + func WithValue() ScanOption + type ScanStartKeyPolicy int v0.2.0 Jan 5, 2022