Class CarrierRefresher

java.lang.Object
com.couchbase.client.core.config.refresher.AbstractRefresher
com.couchbase.client.core.config.refresher.CarrierRefresher
All Implemented Interfaces:
Refresher

public class CarrierRefresher
extends AbstractRefresher
Keeps the bucket config fresh through carrier configuration management.
Since:
1.0
Author:
Michael Nitschinger
  • Constructor Details

  • Method Details

    • shutdown

      public rx.Observable<Boolean> shutdown()
      Description copied from interface: Refresher
      Shuts down all open registration streams.
      Returns:
      true if succeeded, a failing Observable otherwise with the cause.
    • markTainted

      public void markTainted​(BucketConfig config)
      Description copied from interface: Refresher
      Marks the given bucket as tainted.
      Parameters:
      config - the config of the bucket that should be marked.
    • markUntainted

      public void markUntainted​(BucketConfig config)
      Description copied from interface: Refresher
      Mark the given bucket as not tainted.
      Parameters:
      config - the config of the bucket that should not be marked anymore.
    • refresh

      public void refresh​(ClusterConfig config)
      Description copied from interface: Refresher
      If pull based, refresh configs for registered buckets.