docs: @Override
      public void shutdown() {
          if (state.get() == NodeState.Shutdown) {
              return;
          }
          balancingPolicy.shutdown();
          if (autoRebalanceFuture != null) {
              autoRebalanceFuture.cancel(true);
          }
          LOG.info("Shutdown initiated; beginning drain...");
          setState(NodeState.Draining);
          balancingPolicy.drainToCount(0, true);
      }