Skip to content

Commit a023b18

Browse files
committed
Change function naming
Signed-off-by: SungJin1212 <tjdwls1201@gmail.com>
1 parent 51b5c1d commit a023b18

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

pkg/querier/parquet_queryable.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ func NewParquetQueryable(
134134
return nil, err
135135
}
136136

137-
cache, err := parquetutil.NewCache[parquet_storage.ParquetShard](&config.ParquetShardCache, "parquet-shards", extprom.WrapRegistererWith(prometheus.Labels{"component": "querier"}, reg))
137+
cache, err := parquetutil.NewParquetShardCache[parquet_storage.ParquetShard](&config.ParquetShardCache, "parquet-shards", extprom.WrapRegistererWith(prometheus.Labels{"component": "querier"}, reg))
138138
if err != nil {
139139
return nil, err
140140
}

pkg/util/parquetutil/cache.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ func (cfg *CacheConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
7272
cfg.MaintenanceInterval = defaultMaintenanceInterval
7373
}
7474

75-
func NewCache[T any](cfg *CacheConfig, name string, reg prometheus.Registerer) (CacheInterface[T], error) {
75+
func NewParquetShardCache[T any](cfg *CacheConfig, name string, reg prometheus.Registerer) (CacheInterface[T], error) {
7676
if cfg.ParquetShardCacheSize <= 0 {
7777
return &noopCache[T]{}, nil
7878
}

pkg/util/parquetutil/cache_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ func Test_Cache_LRUEviction(t *testing.T) {
1717
ParquetShardCacheTTL: 0,
1818
MaintenanceInterval: time.Minute,
1919
}
20-
cache, err := NewCache[string](cfg, "test", reg)
20+
cache, err := NewParquetShardCache[string](cfg, "test", reg)
2121
require.NoError(t, err)
2222
defer cache.Close()
2323

@@ -59,7 +59,7 @@ func Test_Cache_TTLEvictionByGet(t *testing.T) {
5959
MaintenanceInterval: time.Minute,
6060
}
6161

62-
cache, err := NewCache[string](cfg, "test", reg)
62+
cache, err := NewParquetShardCache[string](cfg, "test", reg)
6363
require.NoError(t, err)
6464
defer cache.Close()
6565

@@ -98,7 +98,7 @@ func Test_Cache_TTLEvictionByLoop(t *testing.T) {
9898
MaintenanceInterval: 100 * time.Millisecond,
9999
}
100100

101-
cache, err := NewCache[string](cfg, "test", reg)
101+
cache, err := NewParquetShardCache[string](cfg, "test", reg)
102102
require.NoError(t, err)
103103
defer cache.Close()
104104

0 commit comments

Comments
 (0)