Index: filter/txnBuf/ds_txn.go |
diff --git a/filter/txnBuf/ds_txn.go b/filter/txnBuf/ds_txn.go |
index e39a8b8e4c404603d358d0885cb4bf169d8afc6f..7b25c607d2d4fc2a003d0a2ab8679d94be086929 100644 |
--- a/filter/txnBuf/ds_txn.go |
+++ b/filter/txnBuf/ds_txn.go |
@@ -32,15 +32,15 @@ func (d *dsTxnBuf) DecodeCursor(s string) (ds.Cursor, error) { |
return d.state.parentDS.DecodeCursor(s) |
} |
-func (d *dsTxnBuf) AllocateIDs(incomplete *ds.Key, n int) (start int64, err error) { |
- return d.state.parentDS.AllocateIDs(incomplete, n) |
+func (d *dsTxnBuf) AllocateIDs(keys []*ds.Key, cb ds.NewKeyCB) error { |
+ return d.state.parentDS.AllocateIDs(keys, cb) |
} |
func (d *dsTxnBuf) GetMulti(keys []*ds.Key, metas ds.MultiMetaGetter, cb ds.GetMultiCB) error { |
return d.state.getMulti(keys, metas, cb, d.haveLock) |
} |
-func (d *dsTxnBuf) PutMulti(keys []*ds.Key, vals []ds.PropertyMap, cb ds.PutMultiCB) error { |
+func (d *dsTxnBuf) PutMulti(keys []*ds.Key, vals []ds.PropertyMap, cb ds.NewKeyCB) error { |
return d.state.putMulti(keys, vals, cb, d.haveLock) |
} |