Use localstorage bucket for persistence

Signed-off-by: Arunprasad Rajkumar <[email protected]>

Author: arajkumar

frostdb/frostdb.go

@@ -22,6 +22,7 @@ import (
 	"github.com/prometheus/prometheus/storage"
 	"github.com/prometheus/prometheus/tsdb/chunkenc"
 	"github.com/segmentio/parquet-go"
+	"github.com/thanos-io/objstore/providers/filesystem"
 )
 
 type FrostDB struct {
@@ -43,12 +44,14 @@ type FrostQuerier struct {
 
 // Open a new frostDB
 func Open(dir string, reg prometheus.Registerer, logger log.Logger) (*FrostDB, error) {
+	bucket, err := filesystem.NewBucket(dir)
 	ctx := context.Background()
 	store, err := frost.New(
 		logger,
 		reg,
 		frost.WithWAL(),
 		frost.WithStoragePath(dir),
+		frost.WithBucketStorage(bucket),
 	)
 	if err != nil {
 		return nil, err

go.mod

@@ -175,6 +175,11 @@ require (
 	github.com/sirupsen/logrus v1.8.1 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/stretchr/objx v0.2.0 // indirect
+	github.com/tidwall/gjson v1.10.2 // indirect
+	github.com/tidwall/match v1.1.1 // indirect
+	github.com/tidwall/pretty v1.2.0 // indirect
+	github.com/tidwall/tinylru v1.1.0 // indirect
+	github.com/tidwall/wal v1.1.7 // indirect
 	go.mongodb.org/mongo-driver v1.8.3 // indirect
 	go.opencensus.io v0.23.0 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.7.0 // indirect