mirror of
https://github.com/prometheus/prometheus.git
synced 2025-01-11 13:57:36 -08:00
tsdb: Extract index file path logic into a helper function
- Added `indexFile` helper function to generate the index file path. - Updated `block.go`, `compact.go`, and `repair.go` to use the new `indexFile` function for consistency and readability. Signed-off-by: johncming <johncming@yahoo.com>
This commit is contained in:
parent
8d5236f927
commit
d4d95b7127
|
@ -253,6 +253,8 @@ const (
|
||||||
|
|
||||||
func chunkDir(dir string) string { return filepath.Join(dir, "chunks") }
|
func chunkDir(dir string) string { return filepath.Join(dir, "chunks") }
|
||||||
|
|
||||||
|
func indexFile(dir string) string { return filepath.Join(dir, indexFilename) }
|
||||||
|
|
||||||
func readMetaFile(dir string) (*BlockMeta, int64, error) {
|
func readMetaFile(dir string) (*BlockMeta, int64, error) {
|
||||||
b, err := os.ReadFile(filepath.Join(dir, metaFilename))
|
b, err := os.ReadFile(filepath.Join(dir, metaFilename))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -359,7 +361,7 @@ func OpenBlock(logger *slog.Logger, dir string, pool chunkenc.Pool, postingsDeco
|
||||||
if postingsDecoderFactory != nil {
|
if postingsDecoderFactory != nil {
|
||||||
decoder = postingsDecoderFactory(meta)
|
decoder = postingsDecoderFactory(meta)
|
||||||
}
|
}
|
||||||
ir, err := index.NewFileReader(filepath.Join(dir, indexFilename), decoder)
|
ir, err := index.NewFileReader(indexFile(dir), decoder)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
|
@ -661,7 +661,7 @@ func (c *LeveledCompactor) write(dest string, meta *BlockMeta, blockPopulator Bl
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
indexw, err := index.NewWriterWithEncoder(c.ctx, filepath.Join(tmp, indexFilename), c.postingsEncoder)
|
indexw, err := index.NewWriterWithEncoder(c.ctx, indexFile(tmp), c.postingsEncoder)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("open index writer: %w", err)
|
return fmt.Errorf("open index writer: %w", err)
|
||||||
}
|
}
|
||||||
|
|
|
@ -72,7 +72,7 @@ func repairBadIndexVersion(logger *slog.Logger, dir string) error {
|
||||||
}
|
}
|
||||||
tmpFiles = append(tmpFiles, repl.Name())
|
tmpFiles = append(tmpFiles, repl.Name())
|
||||||
|
|
||||||
broken, err := os.Open(filepath.Join(d, indexFilename))
|
broken, err := os.Open(indexFile(d))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("open broken index for block dir: %v: %w", d, err)
|
return fmt.Errorf("open broken index for block dir: %v: %w", d, err)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue