Index: filter/featureBreaker/rds.go |
diff --git a/filter/featureBreaker/rds.go b/filter/featureBreaker/rds.go |
index 2bbbce7d445200f3659f8a164ba0222881fffbd3..4523fc297f0147108d2eff75b9fe3cb9426d3eed 100644 |
--- a/filter/featureBreaker/rds.go |
+++ b/filter/featureBreaker/rds.go |
@@ -16,13 +16,10 @@ type dsState struct { |
rds ds.RawInterface |
} |
-func (r *dsState) AllocateIDs(incomplete *ds.Key, n int) (int64, error) { |
- start := int64(0) |
- err := r.run(func() (err error) { |
- start, err = r.rds.AllocateIDs(incomplete, n) |
- return |
+func (r *dsState) AllocateIDs(keys []*ds.Key, cb ds.NewKeyCB) error { |
+ return r.run(func() error { |
+ return r.rds.AllocateIDs(keys, cb) |
}) |
- return start, err |
} |
func (r *dsState) DecodeCursor(s string) (ds.Cursor, error) { |
@@ -70,7 +67,7 @@ func (r *dsState) GetMulti(keys []*ds.Key, meta ds.MultiMetaGetter, cb ds.GetMul |
}) |
} |
-func (r *dsState) PutMulti(keys []*ds.Key, vals []ds.PropertyMap, cb ds.PutMultiCB) error { |
+func (r *dsState) PutMulti(keys []*ds.Key, vals []ds.PropertyMap, cb ds.NewKeyCB) error { |
return r.run(func() (err error) { |
return r.rds.PutMulti(keys, vals, cb) |
}) |