Skip to content

Commit 8809669

Browse files
committed
Nuke index cache deprecated flags.
Signed-off-by: Goutham Veeramachaneni <[email protected]>
1 parent f3d70e1 commit 8809669

File tree

2 files changed

+3
-32
lines changed

2 files changed

+3
-32
lines changed

pkg/chunk/storage/factory.go

Lines changed: 3 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,7 @@ type Config struct {
2828
BoltDBConfig local.BoltDBConfig `yaml:"boltdb"`
2929
FSConfig local.FSConfig `yaml:"filesystem"`
3030

31-
IndexCacheSize int
3231
IndexCacheValidity time.Duration
33-
memcacheClient cache.MemcachedClientConfig
3432

3533
indexQueriesCacheConfig cache.Config
3634
}
@@ -44,10 +42,6 @@ func (cfg *Config) RegisterFlags(f *flag.FlagSet) {
4442
cfg.BoltDBConfig.RegisterFlags(f)
4543
cfg.FSConfig.RegisterFlags(f)
4644

47-
// Deprecated flags!!
48-
f.IntVar(&cfg.IndexCacheSize, "store.index-cache-size", 0, "Deprecated: Use -store.index-cache-read.*; Size of in-memory index cache, 0 to disable.")
49-
cfg.memcacheClient.RegisterFlagsWithPrefix("index.", "Deprecated: Use -store.index-cache-read.*;", f)
50-
5145
cfg.indexQueriesCacheConfig.RegisterFlagsWithPrefix("store.index-cache-read.", "Cache config for index entry reading. ", f)
5246
f.DurationVar(&cfg.IndexCacheValidity, "store.index-cache-validity", 5*time.Minute, "Cache validity for active index entries. Should be no higher than -ingester.max-chunk-idle.")
5347
}
@@ -56,31 +50,9 @@ func (cfg *Config) RegisterFlags(f *flag.FlagSet) {
5650
func NewStore(cfg Config, storeCfg chunk.StoreConfig, schemaCfg chunk.SchemaConfig, limits *validation.Overrides) (chunk.Store, error) {
5751
var err error
5852

59-
// Building up from deprecated flags.
60-
var caches []cache.Cache
61-
if cfg.IndexCacheSize > 0 {
62-
fifocache := cache.Instrument("fifo-index", cache.NewFifoCache("index", cache.FifoCacheConfig{Size: cfg.IndexCacheSize}))
63-
caches = append(caches, fifocache)
64-
}
65-
if cfg.memcacheClient.Host != "" {
66-
client := cache.NewMemcachedClient(cfg.memcacheClient)
67-
memcache := cache.Instrument("memcache-index", cache.NewMemcached(cache.MemcachedConfig{
68-
Expiration: cfg.IndexCacheValidity,
69-
}, client, "memcache-index"))
70-
caches = append(caches, cache.NewBackground("memcache-index", cache.BackgroundConfig{
71-
WriteBackGoroutines: 10,
72-
WriteBackBuffer: 100,
73-
}, memcache))
74-
}
75-
76-
var tieredCache cache.Cache
77-
if len(caches) > 0 {
78-
tieredCache = cache.NewTiered(caches)
79-
} else {
80-
tieredCache, err = cache.New(cfg.indexQueriesCacheConfig)
81-
if err != nil {
82-
return nil, err
83-
}
53+
tieredCache, err := cache.New(cfg.indexQueriesCacheConfig)
54+
if err != nil {
55+
return nil, err
8456
}
8557

8658
// Cache is shared by multiple stores, which means they will try and Stop

pkg/chunk/storage/factory_test.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ func TestFactoryStop(t *testing.T) {
2929
IndexType: "inmemory",
3030
},
3131
}
32-
cfg.memcacheClient.Host = "localhost" // Fake address that should at least resolve.
3332

3433
limits, err := validation.NewOverrides(defaults)
3534
require.NoError(t, err)

0 commit comments

Comments
 (0)