Skip to content

Commit 8ae218c

Browse files
committed
use util.Logger instead of noop logger
Signed-off-by: Ben Ye <yb532204897@gmail.com>
1 parent b64980a commit 8ae218c

File tree

4 files changed

+15
-6
lines changed

4 files changed

+15
-6
lines changed

integration/chunks_storage_backends_test.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
"testing"
1010
"time"
1111

12+
"github.com/go-kit/kit/log"
1213
"github.com/prometheus/common/model"
1314
"github.com/prometheus/prometheus/pkg/labels"
1415
"github.com/stretchr/testify/assert"
@@ -184,7 +185,7 @@ func TestSwiftChunkStorage(t *testing.T) {
184185
limits, err := validation.NewOverrides(defaults, nil)
185186
require.NoError(t, err)
186187

187-
store, err := storage.NewStore(cfg, storeConfig, schemaConfig, limits, nil, nil)
188+
store, err := storage.NewStore(cfg, storeConfig, schemaConfig, limits, nil, nil, log.NewNopLogger())
188189
require.NoError(t, err)
189190

190191
defer store.Stop()

pkg/chunk/storage/factory.go

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,10 +115,17 @@ func (cfg *Config) Validate() error {
115115
}
116116

117117
// NewStore makes the storage clients based on the configuration.
118-
func NewStore(cfg Config, storeCfg chunk.StoreConfig, schemaCfg chunk.SchemaConfig, limits StoreLimits, reg prometheus.Registerer, cacheGenNumLoader chunk.CacheGenNumLoader) (chunk.Store, error) {
118+
func NewStore(
119+
cfg Config,
120+
storeCfg chunk.StoreConfig,
121+
schemaCfg chunk.SchemaConfig,
122+
limits StoreLimits,
123+
reg prometheus.Registerer,
124+
cacheGenNumLoader chunk.CacheGenNumLoader,
125+
logger log.Logger,
126+
) (chunk.Store, error) {
119127
chunkMetrics := newChunkClientMetrics(reg)
120128

121-
logger := log.NewNopLogger()
122129
indexReadCache, err := cache.New(cfg.IndexQueriesCacheConfig, reg, logger)
123130
if err != nil {
124131
return nil, err

pkg/chunk/storage/factory_test.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import (
77
"testing"
88
"time"
99

10+
"github.com/go-kit/kit/log"
1011
"github.com/prometheus/client_golang/prometheus"
1112
"github.com/prometheus/common/model"
1213
"github.com/stretchr/testify/require"
@@ -42,7 +43,7 @@ func TestFactoryStop(t *testing.T) {
4243
limits, err := validation.NewOverrides(defaults, nil)
4344
require.NoError(t, err)
4445

45-
store, err := NewStore(cfg, storeConfig, schemaConfig, limits, nil, nil)
46+
store, err := NewStore(cfg, storeConfig, schemaConfig, limits, nil, nil, log.NewNopLogger())
4647
require.NoError(t, err)
4748

4849
store.Stop()
@@ -190,7 +191,7 @@ func TestCassandraInMultipleSchemas(t *testing.T) {
190191
limits, err := validation.NewOverrides(defaults, nil)
191192
require.NoError(t, err)
192193

193-
store, err := NewStore(cfg, storeConfig, schemaCfg, limits, prometheus.NewRegistry(), nil)
194+
store, err := NewStore(cfg, storeConfig, schemaCfg, limits, prometheus.NewRegistry(), nil, log.NewNopLogger())
194195
require.NoError(t, err)
195196

196197
store.Stop()

pkg/cortex/modules.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,7 @@ func (t *Cortex) initChunkStore() (serv services.Service, err error) {
316316
return
317317
}
318318

319-
t.Store, err = storage.NewStore(t.Cfg.Storage, t.Cfg.ChunkStore, t.Cfg.Schema, t.Overrides, prometheus.DefaultRegisterer, t.TombstonesLoader)
319+
t.Store, err = storage.NewStore(t.Cfg.Storage, t.Cfg.ChunkStore, t.Cfg.Schema, t.Overrides, prometheus.DefaultRegisterer, t.TombstonesLoader, util.Logger)
320320
if err != nil {
321321
return
322322
}

0 commit comments

Comments
 (0)