[Go] Add StatisticsBlobs (#90)

Signed-off-by: sunby <[email protected]>
milvus-io · Nov 9, 2023 · 1cd7b08 · 1cd7b08
1 parent 2038b71
commit 1cd7b08
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/go/storage/manifest/manifest.go b/go/storage/manifest/manifest.go
@@ -76,6 +76,10 @@ func (m *Manifest) SetVersion(version int64) {
 	m.version = version
 }
 
+func (m *Manifest) GetBlobs() []blob.Blob {
+	return m.blobs
+}
+
 func (m *Manifest) ToProtobuf() (*manifest_proto.Manifest, error) {
 	manifest := &manifest_proto.Manifest{}
 	manifest.Version = m.version

diff --git a/go/storage/space.go b/go/storage/space.go
@@ -7,6 +7,7 @@ import (
 	"github.com/milvus-io/milvus-storage/go/common/errors"
 	"github.com/milvus-io/milvus-storage/go/common/log"
 	"github.com/milvus-io/milvus-storage/go/common/utils"
+	"github.com/milvus-io/milvus-storage/go/file/blob"
 	"github.com/milvus-io/milvus-storage/go/file/fragment"
 	"github.com/milvus-io/milvus-storage/go/filter"
 	"github.com/milvus-io/milvus-storage/go/io/fs"
@@ -195,3 +196,7 @@ func (s *Space) LockManager() lock.LockManager {
 func (s *Space) SetLockManager(lockManager lock.LockManager) {
 	s.lockManager = lockManager
 }
+
+func (s *Space) StatisticsBlobs() []blob.Blob {
+	return s.manifest.GetBlobs()
+}