From 1cd7b0866092ae64ed9b96fe9c95686da8dd3bf8 Mon Sep 17 00:00:00 2001 From: Bingyi Sun Date: Thu, 9 Nov 2023 15:28:09 +0800 Subject: [PATCH] [Go] Add StatisticsBlobs (#90) Signed-off-by: sunby --- go/storage/manifest/manifest.go | 4 ++++ go/storage/space.go | 5 +++++ 2 files changed, 9 insertions(+) diff --git a/go/storage/manifest/manifest.go b/go/storage/manifest/manifest.go index dce9ac4..96604b4 100644 --- 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 index 0f1b712..b66658a 100644 --- 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() +}