From 2928bfdfc48c817f1e6d4a5e3ab7b1a719939f0b Mon Sep 17 00:00:00 2001 From: Nick Johnson Date: Wed, 11 Jan 2017 09:32:41 +0000 Subject: [PATCH] ethdb: Add NewTableBatch; rename Table to table --- ethdb/database.go | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/ethdb/database.go b/ethdb/database.go index 4a6cf4a280..5516a54df0 100644 --- a/ethdb/database.go +++ b/ethdb/database.go @@ -306,31 +306,31 @@ func (b *ldbBatch) Write() error { return b.db.Write(b.b, nil) } -type Table struct { +type table struct { db Database prefix string } -func NewTable(db Database, prefix string) *Table { - return &Table{ +func NewTable(db Database, prefix string) *table { + return &table{ db: db, prefix: prefix, } } -func (dt *Table) Put(key []byte, value []byte) error { +func (dt *table) Put(key []byte, value []byte) error { return dt.db.Put(append([]byte(dt.prefix), key...), value) } -func (dt *Table) Get(key []byte) ([]byte, error) { +func (dt *table) Get(key []byte) ([]byte, error) { return dt.db.Get(append([]byte(dt.prefix), key...)) } -func (dt *Table) Delete(key []byte) error { +func (dt *table) Delete(key []byte) error { return dt.db.Delete(append([]byte(dt.prefix), key...)) } -func (dt *Table) Close() { +func (dt *table) Close() { // Do nothing; don't close the underlying DB. } @@ -339,7 +339,11 @@ type tableBatch struct { prefix string } -func (dt *Table) NewBatch() Batch { +func NewTableBatch(db Database, prefix string) *tableBatch { + return &tableBatch{db.NewBatch(), prefix} +} + +func (dt *table) NewBatch() Batch { return &tableBatch{dt.db.NewBatch(), dt.prefix} }