[skywalking-banyandb] branch main updated: fix database location (#69)

[hanahmily]

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git


The following commit(s) were added to refs/heads/main by this push:
     new fd738df  fix database location (#69)
fd738df is described below

commit fd738dff6655d3e3259c0152202797db0c04488d
Author: Jiajing LU <lujiajing1...@gmail.com>
AuthorDate: Thu Jan 20 08:52:51 2022 +0800

    fix database location (#69)
---
 banyand/measure/measure.go | 3 ++-
 banyand/stream/stream.go   | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/banyand/measure/measure.go b/banyand/measure/measure.go
index f48953c..3770c29 100644
--- a/banyand/measure/measure.go
+++ b/banyand/measure/measure.go
@@ -19,6 +19,7 @@ package measure
 
 import (
        "context"
+       "path"
 
        databasev1 
"github.com/apache/skywalking-banyandb/api/proto/banyandb/database/v1"
        "github.com/apache/skywalking-banyandb/banyand/tsdb"
@@ -71,7 +72,7 @@ func openMeasure(root string, spec measureSpec, l 
*logger.Logger) (*measure, err
        db, err := tsdb.OpenDatabase(
                ctx,
                tsdb.DatabaseOpts{
-                       Location:   root,
+                       Location:   path.Join(root, 
spec.schema.GetMetadata().GetGroup(), spec.schema.GetMetadata().GetName()),
                        ShardNum:   sm.schema.GetOpts().GetShardNum(),
                        IndexRules: spec.indexRules,
                        EncodingMethod: tsdb.EncodingMethod{
diff --git a/banyand/stream/stream.go b/banyand/stream/stream.go
index be16b7d..0111de0 100644
--- a/banyand/stream/stream.go
+++ b/banyand/stream/stream.go
@@ -19,6 +19,7 @@ package stream
 
 import (
        "context"
+       "path"
 
        databasev1 
"github.com/apache/skywalking-banyandb/api/proto/banyandb/database/v1"
        "github.com/apache/skywalking-banyandb/banyand/tsdb"
@@ -82,7 +83,7 @@ func openStream(root string, spec streamSpec, l 
*logger.Logger) (*stream, error)
        db, err := tsdb.OpenDatabase(
                ctx,
                tsdb.DatabaseOpts{
-                       Location:   root,
+                       Location:   path.Join(root, 
spec.schema.GetMetadata().GetGroup(), spec.schema.GetMetadata().GetName()),
                        ShardNum:   sm.schema.GetOpts().GetShardNum(),
                        IndexRules: spec.indexRules,
                        EncodingMethod: tsdb.EncodingMethod{