public interface Refresher
Refresher
keeps bucket configs up to date.
The refresher is the companion behavior to the loader. The loader does the initial loading and the refresher does
its best to keep the ConfigurationProvider
informed with an up-to-date configuration for a bucket.Modifier and Type | Method and Description |
---|---|
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.
|
void |
markTainted(BucketConfig config)
Marks the given bucket as tainted.
|
void |
markUntainted(BucketConfig config)
Mark the given bucket as not tainted.
|
void |
provider(ConfigurationProvider provider) |
void |
refresh(ClusterConfig config)
If pull based, refresh configs for registered buckets.
|
rx.Observable<Boolean> |
registerBucket(String name,
String password)
Deprecated.
|
rx.Observable<Boolean> |
registerBucket(String name,
String username,
String password)
Registers a bucket to be watched for new configurations.
|
rx.Observable<Boolean> |
shutdown()
Shuts down all open registration streams.
|
rx.Observable<ProposedBucketConfigContext> configs()
Observable
which will push out new configuration updates.@Deprecated rx.Observable<Boolean> registerBucket(String name, String password)
Observable
otherwise with the cause.rx.Observable<Boolean> registerBucket(String name, String username, String password)
Observable
otherwise with the cause.rx.Observable<Boolean> deregisterBucket(String name)
Observable
otherwise with the cause.rx.Observable<Boolean> shutdown()
Observable
otherwise with the cause.void markTainted(BucketConfig config)
config
- the config of the bucket that should be marked.void markUntainted(BucketConfig config)
config
- the config of the bucket that should not be marked anymore.void refresh(ClusterConfig config)
void provider(ConfigurationProvider provider)
Copyright © 2021 Couchbase, Inc.. All rights reserved.