Method GetVersionPruningWindow

db/database.go:1650–1682

GetVersionPruningWindow returns the current value for the XDCR Version Pruning Window for the backing bucket. if forceRefresh is set, we'll always fetch a new value from the bucket, even if we had one cached.

(ctx context.Context, forceRefresh bool)

// GetVersionPruningWindow returns the current value for the XDCR Version Pruning Window for the backing bucket.
// if forceRefresh is set, we'll always fetch a new value from the bucket, even if we had one cached.
func (db *DatabaseContext) GetVersionPruningWindow(ctx context.Context, forceRefresh bool) time.Duration {
	// test override
	if db.Options.TestVersionPruningWindowOverride != nil {
		return *db.Options.TestVersionPruningWindowOverride
	}

	// fetch cached value if available
	if !forceRefresh {
		vpw := db.CachedVersionPruningWindow.Load()
		if vpw != nil {
			return *vpw
		}
	}

	// fetch from server
	cbStore, ok := base.AsCouchbaseBucketStore(db.Bucket)
	if !ok {
		return DefaultVersionPruningWindow
	}

	serverVersionPruningWindow, err := cbStore.VersionPruningWindow(ctx)
	if err != nil {
		base.WarnfCtx(ctx, "Unable to retrieve server's version pruning window - using default %.2f days. %s", DefaultVersionPruningWindow.Hours()/24, err)
	}

	vpw := DefaultVersionPruningWindow
	if serverVersionPruningWindow > 0 {
		vpw = serverVersionPruningWindow
	}

	db.CachedVersionPruningWindow.Store(&vpw)
	return vpw
}

// updateCCVSettings performs a management query to determine the latest crossClusterVersioning and max cas settings.
func (db *DatabaseContext) updateCCVSettings(ctx context.Context) error {