Class ClusterManagerBucketRefresher

    • Constructor Detail

    • Method Detail

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