Class CarrierRefresher
- java.lang.Object
-
- com.couchbase.client.core.config.refresher.AbstractRefresher
-
- com.couchbase.client.core.config.refresher.CarrierRefresher
-
- All Implemented Interfaces:
Refresher
public class CarrierRefresher extends AbstractRefresher
Keeps the bucket config fresh through carrier configuration management.- Since:
- 1.0
- Author:
- Michael Nitschinger
-
-
Constructor Summary
Constructors Constructor Description CarrierRefresher(CoreEnvironment environment, ClusterFacade cluster)
Creates a newCarrierRefresher
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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<Boolean>
shutdown()
Shuts down all open registration streams.-
Methods inherited from class com.couchbase.client.core.config.refresher.AbstractRefresher
cluster, configs, deregisterBucket, provider, provider, pushConfig, registerBucket, registerBucket, registrations
-
-
-
-
Constructor Detail
-
CarrierRefresher
public CarrierRefresher(CoreEnvironment environment, ClusterFacade cluster)
Creates a newCarrierRefresher
.- Parameters:
environment
- the environment to use.cluster
- the cluster reference.
-
-
Method Detail
-
shutdown
public rx.Observable<Boolean> shutdown()
Description copied from interface:Refresher
Shuts down all open registration streams.- Returns:
- true if succeeded, a failing
Observable
otherwise with the cause.
-
markTainted
public void markTainted(BucketConfig config)
Description copied from interface:Refresher
Marks the given bucket as tainted.- Parameters:
config
- the config of the bucket that should be marked.
-
markUntainted
public void markUntainted(BucketConfig config)
Description copied from interface:Refresher
Mark the given bucket as not tainted.- Parameters:
config
- the config of the bucket that should not be marked anymore.
-
refresh
public void refresh(ClusterConfig config)
Description copied from interface:Refresher
If pull based, refresh configs for registered buckets.
-
-