fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-04-25 06:42:16 +00:00
Code Issues Projects Releases Wiki Activity

whitespaces

Browse Source
This commit is contained in:
Jae Kwon 2014-06-05 18:03:02 -07:00
parent 805e1f51dd
commit d68f7a2262
2 changed files with 30 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
db/level_db.go
View File

@ -1,54 +1,54 @@
package db package db
import ( import (
"fmt" "fmt"
"github.com/syndtr/goleveldb/leveldb" "github.com/syndtr/goleveldb/leveldb"
"path" "path"
) )
type LevelDB struct { type LevelDB struct {
db *leveldb.DB db *leveldb.DB
} }
func NewLevelDB(name string) (*LevelDB, error) { func NewLevelDB(name string) (*LevelDB, error) {
dbPath := path.Join(name) dbPath := path.Join(name)
db, err := leveldb.OpenFile(dbPath, nil) db, err := leveldb.OpenFile(dbPath, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
database := &LevelDB{db: db} database := &LevelDB{db: db}
return database, nil return database, nil
} }
func (db *LevelDB) Put(key []byte, value []byte) { func (db *LevelDB) Put(key []byte, value []byte) {
err := db.db.Put(key, value, nil) err := db.db.Put(key, value, nil)
if err != nil { panic(err) } if err != nil { panic(err) }
} }
func (db *LevelDB) Get(key []byte) ([]byte) { func (db *LevelDB) Get(key []byte) ([]byte) {
res, err := db.db.Get(key, nil) res, err := db.db.Get(key, nil)
if err != nil { panic(err) } if err != nil { panic(err) }
return res return res
} }
func (db *LevelDB) Delete(key []byte) { func (db *LevelDB) Delete(key []byte) {
err := db.db.Delete(key, nil) err := db.db.Delete(key, nil)
if err != nil { panic(err) } if err != nil { panic(err) }
} }
func (db *LevelDB) Db() *leveldb.DB { func (db *LevelDB) Db() *leveldb.DB {
return db.db return db.db
} }
func (db *LevelDB) Close() { func (db *LevelDB) Close() {
db.db.Close() db.db.Close()
} }
func (db *LevelDB) Print() { func (db *LevelDB) Print() {
iter := db.db.NewIterator(nil, nil) iter := db.db.NewIterator(nil, nil)
for iter.Next() { for iter.Next() {
key := iter.Key() key := iter.Key()
value := iter.Value() value := iter.Value()
fmt.Printf("[%x]:\t[%x]", key, value) fmt.Printf("[%x]:\t[%x]", key, value)
} }
} }

14
db/mem_db.go
View File

@ -1,7 +1,7 @@
package db package db
import ( import (
"fmt" "fmt"
) )
type MemDB struct { type MemDB struct {
@ -9,8 +9,8 @@ type MemDB struct {
} }
func NewMemDB() (*MemDB) { func NewMemDB() (*MemDB) {
database := &MemDB{db:make(map[string][]byte)} database := &MemDB{db:make(map[string][]byte)}
return database return database
} }
func (db *MemDB) Put(key []byte, value []byte) { func (db *MemDB) Put(key []byte, value []byte) {
@ -22,11 +22,11 @@ func (db *MemDB) Get(key []byte) ([]byte) {
} }
func (db *MemDB) Delete(key []byte) { func (db *MemDB) Delete(key []byte) {
delete(db.db, string(key)) delete(db.db, string(key))
} }
func (db *MemDB) Print() { func (db *MemDB) Print() {
for key, value := range db.db { for key, value := range db.db {
fmt.Printf("[%x]:\t[%x]", []byte(key), value) fmt.Printf("[%x]:\t[%x]", []byte(key), value)
} }
} }