Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix service dual stack add/del cluster ips not change ovn nb (#2367)
* fix service dual stack add/del cluster ips not change ovn nb * add e2e case
- Loading branch information
Showing
4 changed files
with
154 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,88 @@ | ||
| package service | ||
|
|
||
| import ( | ||
| "os/exec" | ||
| "strings" | ||
|
|
||
| corev1 "k8s.io/api/core/v1" | ||
| "k8s.io/apimachinery/pkg/util/intstr" | ||
|
|
||
| "github.com/kubeovn/kube-ovn/test/e2e/framework" | ||
| "github.com/onsi/ginkgo/v2" | ||
| ) | ||
|
|
||
| var _ = framework.Describe("[group:service]", func() { | ||
| f := framework.NewDefaultFramework("service") | ||
|
|
||
| var serviceClient *framework.ServiceClient | ||
| var podClient *framework.PodClient | ||
| var namespaceName, serviceName, podName string | ||
|
|
||
| ginkgo.BeforeEach(func() { | ||
| serviceClient = f.ServiceClient() | ||
| podClient = f.PodClient() | ||
| namespaceName = f.Namespace.Name | ||
| serviceName = "service-" + framework.RandomSuffix() | ||
| podName = "pod-" + framework.RandomSuffix() | ||
| }) | ||
| ginkgo.AfterEach(func() { | ||
| ginkgo.By("Deleting pod " + podName) | ||
| podClient.DeleteSync(podName) | ||
|
|
||
| ginkgo.By("Deleting service " + serviceName) | ||
| serviceClient.DeleteSync(serviceName) | ||
| }) | ||
|
|
||
| framework.ConformanceIt("should ovn nb change vip when dual-stack service removes the cluster ip ", func() { | ||
| if f.ClusterIpFamily != "dual" { | ||
| ginkgo.Skip("this case only support dual mode") | ||
| } | ||
|
|
||
| ginkgo.By("Creating service " + serviceName) | ||
| ports := []corev1.ServicePort{{ | ||
| Name: "tcp", | ||
| Protocol: corev1.ProtocolTCP, | ||
| Port: 80, | ||
| TargetPort: intstr.FromInt(80), | ||
| }} | ||
|
|
||
| selector := map[string]string{"app": "svc-dual"} | ||
| service := framework.MakeService(serviceName, corev1.ServiceTypeClusterIP, nil, selector, ports, corev1.ServiceAffinityNone) | ||
| service.Namespace = namespaceName | ||
| service.Spec.IPFamilyPolicy = new(corev1.IPFamilyPolicy) | ||
| *service.Spec.IPFamilyPolicy = corev1.IPFamilyPolicyPreferDualStack | ||
| service = serviceClient.CreateSync(service) | ||
| v6ClusterIp := service.Spec.ClusterIPs[1] | ||
| originService := service.DeepCopy() | ||
|
|
||
| podBackend := framework.MakePod(namespaceName, podName, selector, nil, framework.PauseImage, nil, nil) | ||
| _ = podClient.CreateSync(podBackend) | ||
|
|
||
| execCmd := "kubectl ko nbctl --format=csv --data=bare --no-heading --columns=vips find Load_Balancer name=cluster-tcp-loadbalancer" | ||
| output, err := exec.Command("bash", "-c", execCmd).CombinedOutput() | ||
| framework.ExpectNoError(err) | ||
| framework.ExpectTrue(strings.Contains(string(output), v6ClusterIp), "should contains v6 cluster ip") | ||
|
|
||
| ginkgo.By("change service from dual stack to single stack ") | ||
| modifyService := service.DeepCopy() | ||
| *modifyService.Spec.IPFamilyPolicy = corev1.IPFamilyPolicySingleStack | ||
| modifyService.Spec.IPFamilies = []corev1.IPFamily{corev1.IPv4Protocol} | ||
| modifyService.Spec.ClusterIPs = []string{service.Spec.ClusterIP} | ||
| service = serviceClient.Patch(service, modifyService) | ||
|
|
||
| output, err = exec.Command("bash", "-c", execCmd).CombinedOutput() | ||
| framework.ExpectNoError(err) | ||
| framework.ExpectFalse(strings.Contains(string(output), v6ClusterIp), "should not contains v6 cluster ip") | ||
|
|
||
| ginkgo.By("recover service from single stack to dual stack ") | ||
| recoverService := service.DeepCopy() | ||
| *recoverService.Spec.IPFamilyPolicy = *originService.Spec.IPFamilyPolicy | ||
| recoverService.Spec.IPFamilies = originService.Spec.IPFamilies | ||
| recoverService.Spec.ClusterIPs = originService.Spec.ClusterIPs | ||
| _ = serviceClient.Patch(service, recoverService) | ||
|
|
||
| output, err = exec.Command("bash", "-c", execCmd).CombinedOutput() | ||
| framework.ExpectNoError(err) | ||
| framework.ExpectTrue(strings.Contains(string(output), v6ClusterIp), "should contains v6 cluster ip") | ||
| }) | ||
| }) |