mirror of
https://github.com/gogrlx/bitcask.git
synced 2026-04-04 20:12:45 -07:00
Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
67840ffb57 | ||
|
|
9f0a357ca0 |
@@ -34,6 +34,7 @@ type Bitcask struct {
|
||||
func (b *Bitcask) Close() error {
|
||||
defer func() {
|
||||
b.Flock.Unlock()
|
||||
os.Remove(b.Flock.Path())
|
||||
}()
|
||||
|
||||
for _, df := range b.datafiles {
|
||||
|
||||
@@ -35,6 +35,7 @@ func del(path, key string) int {
|
||||
log.WithError(err).Error("error opening database")
|
||||
return 1
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
err = db.Delete(key)
|
||||
if err != nil {
|
||||
|
||||
@@ -36,6 +36,7 @@ func get(path, key string) int {
|
||||
log.WithError(err).Error("error opening database")
|
||||
return 1
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
value, err := db.Get(key)
|
||||
if err != nil {
|
||||
|
||||
@@ -34,6 +34,7 @@ func keys(path string) int {
|
||||
log.WithError(err).Error("error opening database")
|
||||
return 1
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
err = db.Fold(func(key string) error {
|
||||
fmt.Printf("%s\n", key)
|
||||
|
||||
@@ -47,6 +47,7 @@ func set(path, key string, value io.Reader) int {
|
||||
log.WithError(err).Error("error opening database")
|
||||
return 1
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
data, err := ioutil.ReadAll(value)
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user