feat:support auth.

Author: SkyeBeFreeman

polaris-plugins/polaris-plugins-connector/connector-common/src/main/java/com/tencent/polaris/plugins/connector/common/DestroyableServerConnector.java

@@ -23,9 +23,10 @@
 import com.tencent.polaris.api.pojo.Services;
 import com.tencent.polaris.logging.LoggerFactory;
 import com.tencent.polaris.plugins.connector.common.constant.ServiceUpdateTaskConstant.Status;
+import org.slf4j.Logger;
+
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
-import org.slf4j.Logger;
 
 /**
  * Destroyable server connector.
@@ -52,7 +53,7 @@ public abstract class DestroyableServerConnector extends Destroyable implements
      */
     public void retryServiceUpdateTask(ServiceUpdateTask updateTask) {
         LOG.info("[ServerConnector]retry schedule task for {}, retry delay {}", updateTask, TASK_RETRY_INTERVAL_MS);
-        updateTask.setStatus(Status.RUNNING, Status.READY);
+        updateTask.setStatus(Status.RUNNING, Status.READY, true);
         if (isDestroyed()) {
             return;
         }

polaris-plugins/polaris-plugins-connector/connector-common/src/main/java/com/tencent/polaris/plugins/connector/common/ServiceUpdateTask.java

@@ -83,10 +83,14 @@ public boolean setType(Type last, Type current) {
         return taskType.compareAndSet(last, current);
     }
 
-    public boolean setStatus(Status last, Status current) {
+    public boolean setStatus(Status last, Status current, boolean isSpread) {
         return taskStatus.compareAndSet(last, current);
     }
 
+    public boolean setStatus(Status last, Status current) {
+        return setStatus(last, current, false);
+    }
+
     public void setLastUpdateTime(long currentTime) {
         lastUpdateTime.set(currentTime);
     }

polaris-plugins/polaris-plugins-connector/connector-composite/src/main/java/com/tencent/polaris/plugins/connector/composite/CompositeServiceUpdateTask.java

@@ -113,7 +113,6 @@ public void execute() {
                 entry.getValue().execute(this);
             }
         }
-        // TODO 全部规则实现完后改成StringUtils.equals(mainConnectorType, SERVER_CONNECTOR_CONSUL)
         if (ifMainConnectorTypeSet && isServiceUpdateTaskExecuted
                 && (StringUtils.equals(mainConnectorType, SERVER_CONNECTOR_GRPC)
                 || (serviceEventKey.getEventType().equals(EventType.INSTANCE)
@@ -408,6 +407,15 @@ public boolean notifyServerEvent(ServerEvent serverEvent) {
         return svcDeleted;
     }
 
+    public boolean setStatus(Status last, Status current, boolean isSpread) {
+        if (isSpread) {
+            for (Map.Entry<String, ServiceUpdateTask> entry : subServiceUpdateTaskMap.entrySet()) {
+                entry.getValue().setStatus(last, current);
+            }
+        }
+        return taskStatus.compareAndSet(last, current);
+    }
+
     private boolean canExecute(String connectorType, ServiceUpdateTask serviceUpdateTask) {
         boolean canConnectorExecute = StringUtils.equalsIgnoreCase(mainConnectorType, connectorType)
                 || serviceEventKey.getEventType().equals(EventType.INSTANCE)