Method setXDCRBucketSetting

base/main_test_bucket_pool.go:555–584

setXDCRBucketSetting sets the bucket setting "enableCrossClusterVersioning" for mobile XDCR

(ctx context.Context, bucket Bucket)

// setXDCRBucketSetting sets the bucket setting "enableCrossClusterVersioning" for mobile XDCR
func (tbp *TestBucketPool) setXDCRBucketSetting(ctx context.Context, bucket Bucket) {

	tbp.Logf(ctx, "Setting crossClusterVersioningEnabled=true")

	// retry for 1 minute to get this bucket setting, MB-63675
	store, ok := AsCouchbaseBucketStore(bucket)
	if !ok {
		tbp.Fatalf(ctx, "unable to get server management endpoints. Underlying bucket type was not GoCBBucket")
	}

	posts := url.Values{}
	posts.Add("enableCrossClusterVersioning", "true")

	url := fmt.Sprintf("/pools/default/buckets/%s", store.GetName())
	// retry for 1 minute to get this bucket setting, MB-63675
	err, _ := RetryLoop(ctx, "setXDCRBucketSetting", func() (bool, error, interface{}) {
		output, statusCode, err := store.MgmtRequest(ctx, http.MethodPost, url, "application/x-www-form-urlencoded", strings.NewReader(posts.Encode()))
		if err != nil {
			tbp.Fatalf(ctx, "request to mobile XDCR bucket setting failed, status code: %d error: %s output: %s", statusCode, err, string(output))
		}
		if statusCode != http.StatusOK {
			err := fmt.Errorf("request to mobile XDCR bucket setting failed with status code, %d, output: %s", statusCode, string(output))
			return true, err, nil
		}
		return false, nil, nil
	}, CreateMaxDoublingSleeperFunc(200, 500, 500))
	if err != nil {
		tbp.Fatalf(ctx, "Couldn't set crossClusterVersioningEnabled: %v", err)
	}
}

// createCollections will create a set of test collections on the bucket, if enabled...
func (tbp *TestBucketPool) createCollections(ctx context.Context, bucket Bucket) {