Skip to content

Commit

Permalink
chore: Fix unused-parameter linter errors (backport k238) (#15844)
Browse files Browse the repository at this point in the history
Co-authored-by: Christian Haudum <[email protected]>
  • Loading branch information
loki-gh-app[bot] and chaudum authored Jan 20, 2025
1 parent 7cb8dd6 commit eab8559
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 29 deletions.
10 changes: 1 addition & 9 deletions pkg/bloomgateway/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@ import (
"github.com/grafana/loki/v3/pkg/querier/plan"
"github.com/grafana/loki/v3/pkg/queue"
v1 "github.com/grafana/loki/v3/pkg/storage/bloom/v1"
"github.com/grafana/loki/v3/pkg/storage/chunk/cache/resultscache"
"github.com/grafana/loki/v3/pkg/storage/stores/shipper/bloomshipper"
"github.com/grafana/loki/v3/pkg/util/discovery"
)
Expand Down Expand Up @@ -121,14 +120,7 @@ type GatewayClient struct {
dnsProvider *discovery.DNS
}

func NewClient(
cfg ClientConfig,
limits Limits,
registerer prometheus.Registerer,
logger log.Logger,
cacheGen resultscache.CacheGenNumberLoader,
retentionEnabled bool,
) (*GatewayClient, error) {
func NewClient(cfg ClientConfig, registerer prometheus.Registerer, logger log.Logger) (*GatewayClient, error) {
metrics := newClientMetrics(registerer)

dialOpts, err := cfg.GRPCClientConfig.DialOption(grpcclient.Instrument(metrics.requestLatency))
Expand Down
6 changes: 2 additions & 4 deletions pkg/bloomgateway/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,14 +28,12 @@ func (p *errorMockPool) Addr(_ string) (string, error) {
func TestBloomGatewayClient(t *testing.T) {
logger := log.NewNopLogger()

limits := newLimits()

cfg := ClientConfig{}
flagext.DefaultValues(&cfg)

t.Run("FilterChunks returns response", func(t *testing.T) {
reg := prometheus.NewRegistry()
c, err := NewClient(cfg, limits, reg, logger, nil, false)
c, err := NewClient(cfg, reg, logger)
require.NoError(t, err)
expr, err := syntax.ParseExpr(`{foo="bar"}`)
require.NoError(t, err)
Expand All @@ -46,7 +44,7 @@ func TestBloomGatewayClient(t *testing.T) {

t.Run("pool error is suppressed and returns full list of chunks", func(t *testing.T) {
reg := prometheus.NewRegistry()
c, err := NewClient(cfg, limits, reg, logger, nil, false)
c, err := NewClient(cfg, reg, logger)
require.NoError(t, err)
c.pool = &errorMockPool{}

Expand Down
18 changes: 2 additions & 16 deletions pkg/loki/modules.go
Original file line number Diff line number Diff line change
Expand Up @@ -1544,14 +1544,7 @@ func (t *Loki) initIndexGateway() (services.Service, error) {

var bloomQuerier indexgateway.BloomQuerier
if t.Cfg.BloomGateway.Enabled {
bloomGatewayClient, err := bloomgateway.NewClient(
t.Cfg.BloomGateway.Client,
t.Overrides,
prometheus.DefaultRegisterer,
logger,
t.cacheGenerationLoader,
t.Cfg.CompactorConfig.RetentionEnabled,
)
bloomGatewayClient, err := bloomgateway.NewClient(t.Cfg.BloomGateway.Client, prometheus.DefaultRegisterer, logger)
if err != nil {
return nil, err
}
Expand Down Expand Up @@ -1675,14 +1668,7 @@ func (t *Loki) initBloomBuilder() (services.Service, error) {
var bloomGatewayClient bloomgateway.Client
if t.Cfg.BloomGateway.Enabled {
var err error
bloomGatewayClient, err = bloomgateway.NewClient(
t.Cfg.BloomGateway.Client,
t.Overrides,
prometheus.DefaultRegisterer,
logger,
t.cacheGenerationLoader,
t.Cfg.CompactorConfig.RetentionEnabled,
)
bloomGatewayClient, err = bloomgateway.NewClient(t.Cfg.BloomGateway.Client, prometheus.DefaultRegisterer, logger)
if err != nil {
return nil, err
}
Expand Down

0 comments on commit eab8559

Please sign in to comment.