public class HttpRefresher extends AbstractRefresher
Keeps the bucket config fresh through a HTTP streaming connection.
Constructor and Description |
---|
HttpRefresher(ClusterFacade cluster) |
Modifier and Type | Method and Description |
---|---|
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 |
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.
|
cluster, configs, provider, provider, pushConfig, registrations
public HttpRefresher(ClusterFacade cluster)
public rx.Observable<java.lang.Boolean> registerBucket(java.lang.String name, java.lang.String password)
Refresher
Registers a bucket to be watched for new configurations.
registerBucket
in interface Refresher
registerBucket
in class AbstractRefresher
Observable
otherwise with the cause.public rx.Observable<java.lang.Boolean> deregisterBucket(java.lang.String name)
Refresher
De-registers a bucket from watching.
deregisterBucket
in interface Refresher
deregisterBucket
in class AbstractRefresher
Observable
otherwise with the cause.public rx.Observable<java.lang.Boolean> shutdown()
Refresher
Shuts down all open registration streams.
Observable
otherwise with the cause.public void markTainted(BucketConfig config)
Refresher
Marks the given bucket as tainted.
public void markUntainted(BucketConfig config)
Refresher
Mark the given bucket as not tainted.
public void refresh(ClusterConfig config)
Refresher
If pull based, refresh configs for registered buckets.