Method CreateDataStore

base/collection.go:684–705

CreateDataStore adds a collection from the bucket, and creates a scope if it does not exist. This code is synchronous and waits for the collection to be created.

(ctx context.Context, name sgbucket.DataStoreName)

// CreateDataStore adds a collection from the bucket, and creates a scope if it does not exist. This code is synchronous and waits for the collection to be created.
func (b *GocbV2Bucket) CreateDataStore(ctx context.Context, name sgbucket.DataStoreName) error {
	if b.cluster == nil {
		return fmt.Errorf("bucket %s has been closed", MD(b.GetName()))
	}
	// create scope first (if it doesn't already exist)
	if name.ScopeName() != DefaultScope {
		err := b.bucket.Collections().CreateScope(name.ScopeName(), nil)
		if err != nil && !errors.Is(err, gocb.ErrScopeExists) {
			return err
		}
	}
	err := b.bucket.Collections().CreateCollection(gocb.CollectionSpec{Name: name.CollectionName(), ScopeName: name.ScopeName()}, nil)
	if err != nil {
		return err
	}
	// Can't use Collection.Exists since we can't get a collection until the collection exists on CBS
	gocbCollection := b.bucket.Scope(name.ScopeName()).Collection(name.CollectionName())
	return WaitForNoError(ctx, func() error {
		_, err := gocbCollection.Exists("fakedocid", nil)
		return err
	})
}

// DefaultDataStore returns the default collection for the bucket.
func (b *GocbV2Bucket) DefaultDataStore() sgbucket.DataStore {