Class ClusterManagerBucketRefresher

java.lang.Object
com.couchbase.client.core.config.refresher.ClusterManagerBucketRefresher
All Implemented Interfaces:
BucketRefresher

public class ClusterManagerBucketRefresher extends Object implements BucketRefresher
  • Constructor Details

  • 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.