Class ClusterManagerRefresher

    • Method Detail

      • register

        public Mono<Void> register​(String name)
        Description copied from interface: Refresher
        Registers a bucket for refreshing.
        Specified by:
        register in interface Refresher
        Parameters:
        name - the name of the bucket.
        Returns:
        a Mono once complete.
      • deregister

        public Mono<Void> deregister​(String name)
        Description copied from interface: Refresher
        Deregisters a bucket from refreshing (stopping the refresh).
        Specified by:
        deregister in interface Refresher
        Parameters:
        name - the name of the bucket.
        Returns:
        a Mono once complete.
      • shutdown

        public Mono<Void> shutdown()
        Description copied from interface: Refresher
        Permanently shuts down the refresher.
        Specified by:
        shutdown in interface Refresher
        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 Refresher
        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 Refresher
        Parameters:
        name - the name of the bucket.