Add ci

Author: jiangpengcheng

.ci/tests/integration/cases/functionmesh-with-generic-resources/manifests.yaml

@@ -1,7 +1,7 @@
 apiVersion: compute.functionmesh.io/v1alpha1
 kind: FunctionMesh
 metadata:
-  name: functionmesh-generic-resources-sample
+  name: functionmesh-generic-sample
 spec:
   genericResources:
     - apiVersion: "compute.functionmesh.io/v1alpha1"

.ci/tests/integration/cases/functionmesh-with-generic-resources/verify.sh

@@ -36,21 +36,21 @@ manifests_file="${BASE_DIR}"/.ci/tests/integration/cases/functionmesh-with-gener
 
 kubectl apply -f "${manifests_file}" > /dev/null 2>&1
 
-verify_fm_result=$(ci::verify_function_mesh functionmesh-generic-resources-sample-java-function 2>&1)
+verify_fm_result=$(ci::verify_function_mesh functionmesh-generic-sample-java-function 2>&1)
 if [ $? -ne 0 ]; then
   echo "$verify_fm_result"
   kubectl delete -f "${manifests_file}" > /dev/null 2>&1 || true
   exit 1
 fi
 
-verify_fm_result=$(ci::verify_function_mesh functionmesh-generic-resources-sample-golang-function 2>&1)
+verify_fm_result=$(ci::verify_function_mesh functionmesh-generic-sample-golang-function 2>&1)
 if [ $? -ne 0 ]; then
   echo "$verify_fm_result"
   kubectl delete -f "${manifests_file}" > /dev/null 2>&1 || true
   exit 1
 fi
 
-verify_fm_result=$(ci::verify_function_mesh functionmesh-generic-resources-sample-python-function 2>&1)
+verify_fm_result=$(ci::verify_function_mesh functionmesh-generic-sample-python-function 2>&1)
 if [ $? -ne 0 ]; then
   echo "$verify_fm_result"
   kubectl delete -f "${manifests_file}" > /dev/null 2>&1 || true

.ci/tests/integration/e2e_with_tls.yaml

@@ -131,3 +131,5 @@ verify:
       expected: expected.data.yaml
     - query: timeout 5m bash .ci/tests/integration/cases/global-and-namespaced-config/verify.sh
       expected: expected.data.yaml
+    - query: timeout 5m bash .ci/tests/integration/cases/functionmesh-generic-resources/verify.sh
+      expected: expected.data.yaml

controllers/function_mesh.go

@@ -251,7 +251,7 @@ func (r *FunctionMeshReconciler) observeGenericResources(ctx context.Context, me
 		condition, ok := mesh.Status.GenericResourceConditions[resource.Name]
 		if !ok {
 			mesh.Status.GenericResourceConditions[resource.Name] = v1alpha1.ResourceCondition{
-				Condition:  v1alpha1.SinkReady,
+				Condition:  v1alpha1.GenericResourceReady,
 				Status:     metav1.ConditionFalse,
 				Action:     v1alpha1.Create,
 				ApiVersion: resource.APIVersion,

controllers/functionmesh_controller.go

@@ -72,6 +72,9 @@ func (r *FunctionMeshReconciler) Reconcile(ctx context.Context, req ctrl.Request
 	if mesh.Status.SinkConditions == nil {
 		mesh.Status.SinkConditions = make(map[string]v1alpha1.ResourceCondition)
 	}
+	if mesh.Status.GenericResourceConditions == nil {
+		mesh.Status.GenericResourceConditions = make(map[string]v1alpha1.ResourceCondition)
+	}
 	if mesh.Status.Condition == nil {
 		mesh.Status.Condition = &v1alpha1.ResourceCondition{}
 	}

controllers/spec/common.go

@@ -39,6 +39,7 @@ import (
 	autoscalingv2beta2 "k8s.io/api/autoscaling/v2beta2"
 	v1 "k8s.io/api/batch/v1"
 	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/equality"
 	k8serrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
@@ -2058,7 +2059,7 @@ func CheckIfStatefulSetSpecIsEqual(spec *appsv1.StatefulSetSpec, desiredSpec *ap
 					container.ImagePullPolicy != desiredContainer.ImagePullPolicy ||
 					!reflect.DeepEqual(ports, desiredPorts) ||
 					!reflect.DeepEqual(containerEnvFrom, desiredContainerEnvFrom) ||
-					!reflect.DeepEqual(container.Resources, desiredContainer.Resources) {
+					!equality.Semantic.DeepEqual(container.Resources, desiredContainer.Resources) {
 					return false
 				}