@@ -12,8 +12,8 @@ import (
12
12
//数据的get set 主要经过 cache
13
13
//如果需要进行list, 那么把get set 的内容加入到 后端数据库
14
14
type LocalDB struct {
15
- cache * CacheDB
16
- txcache * CacheDB
15
+ cache * cacheDB
16
+ txcache * cacheDB
17
17
keys []string
18
18
intx bool
19
19
hasbegin bool
@@ -36,8 +36,8 @@ func NewLocalDB(cli queue.Client, readOnly bool) db.KVDB {
36
36
panic (err )
37
37
}
38
38
return & LocalDB {
39
- cache : NewCacheDB (),
40
- txcache : NewCacheDB (),
39
+ cache : newcacheDB (),
40
+ txcache : newcacheDB (),
41
41
txid : txid ,
42
42
client : cli ,
43
43
api : api ,
@@ -219,18 +219,18 @@ func (l *LocalDB) PrefixCount(prefix []byte) (count int64) {
219
219
panic ("localdb not support PrefixCount" )
220
220
}
221
221
222
- type CacheDB struct {
222
+ type cacheDB struct {
223
223
data map [string ][]byte
224
224
}
225
225
226
- func NewCacheDB () * CacheDB {
227
- return & CacheDB {
226
+ func newcacheDB () * cacheDB {
227
+ return & cacheDB {
228
228
data : make (map [string ][]byte , 1024 ),
229
229
}
230
230
}
231
231
232
232
//return a flag: is key is in cache
233
- func (db * CacheDB ) Get (key []byte ) (value []byte , incache bool , err error ) {
233
+ func (db * cacheDB ) Get (key []byte ) (value []byte , incache bool , err error ) {
234
234
if db .data == nil {
235
235
return nil , false , types .ErrNotFound
236
236
}
@@ -241,18 +241,18 @@ func (db *CacheDB) Get(key []byte) (value []byte, incache bool, err error) {
241
241
return nil , ok , types .ErrNotFound
242
242
}
243
243
244
- func (db * CacheDB ) Set (key []byte , value []byte ) {
244
+ func (db * cacheDB ) Set (key []byte , value []byte ) {
245
245
if db .data == nil {
246
246
db .data = make (map [string ][]byte , 1024 )
247
247
}
248
248
db .data [string (key )] = value
249
249
}
250
250
251
- func (db * CacheDB ) Reset () {
251
+ func (db * cacheDB ) Reset () {
252
252
db .data = nil
253
253
}
254
254
255
- func (db * CacheDB ) Merge (db2 * CacheDB ) {
255
+ func (db * cacheDB ) Merge (db2 * cacheDB ) {
256
256
for k , v := range db2 .data {
257
257
db .data [k ] = v
258
258
}
0 commit comments