Class HttpRefresher

  • All Implemented Interfaces:
    Refresher

    public class HttpRefresher
    extends AbstractRefresher
    Keeps the bucket config fresh through a HTTP streaming connection.
    Since:
    1.0
    Author:
    Michael Nitschinger
    • Method Detail

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