aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/needle_map.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/storage/needle_map.go')
-rw-r--r--weed/storage/needle_map.go8
1 files changed, 8 insertions, 0 deletions
diff --git a/weed/storage/needle_map.go b/weed/storage/needle_map.go
index ef3d4c151..682c88f78 100644
--- a/weed/storage/needle_map.go
+++ b/weed/storage/needle_map.go
@@ -8,6 +8,7 @@ import (
"github.com/seaweedfs/seaweedfs/weed/storage/idx"
"github.com/seaweedfs/seaweedfs/weed/storage/needle_map"
. "github.com/seaweedfs/seaweedfs/weed/storage/types"
+ "github.com/syndtr/goleveldb/leveldb/opt"
)
type NeedleMapKind int
@@ -43,6 +44,13 @@ type baseNeedleMapper struct {
indexFileOffset int64
}
+type TempNeedleMapper interface {
+ NeedleMapper
+ DoOffsetLoading(v *Volume, indexFile *os.File, startFrom uint64) error
+ UpdateNeedleMap(v *Volume, indexFile *os.File, opts *opt.Options) error
+ UpdateNeedleMapMetric(indexFile *os.File) error
+}
+
func (nm *baseNeedleMapper) IndexFileSize() uint64 {
stat, err := nm.indexFile.Stat()
if err == nil {