Method updateCCVSettings

db/database.go:1685–1710

updateCCVSettings performs a management query to determine the latest crossClusterVersioning and max cas settings.

(ctx context.Context)

// updateCCVSettings performs a management query to determine the latest crossClusterVersioning and max cas settings.
func (db *DatabaseContext) updateCCVSettings(ctx context.Context) error {
	cbStore, ok := base.AsCouchbaseBucketStore(db.Bucket)
	if !ok {
		// for rosmar, ECCV is always enabled, mark starting cas as 0
		db.CachedCCVEnabled.Store(true)
		for vbNo := range db.numVBuckets {
			db.CachedCCVStartingCas.Store(base.VBNo(vbNo), 0)
		}
		return nil
	}

	// Fetch from Couchbase Server
	enabled, maxCAS, err := cbStore.GetCCVSettings(ctx)
	if err != nil {
		return fmt.Errorf("Unable to retrieve server's CCV Starting CAS: %w", err)
	}

	db.CachedCCVEnabled.Store(enabled)
	if !enabled {
		db.CachedCCVStartingCas.Clear()
	}
	for vbNo, cas := range maxCAS {
		db.CachedCCVStartingCas.Store(vbNo, cas)
	}
	return nil
}

func (c *DatabaseCollection) updateAllPrincipalsSequences(ctx context.Context) error {
	users, roles, err := c.allPrincipalIDs(ctx)