feat:support fault injection.

Author: SkyeBeFreeman

polaris-fault/polaris-fault-api/src/main/java/com/tencent/polaris/fault/api/rpc/FaultRequest.java

@@ -17,34 +17,34 @@
 
 package com.tencent.polaris.fault.api.rpc;
 
-import com.tencent.polaris.api.rpc.RequestBaseEntity;
+import com.tencent.polaris.api.pojo.ServiceKey;
 import com.tencent.polaris.metadata.core.manager.MetadataContext;
 
 /**
  * 故障注入请求
  *
  * @author Haotian Zhang
  */
-public class FaultRequest extends RequestBaseEntity {
+public class FaultRequest {
 
-    private final String namespace;
+    private final ServiceKey sourceService;
 
-    private final String service;
+    private final ServiceKey targetService;
 
     private final MetadataContext metadataContext;
 
-    public FaultRequest(String namespace, String service, MetadataContext metadataContext) {
-        this.namespace = namespace;
-        this.service = service;
+    public FaultRequest(String sourceNamespace, String sourceService, String targetNamespace, String targetService, MetadataContext metadataContext) {
+        this.sourceService = new ServiceKey(sourceNamespace, sourceService);
+        this.targetService = new ServiceKey(targetNamespace, targetService);
         this.metadataContext = metadataContext;
     }
 
-    public String getNamespace() {
-        return namespace;
+    public ServiceKey getSourceService() {
+        return sourceService;
     }
 
-    public String getService() {
-        return service;
+    public ServiceKey getTargetService() {
+        return targetService;
     }
 
     public MetadataContext getMetadataContext() {
@@ -54,8 +54,8 @@ public MetadataContext getMetadataContext() {
     @Override
     public String toString() {
         return "FaultRequest{" +
-                "namespace='" + namespace + '\'' +
-                ", service='" + service + '\'' +
+                "sourceService=" + sourceService +
+                ", targetService=" + targetService +
                 ", metadataContext=" + metadataContext +
                 '}';
     }

polaris-fault/polaris-fault-client/src/main/java/com/tencent/polaris/fault/client/flow/DefaultFaultFlow.java

@@ -81,16 +81,15 @@ public FaultResponse fault(FaultRequest faultRequest) throws PolarisException {
         }
 
         FaultResponse faultResponse = new FaultResponse(false);
-        ServiceKey serviceKey = new ServiceKey(faultRequest.getNamespace(), faultRequest.getService());
-        List<FaultInjectionProto.FaultInjection> faultInjectionRules = getFaultInjectionRules(serviceKey);
+        List<FaultInjectionProto.FaultInjection> faultInjectionRules = getFaultInjectionRules(faultRequest.getTargetService());
         if (CollectionUtils.isNotEmpty(faultInjectionRules)) {
             for (FaultInjectionProto.FaultInjection faultInjection : faultInjectionRules) {
                 if (faultInjection != null && faultInjection.getEnabled().getValue()) {
                     LOG.debug("FaultInjectionProto.FaultInjection:{}", faultInjection);
 
                     // 匹配source规则
                     boolean sourceMatched = matchSource(faultInjection.getSourcesList(),
-                            serviceKey, faultRequest.getMetadataContext().getMetadataContainerGroup(false));
+                            faultRequest.getSourceService(), faultRequest.getMetadataContext().getMetadataContainerGroup(false));
                     if (!sourceMatched) {
                         LOG.debug("Source not matched, skipping fault injection. FaultInjectionProto.FaultInjection:{}", faultInjection);
                         continue;

polaris-fault/polaris-fault-client/src/main/java/com/tencent/polaris/fault/client/utils/FaultValidator.java

@@ -34,6 +34,7 @@ public static void validateFaultRequest(FaultRequest faultRequest) throws Polari
         if (null == faultRequest) {
             throw new PolarisException(ErrorCode.API_INVALID_ARGUMENT, "FaultRequest can not be null");
         }
-        CommonValidator.validateNamespaceService(faultRequest.getNamespace(), faultRequest.getService());
+        CommonValidator.validateService(faultRequest.getSourceService());
+        CommonValidator.validateService(faultRequest.getTargetService());
     }
 }