Method DeleteMetadataDocument

base/bootstrap.go:367–380

(ctx context.Context, location, key string, cas uint64)

}

func (cc *CouchbaseCluster) DeleteMetadataDocument(ctx context.Context, location, key string, cas uint64) (err error) {
	if cc == nil {
		return errors.New("nil CouchbaseCluster")
	}

	b, teardown, err := cc.getBucket(ctx, location)
	if err != nil {
		return err
	}
	defer teardown()

	_, removeErr := cc.configPersistence.removeRawConfig(b.DefaultCollection(), key, gocb.Cas(cas))
	return removeErr
}

// UpdateMetadataDocument retries on CAS mismatch
func (cc *CouchbaseCluster) UpdateMetadataDocument(ctx context.Context, location, docID string, updateCallback func(bucketConfig []byte, rawBucketConfigCas uint64) (newConfig []byte, err error)) (newCAS uint64, err error) {