public abstract class AbstractRefresher extends Object implements Refresher
Modifier | Constructor and Description |
---|---|
protected |
AbstractRefresher(CoreEnvironment env,
ClusterFacade cluster)
Creates a new
AbstractRefresher . |
Modifier and Type | Method and Description |
---|---|
protected ClusterFacade |
cluster()
Returns the cluster reference.
|
rx.Observable<ProposedBucketConfigContext> |
configs()
Returns the
Observable which will push out new configuration updates. |
rx.Observable<Boolean> |
deregisterBucket(String name)
De-registers a bucket from watching.
|
protected ConfigurationProvider |
provider() |
void |
provider(ConfigurationProvider provider) |
protected void |
pushConfig(ProposedBucketConfigContext ctx)
Push a
BucketConfig into the config stream. |
rx.Observable<Boolean> |
registerBucket(String name,
String password)
Registers a bucket to be watched for new configurations.
|
rx.Observable<Boolean> |
registerBucket(String name,
String username,
String password)
Registers a bucket to be watched for new configurations.
|
protected Map<String,com.couchbase.client.core.config.refresher.AbstractRefresher.Credential> |
registrations() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
markTainted, markUntainted, refresh, shutdown
protected AbstractRefresher(CoreEnvironment env, ClusterFacade cluster)
AbstractRefresher
.env
- the environmentcluster
- the cluster reference.public rx.Observable<Boolean> deregisterBucket(String name)
Refresher
deregisterBucket
in interface Refresher
Observable
otherwise with the cause.public rx.Observable<Boolean> registerBucket(String name, String password)
Refresher
registerBucket
in interface Refresher
Observable
otherwise with the cause.public rx.Observable<Boolean> registerBucket(String name, String username, String password)
Refresher
registerBucket
in interface Refresher
Observable
otherwise with the cause.public rx.Observable<ProposedBucketConfigContext> configs()
Refresher
Observable
which will push out new configuration updates.protected void pushConfig(ProposedBucketConfigContext ctx)
BucketConfig
into the config stream.ctx
- the config context to push.protected ClusterFacade cluster()
protected ConfigurationProvider provider()
public void provider(ConfigurationProvider provider)
Copyright © 2021 Couchbase, Inc.. All rights reserved.