public class DefaultAsyncClusterManager extends Object implements AsyncClusterManager
| Modifier and Type | Method and Description |
|---|---|
static DefaultAsyncClusterManager |
create(String username,
String password,
ConnectionString connectionString,
CouchbaseEnvironment environment,
ClusterFacade core) |
Observable<BucketSettings> |
getBucket(String name)
Returns the
BucketSettings for the Bucket identified by name. |
Observable<BucketSettings> |
getBuckets()
Returns
BucketSettings for all available Buckets. |
Observable<Boolean> |
hasBucket(String name)
Checks if the cluster has a
Bucket identified by the given name. |
Observable<ClusterInfo> |
info()
Provides information about the cluster.
|
Observable<BucketSettings> |
insertBucket(BucketSettings settings)
Inserts a
Bucket with its BucketSettings if it does not already exist. |
Observable<Boolean> |
removeBucket(String name)
Removes a
Bucket identified by its name. |
Observable<BucketSettings> |
updateBucket(BucketSettings settings)
Updates a
Bucket with its BucketSettings if it does already exist. |
public static DefaultAsyncClusterManager create(String username, String password, ConnectionString connectionString, CouchbaseEnvironment environment, ClusterFacade core)
public Observable<ClusterInfo> info()
AsyncClusterManagerProvides information about the cluster.
The Observable can error under the following conditions:
info in interface AsyncClusterManagerClusterInfo object.public Observable<BucketSettings> getBuckets()
AsyncClusterManagerReturns BucketSettings for all available Buckets.
The Observable can error under the following conditions:
getBuckets in interface AsyncClusterManagerBucketSettings.public Observable<BucketSettings> getBucket(String name)
AsyncClusterManagerReturns the BucketSettings for the Bucket identified by name.
The Observable can error under the following conditions:
getBucket in interface AsyncClusterManagername - the name of the bucket.BucketSettings if found or an empty observable if not found.public Observable<Boolean> hasBucket(String name)
AsyncClusterManagerChecks if the cluster has a Bucket identified by the given name.
The Observable can error under the following conditions:
hasBucket in interface AsyncClusterManagername - the name of the bucket.public Observable<Boolean> removeBucket(String name)
AsyncClusterManagerRemoves a Bucket identified by its name.
The Observable can error under the following conditions:
Note: Removing a Bucket is an asynchronous operation on the server side, so even if the response is returned there is no guarantee that the operation has finished on the server itself.
removeBucket in interface AsyncClusterManagername - the name of the bucket.public Observable<BucketSettings> insertBucket(BucketSettings settings)
AsyncClusterManagerInserts a Bucket with its BucketSettings if it does not already exist.
The Observable can error under the following conditions:
Note: Inserting a Bucket is an asynchronous operation on the server side, so even if the response is returned there is no guarantee that the operation has finished on the server itself.
insertBucket in interface AsyncClusterManagersettings - the bucket settings that should be applied.public Observable<BucketSettings> updateBucket(BucketSettings settings)
AsyncClusterManagerUpdates a Bucket with its BucketSettings if it does already exist.
The Observable can error under the following conditions:
Note: Updating a Bucket is an asynchronous operation on the server side, so even if the response is returned there is no guarantee that the operation has finished on the server itself.
updateBucket in interface AsyncClusterManagersettings - the bucket settings that should be applied.Copyright © 2015 Couchbase, Inc.