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

Class GlobalRefresher

java.lang.Object
com.couchbase.client.core.config.refresher.GlobalRefresher
public class GlobalRefresher extends Object
The GlobalRefresher keeps the cluster-level global config up-to-date.

It works very similar to the KeyValueBucketRefresher, but explicitly has no bucket level scope. It can be started and stopped, since there might be situations where global config polling is not needed.

  • Constructor Details

    • GlobalRefresher

      public GlobalRefresher(ConfigurationProvider provider, Core core)
      Creates a new global refresher.
      Parameters:
      provider - the config provider which should get the config updates proposed.
      core - the core to send the config commands to.

  • Method Details

    • pollerInterval

      protected Duration pollerInterval()
      Allows to override the default poller interval in tests to speed them up.
      Returns:
      the poller interval as a duration.

    • start

      public Mono<Void> start()
      Starts the GlobalRefresher.

      Refreshing can be started and stopped multiple times until the non-reversible shutdown() is called.

      Returns:
      a Mono completing when started.

    • stop

      public Mono<Void> stop()
      Stops the GlobalRefresher.

      Refreshing can be started and stopped multiple times until the non-reversible shutdown() is called.

      Returns:
      a Mono completing when stopped.

    • shutdown

      public Mono<Void> shutdown()
      Permanently shuts down this GlobalRefresher.
      Returns:
      a Mono completing when shutdown completed.