Package com.couchbase.client.core.config.refresher

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.
Set<String>	registered()	Returns the names of all registered buckets.
Mono<Void>	shutdown()	Permanently shuts down the refresher.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ClusterManagerBucketRefresher

public ClusterManagerBucketRefresher(ConfigurationProvider provider,
 Core core)

Method Details

register

public Mono<Void> register(String name)

Registers a given bucket for http-based config refresh if not already registered.

Specified by:

register in interface BucketRefresher

Parameters:

name - the name of the bucket.

Returns:

the Mono once registered.

deregister

public Mono<Void> deregister(String name)

Description copied from interface: BucketRefresher

Deregisters a bucket from refreshing (stopping the refresh).

Specified by:

deregister in interface BucketRefresher

Parameters:

name - the name of the bucket.

Returns:

a Mono once complete.

shutdown

public Mono<Void> shutdown()

Description copied from interface: BucketRefresher

Permanently shuts down the refresher.

Specified by:

shutdown in interface BucketRefresher

Returns:

a Mono once complete.

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 interface BucketRefresher

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 interface BucketRefresher

Parameters:

name - the name of the bucket.

registered

public Set<String> registered()

Description copied from interface: BucketRefresher

Returns the names of all registered buckets.

Specified by:

registered in interface BucketRefresher

Returns:

all registered buckets.