GestEarliestVersion

Author: Kbhat1

sc/memiavl/db.go

@@ -436,7 +436,7 @@ func (db *DB) pruneSnapshots() {
 		}
 
 		// truncate Rlog until the earliest remaining snapshot
-		earliestVersion, err := firstSnapshotVersion(db.dir)
+		earliestVersion, err := GetEarliestVersion(db.dir)
 		if err != nil {
 			db.logger.Error("failed to find first snapshot", "err", err)
 		}
@@ -771,8 +771,8 @@ func seekSnapshot(root string, targetVersion int64) (int64, error) {
 	return snapshotVersion, nil
 }
 
-// firstSnapshotVersion returns the earliest snapshot name in the db
-func firstSnapshotVersion(root string) (int64, error) {
+// GetEarliestVersion returns the earliest snapshot name in the db
+func GetEarliestVersion(root string) (int64, error) {
 	var found int64
 	if err := traverseSnapshots(root, true, func(version int64) (bool, error) {
 		found = version

sc/store.go

@@ -103,6 +103,10 @@ func (cs *CommitStore) GetLatestVersion() (int64, error) {
 	return memiavl.GetLatestVersion(cs.opts.Dir)
 }
 
+func (cs *CommitStore) GetEarliestVersion() (int64, error) {
+	return memiavl.GetEarliestVersion(cs.opts.Dir)
+}
+
 func (cs *CommitStore) ApplyChangeSets(changesets []*proto.NamedChangeSet) error {
 	return cs.db.ApplyChangeSets(changesets)
 }

sc/types/store.go

@@ -15,6 +15,8 @@ type Committer interface {
 
 	GetLatestVersion() (int64, error)
 
+	GetEarliestVersion() (int64, error)
+
 	ApplyChangeSets(cs []*proto.NamedChangeSet) error
 
 	ApplyUpgrades(upgrades []*proto.TreeNameUpgrade) error