Index: filter/dscache/context.go |
diff --git a/filter/dscache/context.go b/filter/dscache/context.go |
index a9f10ba1de6fbf0955edf5800ce4f3842925c0e6..3cd81dec505dc90ebfb0e0c753b9492c53d7b56d 100644 |
--- a/filter/dscache/context.go |
+++ b/filter/dscache/context.go |
@@ -32,7 +32,14 @@ func FilterRDS(c context.Context, shardsForKey func(*ds.Key) int) context.Contex |
if !IsGloballyEnabled(c) { |
return c |
} |
+ return AlwaysFilterRDS(c, shardsForKey) |
+} |
+// AlwaysFilterRDS installs a caching RawDatastore filter in the context. |
+// |
+// Unlike FilterRDS it doesn't check GlobalConfig via IsGloballyEnabled call, |
+// assuming caller already knows whether filter should be applied or not. |
+func AlwaysFilterRDS(c context.Context, shardsForKey func(*ds.Key) int) context.Context { |
return ds.AddRawFilters(c, func(c context.Context, ds ds.RawInterface) ds.RawInterface { |
i := info.Get(c) |