Class ClusterManagerRefresher
- java.lang.Object
-
- com.couchbase.client.core.config.refresher.ClusterManagerRefresher
-
-
Constructor Summary
Constructors Constructor Description ClusterManagerRefresher(ConfigurationProvider provider, Core core)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Flux<ProposedBucketConfigContext>
configs()
Whenever a new config is loaded, it is pushed through this stream to be consumed.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 bucket for refreshing.Mono<Void>
shutdown()
Permanently shuts down the refresher.
-
-
-
Constructor Detail
-
ClusterManagerRefresher
public ClusterManagerRefresher(ConfigurationProvider provider, Core core)
-
-
Method Detail
-
register
public Mono<Void> register(String name)
Description copied from interface:Refresher
Registers a bucket for refreshing.
-
deregister
public Mono<Void> deregister(String name)
Description copied from interface:Refresher
Deregisters a bucket from refreshing (stopping the refresh).- Specified by:
deregister
in interfaceRefresher
- Parameters:
name
- the name of the bucket.- Returns:
- a
Mono
once complete.
-
shutdown
public Mono<Void> shutdown()
Description copied from interface:Refresher
Permanently shuts down the refresher.
-
configs
public Flux<ProposedBucketConfigContext> configs()
Description copied from interface:Refresher
Whenever a new config is loaded, it is pushed through this stream to be consumed.
-
markTainted
public 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.- Specified by:
markTainted
in interfaceRefresher
- Parameters:
name
- the name of the bucket.
-
markUntainted
public 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.- Specified by:
markUntainted
in interfaceRefresher
- Parameters:
name
- the name of the bucket.
-
-