Index: filter/count/rds.go |
diff --git a/filter/count/rds.go b/filter/count/rds.go |
index 6534d165092828a74c1317f5a0b4e92ce6fbe5a7..f9b68ca175a6832ade34b9615cb3a30b025c3813 100644 |
--- a/filter/count/rds.go |
+++ b/filter/count/rds.go |
@@ -25,10 +25,10 @@ type DSCounter struct { |
type dsCounter struct { |
c *DSCounter |
- ds ds.Interface |
+ ds ds.RawInterface |
} |
-var _ ds.Interface = (*dsCounter)(nil) |
+var _ ds.RawInterface = (*dsCounter)(nil) |
func (r *dsCounter) NewKey(kind, stringID string, intID int64, parent ds.Key) ds.Key { |
r.c.NewKey.up() |
@@ -45,7 +45,7 @@ func (r *dsCounter) NewQuery(kind string) ds.Query { |
return r.ds.NewQuery(kind) |
} |
-func (r *dsCounter) Run(q ds.Query, cb ds.RunCB) error { |
+func (r *dsCounter) Run(q ds.Query, cb ds.RawRunCB) error { |
return r.c.Run.up(r.ds.Run(q, cb)) |
} |
@@ -61,14 +61,14 @@ func (r *dsCounter) GetMulti(keys []ds.Key, cb ds.GetMultiCB) error { |
return r.c.GetMulti.up(r.ds.GetMulti(keys, cb)) |
} |
-func (r *dsCounter) PutMulti(keys []ds.Key, vals []ds.PropertyLoadSaver, cb ds.PutMultiCB) error { |
+func (r *dsCounter) PutMulti(keys []ds.Key, vals []ds.PropertyMap, cb ds.PutMultiCB) error { |
return r.c.PutMulti.up(r.ds.PutMulti(keys, vals, cb)) |
} |
// FilterRDS installs a counter datastore filter in the context. |
func FilterRDS(c context.Context) (context.Context, *DSCounter) { |
state := &DSCounter{} |
- return ds.AddFilters(c, func(ic context.Context, ds ds.Interface) ds.Interface { |
+ return ds.AddRawFilters(c, func(ic context.Context, ds ds.RawInterface) ds.RawInterface { |
return &dsCounter{state, ds} |
}), state |
} |