public class ClusterManagerBucketRefresher extends Object implements BucketRefresher
Constructor and Description |
---|
ClusterManagerBucketRefresher(ConfigurationProvider provider,
Core core) |
Modifier and Type | Method and 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.
|
public ClusterManagerBucketRefresher(ConfigurationProvider provider, Core core)
public Mono<Void> register(String name)
register
in interface BucketRefresher
name
- the name of the bucket.public Mono<Void> deregister(String name)
BucketRefresher
deregister
in interface BucketRefresher
name
- the name of the bucket.Mono
once complete.public Mono<Void> shutdown()
BucketRefresher
shutdown
in interface BucketRefresher
Mono
once complete.public void markTainted(String name)
markTainted
in interface BucketRefresher
name
- the name of the bucket.public void markUntainted(String name)
markUntainted
in interface BucketRefresher
name
- the name of the bucket.public Set<String> registered()
BucketRefresher
registered
in interface BucketRefresher
Copyright © 2024 Couchbase, Inc.. All rights reserved.