| // Copyright Istio Authors |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| package object |
| |
| import ( |
| "strings" |
| "testing" |
| ) |
| |
| import ( |
| "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" |
| ) |
| |
| import ( |
| "github.com/apache/dubbo-go-pixiu/operator/pkg/util" |
| ) |
| |
| func TestHash(t *testing.T) { |
| hashTests := []struct { |
| desc string |
| kind string |
| namespace string |
| name string |
| want string |
| }{ |
| {"CalculateHashForObjectWithNormalCharacter", "Service", "default", "ingressgateway", "Service:default:ingressgateway"}, |
| {"CalculateHashForObjectWithDash", "Deployment", "dubbo-system", "istio-pilot", "Deployment:dubbo-system:istio-pilot"}, |
| {"CalculateHashForObjectWithDot", "ConfigMap", "dubbo-system", "my.config", "ConfigMap:dubbo-system:my.config"}, |
| } |
| |
| for _, tt := range hashTests { |
| t.Run(tt.desc, func(t *testing.T) { |
| got := Hash(tt.kind, tt.namespace, tt.name) |
| if got != tt.want { |
| t.Errorf("Hash(%s): got %s for kind %s, namespace %s, name %s, want %s", tt.desc, got, tt.kind, tt.namespace, tt.name, tt.want) |
| } |
| }) |
| } |
| } |
| |
| func TestFromHash(t *testing.T) { |
| hashTests := []struct { |
| desc string |
| hash string |
| kind string |
| namespace string |
| name string |
| }{ |
| {"ParseHashWithNormalCharacter", "Service:default:ingressgateway", "Service", "default", "ingressgateway"}, |
| {"ParseHashForObjectWithDash", "Deployment:dubbo-system:istio-pilot", "Deployment", "dubbo-system", "istio-pilot"}, |
| {"ParseHashForObjectWithDot", "ConfigMap:dubbo-system:my.config", "ConfigMap", "dubbo-system", "my.config"}, |
| {"InvalidHash", "test", "Bad hash string: test", "", ""}, |
| } |
| |
| for _, tt := range hashTests { |
| t.Run(tt.desc, func(t *testing.T) { |
| k, ns, name := FromHash(tt.hash) |
| if k != tt.kind || ns != tt.namespace || name != tt.name { |
| t.Errorf("FromHash(%s): got kind %s, namespace %s, name %s, want kind %s, namespace %s, name %s", tt.desc, k, ns, name, tt.kind, tt.namespace, tt.name) |
| } |
| }) |
| } |
| } |
| |
| func TestHashNameKind(t *testing.T) { |
| hashNameKindTests := []struct { |
| desc string |
| kind string |
| name string |
| want string |
| }{ |
| {"CalculateHashNameKindForObjectWithNormalCharacter", "Service", "ingressgateway", "Service:ingressgateway"}, |
| {"CalculateHashNameKindForObjectWithDash", "Deployment", "istio-pilot", "Deployment:istio-pilot"}, |
| {"CalculateHashNameKindForObjectWithDot", "ConfigMap", "my.config", "ConfigMap:my.config"}, |
| } |
| |
| for _, tt := range hashNameKindTests { |
| t.Run(tt.desc, func(t *testing.T) { |
| got := HashNameKind(tt.kind, tt.name) |
| if got != tt.want { |
| t.Errorf("HashNameKind(%s): got %s for kind %s, name %s, want %s", tt.desc, got, tt.kind, tt.name, tt.want) |
| } |
| }) |
| } |
| } |
| |
| func TestParseJSONToK8sObject(t *testing.T) { |
| testDeploymentJSON := `{ |
| "apiVersion": "apps/v1", |
| "kind": "Deployment", |
| "metadata": { |
| "name": "istio-citadel", |
| "namespace": "dubbo-system", |
| "labels": { |
| "istio": "citadel" |
| } |
| }, |
| "spec": { |
| "replicas": 1, |
| "selector": { |
| "matchLabels": { |
| "istio": "citadel" |
| } |
| }, |
| "template": { |
| "metadata": { |
| "labels": { |
| "istio": "citadel" |
| } |
| }, |
| "spec": { |
| "containers": [ |
| { |
| "name": "citadel", |
| "image": "docker.io/istio/citadel:1.1.8", |
| "args": [ |
| "--append-dns-names=true", |
| "--grpc-port=8060", |
| "--grpc-hostname=citadel", |
| "--citadel-storage-namespace=dubbo-system", |
| "--custom-dns-names=istio-pilot-service-account.dubbo-system:istio-pilot.dubbo-system", |
| "--monitoring-port=15014", |
| "--self-signed-ca=true" |
| ] |
| } |
| ] |
| } |
| } |
| } |
| }` |
| testPodJSON := `{ |
| "apiVersion": "v1", |
| "kind": "Pod", |
| "metadata": { |
| "name": "istio-galley-75bcd59768-hpt5t", |
| "namespace": "dubbo-system", |
| "labels": { |
| "istio": "galley" |
| } |
| }, |
| "spec": { |
| "containers": [ |
| { |
| "name": "galley", |
| "image": "docker.io/istio/galley:1.1.8", |
| "command": [ |
| "/usr/local/bin/galley", |
| "server", |
| "--meshConfigFile=/etc/mesh-config/mesh", |
| "--livenessProbeInterval=1s", |
| "--livenessProbePath=/healthliveness", |
| "--readinessProbePath=/healthready", |
| "--readinessProbeInterval=1s", |
| "--deployment-namespace=dubbo-system", |
| "--insecure=true", |
| "--validation-webhook-config-file", |
| "/etc/config/validatingwebhookconfiguration.yaml", |
| "--monitoringPort=15014", |
| "--log_output_level=default:info" |
| ], |
| "ports": [ |
| { |
| "containerPort": 443, |
| "protocol": "TCP" |
| }, |
| { |
| "containerPort": 15014, |
| "protocol": "TCP" |
| }, |
| { |
| "containerPort": 9901, |
| "protocol": "TCP" |
| } |
| ] |
| } |
| ] |
| } |
| }` |
| testServiceJSON := `{ |
| "apiVersion": "v1", |
| "kind": "Service", |
| "metadata": { |
| "labels": { |
| "app": "pilot" |
| }, |
| "name": "istio-pilot", |
| "namespace": "dubbo-system" |
| }, |
| "spec": { |
| "clusterIP": "10.102.230.31", |
| "ports": [ |
| { |
| "name": "grpc-xds", |
| "port": 15010, |
| "protocol": "TCP", |
| "targetPort": 15010 |
| }, |
| { |
| "name": "https-xds", |
| "port": 15011, |
| "protocol": "TCP", |
| "targetPort": 15011 |
| }, |
| { |
| "name": "http-legacy-discovery", |
| "port": 8080, |
| "protocol": "TCP", |
| "targetPort": 8080 |
| }, |
| { |
| "name": "http-monitoring", |
| "port": 15014, |
| "protocol": "TCP", |
| "targetPort": 15014 |
| } |
| ], |
| "selector": { |
| "istio": "pilot" |
| }, |
| "sessionAffinity": "None", |
| "type": "ClusterIP" |
| } |
| }` |
| |
| testInvalidJSON := `invalid json` |
| |
| parseJSONToK8sObjectTests := []struct { |
| desc string |
| objString string |
| wantGroup string |
| wantKind string |
| wantName string |
| wantNamespace string |
| wantErr bool |
| }{ |
| {"ParseJsonToK8sDeployment", testDeploymentJSON, "apps", "Deployment", "istio-citadel", "dubbo-system", false}, |
| {"ParseJsonToK8sPod", testPodJSON, "", "Pod", "istio-galley-75bcd59768-hpt5t", "dubbo-system", false}, |
| {"ParseJsonToK8sService", testServiceJSON, "", "Service", "istio-pilot", "dubbo-system", false}, |
| {"ParseJsonError", testInvalidJSON, "", "", "", "", true}, |
| } |
| |
| for _, tt := range parseJSONToK8sObjectTests { |
| t.Run(tt.desc, func(t *testing.T) { |
| k8sObj, err := ParseJSONToK8sObject([]byte(tt.objString)) |
| if err == nil { |
| if tt.wantErr { |
| t.Errorf("ParseJsonToK8sObject(%s): should be error", tt.desc) |
| } |
| k8sObjStr := k8sObj.YAMLDebugString() |
| if k8sObj.Group != tt.wantGroup { |
| t.Errorf("ParseJsonToK8sObject(%s): got group %s for k8s object %s, want %s", tt.desc, k8sObj.Group, k8sObjStr, tt.wantGroup) |
| } |
| if k8sObj.Kind != tt.wantKind { |
| t.Errorf("ParseJsonToK8sObject(%s): got kind %s for k8s object %s, want %s", tt.desc, k8sObj.Kind, k8sObjStr, tt.wantKind) |
| } |
| if k8sObj.Name != tt.wantName { |
| t.Errorf("ParseJsonToK8sObject(%s): got name %s for k8s object %s, want %s", tt.desc, k8sObj.Name, k8sObjStr, tt.wantName) |
| } |
| if k8sObj.Namespace != tt.wantNamespace { |
| t.Errorf("ParseJsonToK8sObject(%s): got group %s for k8s object %s, want %s", tt.desc, k8sObj.Namespace, k8sObjStr, tt.wantNamespace) |
| } |
| } else if !tt.wantErr { |
| t.Errorf("ParseJsonToK8sObject(%s): got unexpected error: %v", tt.desc, err) |
| } |
| }) |
| } |
| } |
| |
| func TestParseYAMLToK8sObject(t *testing.T) { |
| testDeploymentYaml := `apiVersion: apps/v1 |
| kind: Deployment |
| metadata: |
| name: istio-citadel |
| namespace: dubbo-system |
| labels: |
| istio: citadel |
| spec: |
| replicas: 1 |
| selector: |
| matchLabels: |
| istio: citadel |
| template: |
| metadata: |
| labels: |
| istio: citadel |
| spec: |
| containers: |
| - name: citadel |
| image: docker.io/istio/citadel:1.1.8 |
| args: |
| - "--append-dns-names=true" |
| - "--grpc-port=8060" |
| - "--grpc-hostname=citadel" |
| - "--citadel-storage-namespace=dubbo-system" |
| - "--custom-dns-names=istio-pilot-service-account.dubbo-system:istio-pilot.dubbo-system" |
| - "--monitoring-port=15014" |
| - "--self-signed-ca=true"` |
| |
| testPodYaml := `apiVersion: v1 |
| kind: Pod |
| metadata: |
| name: istio-galley-75bcd59768-hpt5t |
| namespace: dubbo-system |
| labels: |
| istio: galley |
| spec: |
| containers: |
| - name: galley |
| image: docker.io/istio/galley:1.1.8 |
| command: |
| - "/usr/local/bin/galley" |
| - server |
| - "--meshConfigFile=/etc/mesh-config/mesh" |
| - "--livenessProbeInterval=1s" |
| - "--livenessProbePath=/healthliveness" |
| - "--readinessProbePath=/healthready" |
| - "--readinessProbeInterval=1s" |
| - "--deployment-namespace=dubbo-system" |
| - "--insecure=true" |
| - "--validation-webhook-config-file" |
| - "/etc/config/validatingwebhookconfiguration.yaml" |
| - "--monitoringPort=15014" |
| - "--log_output_level=default:info" |
| ports: |
| - containerPort: 443 |
| protocol: TCP |
| - containerPort: 15014 |
| protocol: TCP |
| - containerPort: 9901 |
| protocol: TCP` |
| |
| testServiceYaml := `apiVersion: v1 |
| kind: Service |
| metadata: |
| labels: |
| app: pilot |
| name: istio-pilot |
| namespace: dubbo-system |
| spec: |
| clusterIP: 10.102.230.31 |
| ports: |
| - name: grpc-xds |
| port: 15010 |
| protocol: TCP |
| targetPort: 15010 |
| - name: https-xds |
| port: 15011 |
| protocol: TCP |
| targetPort: 15011 |
| - name: http-legacy-discovery |
| port: 8080 |
| protocol: TCP |
| targetPort: 8080 |
| - name: http-monitoring |
| port: 15014 |
| protocol: TCP |
| targetPort: 15014 |
| selector: |
| istio: pilot |
| sessionAffinity: None |
| type: ClusterIP` |
| |
| parseYAMLToK8sObjectTests := []struct { |
| desc string |
| objString string |
| wantGroup string |
| wantKind string |
| wantName string |
| wantNamespace string |
| }{ |
| {"ParseYamlToK8sDeployment", testDeploymentYaml, "apps", "Deployment", "istio-citadel", "dubbo-system"}, |
| {"ParseYamlToK8sPod", testPodYaml, "", "Pod", "istio-galley-75bcd59768-hpt5t", "dubbo-system"}, |
| {"ParseYamlToK8sService", testServiceYaml, "", "Service", "istio-pilot", "dubbo-system"}, |
| } |
| |
| for _, tt := range parseYAMLToK8sObjectTests { |
| t.Run(tt.desc, func(t *testing.T) { |
| k8sObj, err := ParseYAMLToK8sObject([]byte(tt.objString)) |
| if err != nil { |
| k8sObjStr := k8sObj.YAMLDebugString() |
| if k8sObj.Group != tt.wantGroup { |
| t.Errorf("ParseYAMLToK8sObject(%s): got group %s for k8s object %s, want %s", tt.desc, k8sObj.Group, k8sObjStr, tt.wantGroup) |
| } |
| if k8sObj.Group != tt.wantGroup { |
| t.Errorf("ParseYAMLToK8sObject(%s): got kind %s for k8s object %s, want %s", tt.desc, k8sObj.Kind, k8sObjStr, tt.wantKind) |
| } |
| if k8sObj.Name != tt.wantName { |
| t.Errorf("ParseYAMLToK8sObject(%s): got name %s for k8s object %s, want %s", tt.desc, k8sObj.Name, k8sObjStr, tt.wantName) |
| } |
| if k8sObj.Namespace != tt.wantNamespace { |
| t.Errorf("ParseYAMLToK8sObject(%s): got group %s for k8s object %s, want %s", tt.desc, k8sObj.Namespace, k8sObjStr, tt.wantNamespace) |
| } |
| } |
| }) |
| } |
| } |
| |
| func TestParseK8sObjectsFromYAMLManifest(t *testing.T) { |
| testDeploymentYaml := `apiVersion: apps/v1 |
| kind: Deployment |
| metadata: |
| name: istio-citadel |
| namespace: dubbo-system |
| labels: |
| istio: citadel |
| spec: |
| replicas: 1 |
| selector: |
| matchLabels: |
| istio: citadel |
| template: |
| metadata: |
| labels: |
| istio: citadel |
| spec: |
| containers: |
| - name: citadel |
| image: docker.io/istio/citadel:1.1.8 |
| args: |
| - "--append-dns-names=true" |
| - "--grpc-port=8060" |
| - "--grpc-hostname=citadel" |
| - "--citadel-storage-namespace=dubbo-system" |
| - "--custom-dns-names=istio-pilot-service-account.dubbo-system:istio-pilot.dubbo-system" |
| - "--monitoring-port=15014" |
| - "--self-signed-ca=true"` |
| |
| testPodYaml := `apiVersion: v1 |
| kind: Pod |
| metadata: |
| name: istio-galley-75bcd59768-hpt5t |
| namespace: dubbo-system |
| labels: |
| istio: galley |
| spec: |
| containers: |
| - name: galley |
| image: docker.io/istio/galley:1.1.8 |
| command: |
| - "/usr/local/bin/galley" |
| - server |
| - "--meshConfigFile=/etc/mesh-config/mesh" |
| - "--livenessProbeInterval=1s" |
| - "--livenessProbePath=/healthliveness" |
| - "--readinessProbePath=/healthready" |
| - "--readinessProbeInterval=1s" |
| - "--deployment-namespace=dubbo-system" |
| - "--insecure=true" |
| - "--validation-webhook-config-file" |
| - "/etc/config/validatingwebhookconfiguration.yaml" |
| - "--monitoringPort=15014" |
| - "--log_output_level=default:info" |
| ports: |
| - containerPort: 443 |
| protocol: TCP |
| - containerPort: 15014 |
| protocol: TCP |
| - containerPort: 9901 |
| protocol: TCP` |
| |
| testServiceYaml := `apiVersion: v1 |
| kind: Service |
| metadata: |
| labels: |
| app: pilot |
| name: istio-pilot |
| namespace: dubbo-system |
| spec: |
| clusterIP: 10.102.230.31 |
| ports: |
| - name: grpc-xds |
| port: 15010 |
| protocol: TCP |
| targetPort: 15010 |
| - name: https-xds |
| port: 15011 |
| protocol: TCP |
| targetPort: 15011 |
| - name: http-legacy-discovery |
| port: 8080 |
| protocol: TCP |
| targetPort: 8080 |
| - name: http-monitoring |
| port: 15014 |
| protocol: TCP |
| targetPort: 15014 |
| selector: |
| istio: pilot |
| sessionAffinity: None |
| type: ClusterIP` |
| |
| parseK8sObjectsFromYAMLManifestTests := []struct { |
| desc string |
| objsMap map[string]string |
| }{ |
| { |
| "FromHybridYAMLManifest", |
| map[string]string{ |
| "Deployment:dubbo-system:istio-citadel": testDeploymentYaml, |
| "Pod:dubbo-system:istio-galley-75bcd59768-hpt5t": testPodYaml, |
| "Service:dubbo-system:istio-pilot": testServiceYaml, |
| }, |
| }, |
| } |
| |
| for _, tt := range parseK8sObjectsFromYAMLManifestTests { |
| t.Run(tt.desc, func(t *testing.T) { |
| testManifestYaml := strings.Join([]string{testDeploymentYaml, testPodYaml, testServiceYaml}, YAMLSeparator) |
| gotK8sObjs, err := ParseK8sObjectsFromYAMLManifest(testManifestYaml) |
| if err != nil { |
| gotK8sObjsMap := gotK8sObjs.ToMap() |
| for objHash, want := range tt.objsMap { |
| if gotObj, ok := gotK8sObjsMap[objHash]; ok { |
| gotObjYaml := gotObj.YAMLDebugString() |
| if !util.IsYAMLEqual(gotObjYaml, want) { |
| t.Errorf("ParseK8sObjectsFromYAMLManifest(%s): got:\n%s\n\nwant:\n%s\nDiff:\n%s\n", tt.desc, gotObjYaml, want, util.YAMLDiff(gotObjYaml, want)) |
| } |
| } |
| } |
| } |
| }) |
| } |
| } |
| |
| func TestK8sObject_Equal(t *testing.T) { |
| obj1 := K8sObject{ |
| object: &unstructured.Unstructured{Object: map[string]interface{}{ |
| "key": "value1", |
| }}, |
| } |
| obj2 := K8sObject{ |
| object: &unstructured.Unstructured{Object: map[string]interface{}{ |
| "key": "value2", |
| }}, |
| } |
| cases := []struct { |
| desc string |
| o1 *K8sObject |
| o2 *K8sObject |
| want bool |
| }{ |
| { |
| desc: "Equals", |
| o1: &obj1, |
| o2: &obj1, |
| want: true, |
| }, |
| { |
| desc: "NotEquals", |
| o1: &obj1, |
| o2: &obj2, |
| want: false, |
| }, |
| { |
| desc: "NilSource", |
| o1: nil, |
| o2: &obj2, |
| want: false, |
| }, |
| { |
| desc: "NilDest", |
| o1: &obj1, |
| o2: nil, |
| want: false, |
| }, |
| { |
| desc: "TwoNils", |
| o1: nil, |
| o2: nil, |
| want: true, |
| }, |
| } |
| for _, tt := range cases { |
| t.Run(tt.desc, func(t *testing.T) { |
| res := tt.o1.Equal(tt.o2) |
| if res != tt.want { |
| t.Errorf("got %v, want: %v", res, tt.want) |
| } |
| }) |
| } |
| } |
| |
| func TestK8sObject_ResolveK8sConflict(t *testing.T) { |
| getK8sObject := func(ystr string) *K8sObject { |
| o, err := ParseYAMLToK8sObject([]byte(ystr)) |
| if err != nil { |
| panic(err) |
| } |
| // Ensure that json data is in sync. |
| // Since the object was created using yaml, json is empty. |
| // make sure the object json is set correctly. |
| o.json, _ = o.JSON() |
| return o |
| } |
| |
| cases := []struct { |
| desc string |
| o1 *K8sObject |
| o2 *K8sObject |
| }{ |
| { |
| desc: "not applicable kind", |
| o1: getK8sObject(` |
| apiVersion: v1 |
| kind: Service |
| metadata: |
| labels: |
| app: pilot |
| name: istio-pilot |
| namespace: dubbo-system |
| spec: |
| clusterIP: 10.102.230.31`), |
| o2: getK8sObject(` |
| apiVersion: v1 |
| kind: Service |
| metadata: |
| labels: |
| app: pilot |
| name: istio-pilot |
| namespace: dubbo-system |
| spec: |
| clusterIP: 10.102.230.31`), |
| }, |
| { |
| desc: "only minAvailable is set", |
| o1: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: zk-pdb |
| spec: |
| minAvailable: 2`), |
| o2: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: zk-pdb |
| spec: |
| minAvailable: 2`), |
| }, |
| { |
| desc: "only maxUnavailable is set", |
| o1: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: istio |
| spec: |
| maxUnavailable: 3`), |
| o2: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: istio |
| spec: |
| maxUnavailable: 3`), |
| }, |
| { |
| desc: "minAvailable and maxUnavailable are set to none zero values", |
| o1: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: istio |
| spec: |
| maxUnavailable: 50% |
| minAvailable: 3`), |
| o2: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: istio |
| spec: |
| maxUnavailable: 50%`), |
| }, |
| { |
| desc: "both minAvailable and maxUnavailable are set default", |
| o1: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: istio |
| spec: |
| minAvailable: 0 |
| maxUnavailable: 0`), |
| o2: getK8sObject(` |
| apiVersion: policy/v1 |
| kind: PodDisruptionBudget |
| metadata: |
| name: istio |
| spec: |
| maxUnavailable: 0 |
| minAvailable: 0`), |
| }, |
| } |
| for _, tt := range cases { |
| t.Run(tt.desc, func(t *testing.T) { |
| newObj := tt.o1.ResolveK8sConflict() |
| if !newObj.Equal(tt.o2) { |
| newObjjson, _ := newObj.JSON() |
| wantedObjjson, _ := tt.o2.JSON() |
| t.Errorf("Got: %s, want: %s", string(newObjjson), string(wantedObjjson)) |
| } |
| }) |
| } |
| } |
