| 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)
|
|
|
|
|