-
Notifications
You must be signed in to change notification settings - Fork 211
/
memory_database_iterator.go
90 lines (73 loc) · 1.72 KB
/
memory_database_iterator.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
package database
import (
"reflect"
)
// MemDatabaseIterator is an iterator for memory database
type MemDatabaseIterator struct {
keys [][]byte
db map[string][]byte
index int
}
// Key returns the key of the current item iterator is pointing at
func (iter *MemDatabaseIterator) Key() []byte {
return iter.keys[iter.index]
}
// Value returns the value of the current item iterator is pointing at
func (iter *MemDatabaseIterator) Value() []byte {
key := iter.keys[iter.index]
return iter.db[string(key)]
}
// Next advances iterator to next item
func (iter *MemDatabaseIterator) Next() bool {
if iter.index == len(iter.keys)-1 {
return false
}
iter.index++
return true
}
// First moves the iterator to first object
func (iter *MemDatabaseIterator) First() bool {
if len(iter.db) == 0 {
iter.index = -1
return false
}
iter.index = 0
return true
}
// Last moves the iterator to last object
func (iter *MemDatabaseIterator) Last() bool {
size := len(iter.keys)
if size == 0 {
iter.index = 0
return false
}
iter.index = size - 1
return true
}
// Prev moves the iterator one item back
func (iter *MemDatabaseIterator) Prev() bool {
iter.index--
if iter.index < 0 {
iter.index = -1
return false
}
return true
}
// Seek returns true if key is found in iterator object
func (iter *MemDatabaseIterator) Seek(key []byte) bool {
size := len(iter.keys)
if size == 0 {
iter.index = 0
return false
}
for k := range iter.db {
if reflect.DeepEqual(k, key) {
return true
}
}
return false
}
// Release is a stub to comply with DB interface
func (iter *MemDatabaseIterator) Release() { return }
// Error is a stub to comply with DB interface
func (iter *MemDatabaseIterator) Error() error { return nil }