removed commented code and unused functions
This commit is contained in:
parent
4c6bc23043
commit
f0ee9a3c66
@ -32,22 +32,6 @@ func (b *Batch) Merge(key, val []byte) {
|
||||
b.merge.Merge(key, val)
|
||||
}
|
||||
|
||||
// func (b *Batch) Execute() error {
|
||||
|
||||
// // first process merges
|
||||
// ops, err := b.merge.ExecuteDeferred(b.w)
|
||||
// if err != nil {
|
||||
// return err
|
||||
// }
|
||||
// for _, op := range ops {
|
||||
// b.batch.Put(op.K, op.V)
|
||||
// }
|
||||
|
||||
// wopts := defaultWriteOptions()
|
||||
// err = b.w.store.db.Write(b.batch, wopts)
|
||||
// return err
|
||||
// }
|
||||
|
||||
func (b *Batch) Reset() {
|
||||
b.batch.Reset()
|
||||
b.merge = store.NewEmulatedMerge(b.store.mo)
|
||||
|
@ -20,14 +20,6 @@ type Writer struct {
|
||||
store *Store
|
||||
}
|
||||
|
||||
func (w *Writer) Set(key, val []byte) error {
|
||||
return w.store.db.Put(key, val, w.store.defaultWriteOptions)
|
||||
}
|
||||
|
||||
func (w *Writer) Delete(key []byte) error {
|
||||
return w.store.db.Delete(key, w.store.defaultWriteOptions)
|
||||
}
|
||||
|
||||
func (w *Writer) NewBatch() store.KVBatch {
|
||||
rv := Batch{
|
||||
store: w.store,
|
||||
|
Loading…
Reference in New Issue
Block a user