Merge pull request #9 from solarisdb/chunks_meta_store

Chunks meta store, no caching yet
solarisdb · Mar 15, 2024 · 7909e52 · 7909e52
2 parents d9ecb3a + 8e472ce
commit 7909e52
Show file tree

Hide file tree

Showing 5 changed files with 516 additions and 140 deletions.
diff --git a/pkg/server/config.go b/pkg/server/config.go
@@ -27,13 +27,17 @@ type (
 	Config struct {
 		// GrpcTransport specifies grpc transport configuration
 		GrpcTransport *transport.Config
+		// MetaDBFilePath specifies logs and chunks metadata is stored,
+		// if left empty, in-memory storage is used
+		MetaDBFilePath string
 	}
 )
 
 // getDefaultConfig returns the default server config
 func getDefaultConfig() *Config {
 	return &Config{
-		GrpcTransport: transport.GetDefaultGRPCConfig(),
+		GrpcTransport:  transport.GetDefaultGRPCConfig(),
+		MetaDBFilePath: ":memory:",
 	}
 }
 

diff --git a/pkg/server/server.go b/pkg/server/server.go
@@ -44,7 +44,7 @@ func Run(ctx context.Context, cfg *Config) error {
 
 	inj := linker.New()
 	inj.Register(linker.Component{Name: "", Value: grpc.NewServer(grpc.Config{Transport: *cfg.GrpcTransport, RegisterEndpoints: grpcRegF})})
-	inj.Register(linker.Component{Name: "", Value: buntdb.NewLogStorage(buntdb.Config{})})
+	inj.Register(linker.Component{Name: "", Value: buntdb.NewStorage(buntdb.Config{DBFilePath: cfg.MetaDBFilePath})})
 
 	inj.Init(ctx)
 	<-ctx.Done()