Class ClusterManagerBucketRefresher
java.lang.Object
com.couchbase.client.core.config.refresher.ClusterManagerBucketRefresher
- All Implemented Interfaces:
BucketRefresher
public class ClusterManagerBucketRefresher extends Object implements BucketRefresher
-
Constructor Summary
Constructors Constructor Description ClusterManagerBucketRefresher(ConfigurationProvider provider, Core core)
-
Method Summary
Modifier and Type Method Description Mono<Void>
deregister(String name)
Deregisters a bucket from refreshing (stopping the refresh).void
markTainted(String name)
No action needed when a config is marked as tainted for the cluster manager refresher, since the server pushes new configs anyways during rebalance.void
markUntainted(String name)
No action needed when a config is marked as untainted for the cluster manager refresher, since the server pushes new configs anyways during rebalance.Mono<Void>
register(String name)
Registers a given bucket for http-based config refresh if not already registered.Mono<Void>
shutdown()
Permanently shuts down the refresher.
-
Constructor Details
-
ClusterManagerBucketRefresher
-
-
Method Details
-
register
Registers a given bucket for http-based config refresh if not already registered.- Specified by:
register
in interfaceBucketRefresher
- Parameters:
name
- the name of the bucket.- Returns:
- the Mono once registered.
-
deregister
Description copied from interface:BucketRefresher
Deregisters a bucket from refreshing (stopping the refresh).- Specified by:
deregister
in interfaceBucketRefresher
- Parameters:
name
- the name of the bucket.- Returns:
- a
Mono
once complete.
-
shutdown
Description copied from interface:BucketRefresher
Permanently shuts down the refresher.- Specified by:
shutdown
in interfaceBucketRefresher
- Returns:
- a
Mono
once complete.
-
markTainted
No action needed when a config is marked as tainted for the cluster manager refresher, since the server pushes new configs anyways during rebalance.- Specified by:
markTainted
in interfaceBucketRefresher
- Parameters:
name
- the name of the bucket.
-
markUntainted
No action needed when a config is marked as untainted for the cluster manager refresher, since the server pushes new configs anyways during rebalance.- Specified by:
markUntainted
in interfaceBucketRefresher
- Parameters:
name
- the name of the bucket.
-