public class CarrierRefresher extends AbstractRefresher
Keeps the bucket config fresh through carrier configuration management.
Constructor and Description |
---|
CarrierRefresher(CoreEnvironment environment,
ClusterFacade cluster) |
Modifier and Type | Method and Description |
---|---|
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> |
shutdown()
Shuts down all open registration streams.
|
cluster, configs, deregisterBucket, provider, provider, pushConfig, registerBucket, registrations
public CarrierRefresher(CoreEnvironment environment, ClusterFacade cluster)
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.