Configurable Kopia Maintenance Interval

Signed-off-by: Tiger Kaovilai <[email protected]>

pkg/repository/udmrepo/kopialib/lib_repo.go

@@ -79,6 +79,8 @@ const (
 	defaultMaintainCheckPeriod     = time.Hour
 	overwriteFullMaintainInterval  = time.Duration(0)
 	overwriteQuickMaintainInterval = time.Duration(0)
+	eagerGCFullInterval            = time.Duration(12)
+	eagerGCQuickInterval           = time.Duration(6)
 )
 
 var kopiaRepoOpen = repo.Open
@@ -600,7 +602,14 @@ func writeInitParameters(ctx context.Context, repoOption udmrepo.RepoOptions, lo
 			logger.Infof("Quick maintenance interval change from %v to %v", p.QuickCycle.Interval, overwriteQuickMaintainInterval)
 			p.QuickCycle.Interval = overwriteQuickMaintainInterval
 		}
-
+		if repoOption.FullMaintenanceInterval == udmrepo.FastGC {
+			logger.Infof("Full maintenance interval change from %v to %v", p.FullCycle.Interval, udmrepo.FastGCInterval)
+			p.FullCycle.Interval = udmrepo.FastGCInterval
+		}
+		if repoOption.FullMaintenanceInterval == udmrepo.EagerGC {
+			logger.Infof("Full maintenance interval change from %v to %v", p.FullCycle.Interval, udmrepo.EagerGCInterval)
+			p.FullCycle.Interval = udmrepo.EagerGCInterval
+		}
 		p.Owner = r.ClientOptions().UsernameAtHost()
 
 		if err := maintenance.SetParams(ctx, w, &p); err != nil {

pkg/repository/udmrepo/repo_options.go

@@ -20,6 +20,7 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"time"
 )
 
 const (
@@ -65,13 +66,19 @@ const (
 
 	StoreOptionCacheLimit = "cacheLimitMB"
 
-	ThrottleOptionReadOps       = "readOPS"
-	ThrottleOptionWriteOps      = "writeOPS"
-	ThrottleOptionListOps       = "listOPS"
-	ThrottleOptionUploadBytes   = "uploadBytes"
-	ThrottleOptionDownloadBytes = "downloadBytes"
+	ThrottleOptionReadOps                                      = "readOPS"
+	ThrottleOptionWriteOps                                     = "writeOPS"
+	ThrottleOptionListOps                                      = "listOPS"
+	ThrottleOptionUploadBytes                                  = "uploadBytes"
+	ThrottleOptionDownloadBytes                                = "downloadBytes"
+	FastGC                      FullMaintenanceIntervalOptions = "fastGC"
+	FastGCInterval              time.Duration                  = 12 * time.Hour
+	EagerGC                     FullMaintenanceIntervalOptions = "eagerGC"
+	EagerGCInterval             time.Duration                  = 6 * time.Hour
 )
 
+type FullMaintenanceIntervalOptions string
+
 const (
 	defaultUsername = "default"
 	defaultDomain   = "default"
@@ -88,6 +95,9 @@ type RepoOptions struct {
 	GeneralOptions map[string]string
 	// StorageOptions takes storage specific options
 	StorageOptions map[string]string
+	// FullMaintenanceInterval will overwrite kopia maintenance interval
+	// options are fastGC for 12 hours, eagerGC for 6 hours
+	FullMaintenanceInterval FullMaintenanceIntervalOptions
 
 	// Description is a description of the backup repository/backup repository operation.
 	// It is for logging/debugging purpose only and doesn't control any behavior of the backup repository.
@@ -156,6 +166,14 @@ func WithGenOptions(genOptions map[string]string) func(*RepoOptions) error {
 	}
 }
 
+// WithFullMaintenanceInterval
+func WithFullMaintenanceInterval(interval FullMaintenanceIntervalOptions) func(*RepoOptions) error {
+	return func(options *RepoOptions) error {
+		options.FullMaintenanceInterval = interval
+		return nil
+	}
+}
+
 // WithStoreOptions sets the StorageOptions to RepoOptions, the store options are acquired through
 // the provided interface
 func WithStoreOptions(getter StoreOptionsGetter, param interface{}) func(*RepoOptions) error {