mirror
/
ledisdb
mirror of https://github.com/ledisdb/ledisdb.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

add inclusive flag for scan

This commit is contained in:
siddontang 2014-05-23 13:06:44 +08:00
parent f404e35142
commit 8038a54cdb
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ledis/t_kv.go
View File

@ -289,7 +289,8 @@ func (db *DB) KvFlush() (drop int64, err error) {
return return
} }
func (db *DB) Scan(key []byte, count int) ([]KVPair, error) { //if inclusive is true, scan range [key, inf) else (key, inf)
func (db *DB) Scan(key []byte, count int, inclusive bool) ([]KVPair, error) {
var minKey []byte var minKey []byte
if key != nil { if key != nil {
if err := checkKeySize(key); err != nil { if err := checkKeySize(key); err != nil {
@ -308,7 +309,12 @@ func (db *DB) Scan(key []byte, count int) ([]KVPair, error) {
v := make([]KVPair, 0, 2*count) v := make([]KVPair, 0, 2*count)
it := db.db.Iterator(minKey, maxKey, leveldb.RangeROpen, 0, count) rangeType := leveldb.RangeROpen
if !inclusive {
rangeType = leveldb.RangeOpen
}
it := db.db.Iterator(minKey, maxKey, rangeType, 0, count)
for ; it.Valid(); it.Next() { for ; it.Valid(); it.Next() {
if key, err := db.decodeKVKey(it.Key()); err != nil { if key, err := db.decodeKVKey(it.Key()); err != nil {
continue continue