fix: faultinjection ui

Author: spring-young

pkg/manager/controllers/circuitbreaker/event_handler.go

@@ -18,6 +18,7 @@ package circuitbreaker
 
 import (
 	"context"
+	"reflect"
 
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -126,7 +127,9 @@ func matchChangedBreakers(c client.Reader, old, new *v1.Pod) ([]*ctrlmeshv1alpha
 		}
 		oldMatch := selector.Matches(labels.Set(old.Labels))
 		newMatch := selector.Matches(labels.Set(new.Labels))
-		if oldMatch != newMatch {
+		oldStatus := old.Status 
+		newStatus := new.Status 
+		if oldMatch != newMatch || !reflect.DeepEqual(oldStatus, newStatus) {
 			res = append(res, &breakers.Items[i])
 		}
 	}

pkg/manager/controllers/faultinjection/event_handler.go

@@ -18,6 +18,7 @@ package faultinjection
 
 import (
 	"context"
+	"reflect"
 
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -127,7 +128,9 @@ func matchChangedFaults(c client.Reader, old, new *v1.Pod) ([]*ctrlmeshv1alpha1.
 		}
 		oldMatch := selector.Matches(labels.Set(old.Labels))
 		newMatch := selector.Matches(labels.Set(new.Labels))
-		if oldMatch != newMatch {
+		oldStatus := old.Status
+		newStatus := new.Status
+		if oldMatch != newMatch || !reflect.DeepEqual(oldStatus, newStatus) {
 			res = append(res, &faults.Items[i])
 		}
 	}

pkg/manager/controllers/faultinjection/faultinject_controller.go

@@ -44,6 +44,7 @@ import (
 	"github.com/KusionStack/controller-mesh/pkg/apis/ctrlmesh/proto/protoconnect"
 	"github.com/KusionStack/controller-mesh/pkg/apis/ctrlmesh/utils/conv"
 	ctrlmeshv1alpha1 "github.com/KusionStack/controller-mesh/pkg/apis/ctrlmesh/v1alpha1"
+	"github.com/KusionStack/controller-mesh/pkg/proxy/grpcserver"
 	"github.com/KusionStack/controller-mesh/pkg/utils"
 )
 
@@ -161,7 +162,7 @@ func (r *FaultInjectionReconciler) Reconcile(ctx context.Context, req ctrl.Reque
 	}
 	fi.Status = *status
 	if err := r.Status().Update(ctx, fi); err != nil {
-		klog.Errorf("fail to update circuit breaker %s status", utils.KeyFunc(fi))
+		klog.Errorf("fail to update fault injection %s status", utils.KeyFunc(fi))
 		reconcileErr = errors.Join(reconcileErr, err)
 	}
 	return ctrl.Result{}, reconcileErr
@@ -279,7 +280,7 @@ func protoClient(podIp string) protoconnect.FaultInjectClient {
 }
 
 func podAddr(podIp string) string {
-	return fmt.Sprintf("https://%s:%d", podIp, constants.ProxyGRPCServerPort)
+	return fmt.Sprintf("https://%s:%d", podIp, grpcserver.GrpcServerPort)
 }
 
 // isProxyAvailable check whether the proxy container is available

pkg/manager/controllers/faultinjection/faultinjection_controller_test.go

@@ -79,7 +79,7 @@ var faultInjection = &ctrlmeshv1alpha1.FaultInjection{
 			{
 				Delay: &ctrlmeshv1alpha1.HTTPFaultInjectionDelay{
 					Percent:    "100",
-					FixedDelay: "20s",
+					FixedDelay: "20ms",
 				},
 				Match: &ctrlmeshv1alpha1.Match{
 					Resources: []*ctrlmeshv1alpha1.ResourceMatch{