Close frostdb during prometheus shutdown

arajkumar · metalmatze · commit 089211434cdb · 2023-03-04T17:34:04.000+01:00
Signed-off-by: Arunprasad Rajkumar &lt;ar.arunprasad@gmail.com&gt;
diff --git a/frostdb/frostdb.go b/frostdb/frostdb.go
@@ -158,7 +158,9 @@ func (f *FrostQuerier) LabelNames(matchers ...*labels.Matcher) ([]string, storag
 	return names, nil, nil
 }
 
-func (f *FrostQuerier) Close() error { return nil }
+func (f *FrostQuerier) Close() error {
+	return nil
+}
 
 func (f *FrostQuerier) Select(sortSeries bool, hints *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet {
 	engine := query.NewEngine(
@@ -201,7 +203,7 @@ func (f *FrostDB) StartTime() (int64, error) {
 }
 
 func (f *FrostDB) Close() error {
-	return nil
+	return f.store.Close()
 }
 
 func (f *FrostDB) Appender(ctx context.Context) storage.Appender {

Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,9 @@ func (f FrostQuerier) LabelNames(matchers ...labels.Matcher) ([]string, storag`
`158`	`158`	`return names, nil, nil`
`159`	`159`	`}`
`160`	`160`
`161`		`-func (f *FrostQuerier) Close() error { return nil }`
	`161`	`+func (f *FrostQuerier) Close() error {`
	`162`	`+ return nil`
	`163`	`+}`
`162`	`164`
`163`	`165`	`func (f FrostQuerier) Select(sortSeries bool, hints storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet {`
`164`	`166`	`engine := query.NewEngine(`
`@@ -201,7 +203,7 @@ func (f *FrostDB) StartTime() (int64, error) {`
`201`	`203`	`}`
`202`	`204`
`203`	`205`	`func (f *FrostDB) Close() error {`
`204`		`- return nil`
	`206`	`+ return f.store.Close()`
`205`	`207`	`}`
`206`	`208`
`207`	`209`	`func (f *FrostDB) Appender(ctx context.Context) storage.Appender {`