Skip to content

Commit

Permalink
fix build error
Browse files Browse the repository at this point in the history
Signed-off-by: Wen Xu <[email protected]>
  • Loading branch information
wenxu1024 committed Nov 9, 2023
1 parent e372de7 commit 6a18b41
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/compactor/compactor.go
Original file line number Diff line number Diff line change
Expand Up @@ -498,14 +498,14 @@ func newCompactor(
// Instance the right strategy.
switch c.compactorCfg.ShardingStrategy {
case util.ShardingStrategyDefault:
c.shardingStrategy = storegateway.NewDefaultShardingStrategy(c.ring, c.ringLifecycler.Addr, logger)
c.shardingStrategy = storegateway.NewDefaultShardingStrategy(c.ring, c.ringLifecycler.Addr, logger, c.allowedTenants)
case util.ShardingStrategyShuffle:
c.shardingStrategy = storegateway.NewShuffleShardingStrategy(c.ring, lifecyclerCfg.ID, lifecyclerCfg.Addr, limits, logger, c.compactorCfg.ShardingRing.ZoneStableShuffleSharding)
c.shardingStrategy = storegateway.NewShuffleShardingStrategy(c.ring, lifecyclerCfg.ID, lifecyclerCfg.Addr, limits, logger, c.allowedTenants, c.compactorCfg.ShardingRing.ZoneStableShuffleSharding)
default:
return nil, errInvalidShardingStrategy
}
} else {
c.shardingStrategy = storegateway.NewNoShardingStrategy()
c.shardingStrategy = storegateway.NewNoShardingStrategy(logger, c.allowedTenants)
}

c.Service = services.NewBasicService(c.starting, c.running, c.stopping)
Expand Down

0 comments on commit 6a18b41

Please sign in to comment.