public interface Refresher
A 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<BucketConfig> |
configs()
Returns the
Observable which will push out new configuration updates. |
rx.Observable<java.lang.Boolean> |
deregisterBucket(java.lang.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<java.lang.Boolean> |
registerBucket(java.lang.String name,
java.lang.String password)
Registers a bucket to be watched for new configurations.
|
rx.Observable<java.lang.Boolean> |
shutdown()
Shuts down all open registration streams.
|
rx.Observable<BucketConfig> configs()
Returns the Observable
which will push out new configuration updates.
rx.Observable<java.lang.Boolean> registerBucket(java.lang.String name, java.lang.String password)
Registers a bucket to be watched for new configurations.
Observable
otherwise with the cause.rx.Observable<java.lang.Boolean> deregisterBucket(java.lang.String name)
De-registers a bucket from watching.
Observable
otherwise with the cause.rx.Observable<java.lang.Boolean> shutdown()
Shuts down all open registration streams.
Observable
otherwise with the cause.void markTainted(BucketConfig config)
Marks the given bucket as tainted.
config
- void markUntainted(BucketConfig config)
Mark the given bucket as not tainted.
config
- void refresh(ClusterConfig config)
If pull based, refresh configs for registered buckets.
void provider(ConfigurationProvider provider)