cluster/store: start compaction loop when Opening store

vinceanalytics · Feb 29, 2024 · f9c0151 · f9c0151
1 parent 363fe1b
commit f9c0151
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/internal/cluster/store/store.go b/internal/cluster/store/store.go
@@ -172,9 +172,6 @@ type Store struct {
 	peersInfoPath string
 	dbPath        string
 
-	restorePath   string
-	restoreDoneCh chan struct{}
-
 	raft   *raft.Raft // The consensus mechanism.
 	ly     Layer
 	raftTn *NodeTransport
@@ -258,14 +255,14 @@ func NewStore(base *v1.Config, ly Layer) (*Store, error) {
 			uint64(base.GranuleSize),
 		),
 	)
+
 	return &Store{
 		ly:             ly,
 		raftDir:        base.Data,
 		snapshotDir:    filepath.Join(base.Data, snapshotsDirName),
 		peersPath:      filepath.Join(base.Data, peersPath),
 		peersInfoPath:  filepath.Join(base.Data, peersInfoPath),
 		dbPath:         filepath.Join(base.Data, dbName),
-		restoreDoneCh:  make(chan struct{}),
 		logger:         slog.Default().With("component", "store"),
 		notifyingNodes: make(map[string]*v1.Server),
 		ApplyTimeout:   applyTimeout,
@@ -274,7 +271,7 @@ func NewStore(base *v1.Config, ly Layer) (*Store, error) {
 	}, nil
 }
 
-func (s *Store) Open() error {
+func (s *Store) Open(ctx context.Context) error {
 	if s.open.Is() {
 		return ErrOpen
 	}
@@ -349,6 +346,7 @@ func (s *Store) Open() error {
 		return fmt.Errorf("creating the raft system failed: %s", err)
 	}
 	s.raft = ra
+	s.session.Start(ctx)
 	return nil
 }