mirror of https://github.com/ledisdb/ledisdb.git
36 lines
678 B
Go
36 lines
678 B
Go
|
// +build hyperleveldb
|
||
|
|
|
||
|
|
package hyperleveldb
|
||
|
|
|
||
|
|
// #cgo LDFLAGS: -lhyperleveldb
|
||
|
|
// #include "hyperleveldb/c.h"
|
||
|
|
import "C"
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/siddontang/ledisdb/store/driver"
|
||
|
|
)
|
||
|
|
|
||
|
|
type Snapshot struct {
|
||
|
|
db *DB
|
||
|
|
snap *C.leveldb_snapshot_t
|
||
|
|
readOpts *ReadOptions
|
||
|
|
iteratorOpts *ReadOptions
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Snapshot) Get(key []byte) ([]byte, error) {
|
||
|
|
return s.db.get(s.readOpts, key)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Snapshot) NewIterator() driver.IIterator {
|
||
|
|
it := new(Iterator)
|
||
|
|
it.it = C.leveldb_create_iterator(s.db.db, s.db.iteratorOpts.Opt)
|
||
|
|
return it
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Snapshot) Close() {
|
||
|
|
C.leveldb_release_snapshot(s.db.db, s.snap)
|
||
|
|
s.iteratorOpts.Close()
|
||
|
|
s.readOpts.Close()
|
||
|
|
}
|