Skip to content

Commit faa3a5f

Browse files
k8s-ci-robotk8s-ci-robot
authored
Merge pull request kubernetes#99916 from swetharepakula/eps-ga-e2e
Promote Endpoint Slice E2E Tests to Conformance
2 parents 841cb4a + 17beeaf commit faa3a5f

File tree

8 files changed

+145
-78
lines changed

8 files changed

+145
-78
lines changed

‎test/conformance/testdata/conformance.yaml

+40
Original file line numberDiff line numberDiff line change
@@ -1157,6 +1157,46 @@
11571157
DNS configuration MUST be configured in the Pod.
11581158
release: v1.17
11591159
file: test/e2e/network/dns.go
1160+
- testname: EndpointSlice API
1161+
codename: '[sig-network] EndpointSlice should create Endpoints and EndpointSlices
1162+
for Pods matching a Service [Conformance]'
1163+
description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
1164+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io
1165+
discovery document. The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1
1166+
discovery document. The endpointslice controller must create EndpointSlices for
1167+
Pods mataching a Service.
1168+
release: v1.21
1169+
file: test/e2e/network/endpointslice.go
1170+
- testname: EndpointSlice API
1171+
codename: '[sig-network] EndpointSlice should create and delete Endpoints and EndpointSlices
1172+
for a Service with a selector specified [Conformance]'
1173+
description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
1174+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io
1175+
discovery document. The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1
1176+
discovery document. The endpointslice controller should create and delete EndpointSlices
1177+
for Pods matching a Service.
1178+
release: v1.21
1179+
file: test/e2e/network/endpointslice.go
1180+
- testname: EndpointSlice API
1181+
codename: '[sig-network] EndpointSlice should have Endpoints and EndpointSlices
1182+
pointing to API Server [Conformance]'
1183+
description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
1184+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io
1185+
discovery document. The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1
1186+
discovery document. API Server should create self referential Endpoints and EndpointSlices
1187+
named "kubernetes" in the default namespace.
1188+
release: v1.21
1189+
file: test/e2e/network/endpointslice.go
1190+
- testname: EndpointSlice Mirroring
1191+
codename: '[sig-network] EndpointSliceMirroring should mirror a custom Endpoints
1192+
resource through create update and delete [Conformance]'
1193+
description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
1194+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io
1195+
discovery document. The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1
1196+
discovery document. The endpointslices mirrorowing must mirror endpoint create,
1197+
update, and delete actions.
1198+
release: v1.21
1199+
file: test/e2e/network/endpointslicemirroring.go
11601200
- testname: Scheduling, HostPort matching and HostIP and Protocol not-matching
11611201
codename: '[sig-network] HostPort validates that there is no conflict between pods
11621202
with same hostPort but different hostIP and protocol [LinuxOnly] [Conformance]'

‎test/e2e/framework/endpointslice/ports.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -17,15 +17,15 @@ limitations under the License.
1717
package endpointslice
1818

1919
import (
20-
discoveryv1beta1 "k8s.io/api/discovery/v1beta1"
20+
discoveryv1 "k8s.io/api/discovery/v1"
2121
"k8s.io/apimachinery/pkg/types"
2222
)
2323

2424
// PortsByPodUID is a map that maps pod UID to container ports.
2525
type PortsByPodUID map[types.UID][]int
2626

2727
// GetContainerPortsByPodUID returns a PortsByPodUID map on the given endpoints.
28-
func GetContainerPortsByPodUID(eps []discoveryv1beta1.EndpointSlice) PortsByPodUID {
28+
func GetContainerPortsByPodUID(eps []discoveryv1.EndpointSlice) PortsByPodUID {
2929
m := PortsByPodUID{}
3030

3131
for _, es := range eps {

‎test/e2e/framework/service/jig.go

+36-41
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ import (
2727

2828
"github.com/onsi/ginkgo"
2929
v1 "k8s.io/api/core/v1"
30-
discoveryv1beta1 "k8s.io/api/discovery/v1beta1"
30+
discoveryv1 "k8s.io/api/discovery/v1"
3131
policyv1beta1 "k8s.io/api/policy/v1beta1"
3232
apierrors "k8s.io/apimachinery/pkg/api/errors"
3333
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -395,52 +395,47 @@ func (j *TestJig) waitForAvailableEndpoint(timeout time.Duration) error {
395395

396396
go controller.Run(stopCh)
397397

398-
// If EndpointSlice API is enabled, then validate if appropriate EndpointSlice objects were also create/updated/deleted.
399-
if _, err := j.Client.Discovery().ServerResourcesForGroupVersion(discoveryv1beta1.SchemeGroupVersion.String()); err == nil {
400-
var esController cache.Controller
401-
_, esController = cache.NewInformer(
402-
&cache.ListWatch{
403-
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
404-
options.LabelSelector = "kubernetes.io/service-name=" + j.Name
405-
obj, err := j.Client.DiscoveryV1beta1().EndpointSlices(j.Namespace).List(context.TODO(), options)
406-
return runtime.Object(obj), err
407-
},
408-
WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
409-
options.LabelSelector = "kubernetes.io/service-name=" + j.Name
410-
return j.Client.DiscoveryV1beta1().EndpointSlices(j.Namespace).Watch(context.TODO(), options)
411-
},
398+
var esController cache.Controller
399+
_, esController = cache.NewInformer(
400+
&cache.ListWatch{
401+
ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
402+
options.LabelSelector = "kubernetes.io/service-name=" + j.Name
403+
obj, err := j.Client.DiscoveryV1().EndpointSlices(j.Namespace).List(context.TODO(), options)
404+
return runtime.Object(obj), err
412405
},
413-
&discoveryv1beta1.EndpointSlice{},
414-
0,
415-
cache.ResourceEventHandlerFuncs{
416-
AddFunc: func(obj interface{}) {
417-
if es, ok := obj.(*discoveryv1beta1.EndpointSlice); ok {
418-
// TODO: currently we only consider addreses in 1 slice, but services with
419-
// a large number of endpoints (>1000) may have multiple slices. Some slices
420-
// with only a few addresses. We should check the addresses in all slices.
421-
if len(es.Endpoints) > 0 && len(es.Endpoints[0].Addresses) > 0 {
422-
endpointSliceAvailable = true
423-
}
406+
WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
407+
options.LabelSelector = "kubernetes.io/service-name=" + j.Name
408+
return j.Client.DiscoveryV1().EndpointSlices(j.Namespace).Watch(context.TODO(), options)
409+
},
410+
},
411+
&discoveryv1.EndpointSlice{},
412+
0,
413+
cache.ResourceEventHandlerFuncs{
414+
AddFunc: func(obj interface{}) {
415+
if es, ok := obj.(*discoveryv1.EndpointSlice); ok {
416+
// TODO: currently we only consider addreses in 1 slice, but services with
417+
// a large number of endpoints (>1000) may have multiple slices. Some slices
418+
// with only a few addresses. We should check the addresses in all slices.
419+
if len(es.Endpoints) > 0 && len(es.Endpoints[0].Addresses) > 0 {
420+
endpointSliceAvailable = true
424421
}
425-
},
426-
UpdateFunc: func(old, cur interface{}) {
427-
if es, ok := cur.(*discoveryv1beta1.EndpointSlice); ok {
428-
// TODO: currently we only consider addreses in 1 slice, but services with
429-
// a large number of endpoints (>1000) may have multiple slices. Some slices
430-
// with only a few addresses. We should check the addresses in all slices.
431-
if len(es.Endpoints) > 0 && len(es.Endpoints[0].Addresses) > 0 {
432-
endpointSliceAvailable = true
433-
}
422+
}
423+
},
424+
UpdateFunc: func(old, cur interface{}) {
425+
if es, ok := cur.(*discoveryv1.EndpointSlice); ok {
426+
// TODO: currently we only consider addreses in 1 slice, but services with
427+
// a large number of endpoints (>1000) may have multiple slices. Some slices
428+
// with only a few addresses. We should check the addresses in all slices.
429+
if len(es.Endpoints) > 0 && len(es.Endpoints[0].Addresses) > 0 {
430+
endpointSliceAvailable = true
434431
}
435-
},
432+
}
436433
},
437-
)
434+
},
435+
)
438436

439-
go esController.Run(stopCh)
437+
go esController.Run(stopCh)
440438

441-
} else {
442-
endpointSliceAvailable = true
443-
}
444439
err := wait.Poll(1*time.Second, timeout, func() (bool, error) {
445440
return endpointAvailable && endpointSliceAvailable, nil
446441
})

‎test/e2e/network/endpointslice.go

+43-19
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import (
2323
"time"
2424

2525
v1 "k8s.io/api/core/v1"
26-
discoveryv1beta1 "k8s.io/api/discovery/v1beta1"
26+
discoveryv1 "k8s.io/api/discovery/v1"
2727
apierrors "k8s.io/apimachinery/pkg/api/errors"
2828
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
2929
"k8s.io/apimachinery/pkg/util/intstr"
@@ -48,7 +48,15 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
4848
podClient = f.PodClient()
4949
})
5050

51-
ginkgo.It("should have Endpoints and EndpointSlices pointing to API Server", func() {
51+
/*
52+
Release: v1.21
53+
Testname: EndpointSlice API
54+
Description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
55+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io discovery document.
56+
The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1 discovery document.
57+
API Server should create self referential Endpoints and EndpointSlices named "kubernetes" in the default namespace.
58+
*/
59+
framework.ConformanceIt("should have Endpoints and EndpointSlices pointing to API Server", func() {
5260
namespace := "default"
5361
name := "kubernetes"
5462
endpoints, err := cs.CoreV1().Endpoints(namespace).Get(context.TODO(), name, metav1.GetOptions{})
@@ -58,7 +66,7 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
5866
}
5967

6068
endpointSubset := endpoints.Subsets[0]
61-
endpointSlice, err := cs.DiscoveryV1beta1().EndpointSlices(namespace).Get(context.TODO(), name, metav1.GetOptions{})
69+
endpointSlice, err := cs.DiscoveryV1().EndpointSlices(namespace).Get(context.TODO(), name, metav1.GetOptions{})
6270
framework.ExpectNoError(err, "error creating EndpointSlice resource")
6371
if len(endpointSlice.Ports) != len(endpointSubset.Ports) {
6472
framework.Failf("Expected EndpointSlice to have %d ports, got %d: %#v", len(endpointSubset.Ports), len(endpointSlice.Ports), endpointSlice.Ports)
@@ -70,7 +78,15 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
7078

7179
})
7280

73-
ginkgo.It("should create and delete Endpoints and EndpointSlices for a Service with a selector specified", func() {
81+
/*
82+
Release: v1.21
83+
Testname: EndpointSlice API
84+
Description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
85+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io discovery document.
86+
The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1 discovery document.
87+
The endpointslice controller should create and delete EndpointSlices for Pods matching a Service.
88+
*/
89+
framework.ConformanceIt("should create and delete Endpoints and EndpointSlices for a Service with a selector specified", func() {
7490
svc := createServiceReportErr(cs, f.Namespace.Name, &v1.Service{
7591
ObjectMeta: metav1.ObjectMeta{
7692
Name: "example-empty-selector",
@@ -99,9 +115,9 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
99115
}
100116

101117
// Expect EndpointSlice resource to be created.
102-
var endpointSlice discoveryv1beta1.EndpointSlice
118+
var endpointSlice discoveryv1.EndpointSlice
103119
if err := wait.PollImmediate(2*time.Second, wait.ForeverTestTimeout, func() (bool, error) {
104-
endpointSliceList, err := cs.DiscoveryV1beta1().EndpointSlices(svc.Namespace).List(context.TODO(), metav1.ListOptions{
120+
endpointSliceList, err := cs.DiscoveryV1().EndpointSlices(svc.Namespace).List(context.TODO(), metav1.ListOptions{
105121
LabelSelector: "kubernetes.io/service-name=" + svc.Name,
106122
})
107123
if err != nil {
@@ -117,12 +133,12 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
117133
}
118134

119135
// Ensure EndpointSlice has expected values.
120-
managedBy, ok := endpointSlice.Labels[discoveryv1beta1.LabelManagedBy]
136+
managedBy, ok := endpointSlice.Labels[discoveryv1.LabelManagedBy]
121137
expectedManagedBy := "endpointslice-controller.k8s.io"
122138
if !ok {
123-
framework.Failf("Expected EndpointSlice to have %s label, got %#v", discoveryv1beta1.LabelManagedBy, endpointSlice.Labels)
139+
framework.Failf("Expected EndpointSlice to have %s label, got %#v", discoveryv1.LabelManagedBy, endpointSlice.Labels)
124140
} else if managedBy != expectedManagedBy {
125-
framework.Failf("Expected EndpointSlice to have %s label with %s value, got %s", discoveryv1beta1.LabelManagedBy, expectedManagedBy, managedBy)
141+
framework.Failf("Expected EndpointSlice to have %s label with %s value, got %s", discoveryv1.LabelManagedBy, expectedManagedBy, managedBy)
126142
}
127143
if len(endpointSlice.Endpoints) != 0 {
128144
framework.Failf("Expected EndpointSlice to have 0 endpoints, got %d: %#v", len(endpointSlice.Endpoints), endpointSlice.Endpoints)
@@ -150,7 +166,7 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
150166
// and may need to retry informer resync at some point during an e2e
151167
// run.
152168
if err := wait.PollImmediate(2*time.Second, 90*time.Second, func() (bool, error) {
153-
endpointSliceList, err := cs.DiscoveryV1beta1().EndpointSlices(svc.Namespace).List(context.TODO(), metav1.ListOptions{
169+
endpointSliceList, err := cs.DiscoveryV1().EndpointSlices(svc.Namespace).List(context.TODO(), metav1.ListOptions{
154170
LabelSelector: "kubernetes.io/service-name=" + svc.Name,
155171
})
156172
if err != nil {
@@ -165,7 +181,15 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
165181
}
166182
})
167183

168-
ginkgo.It("should create Endpoints and EndpointSlices for Pods matching a Service", func() {
184+
/*
185+
Release: v1.21
186+
Testname: EndpointSlice API
187+
Description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
188+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io discovery document.
189+
The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1 discovery document.
190+
The endpointslice controller must create EndpointSlices for Pods mataching a Service.
191+
*/
192+
framework.ConformanceIt("should create Endpoints and EndpointSlices for Pods matching a Service", func() {
169193
labelPod1 := "pod1"
170194
labelPod2 := "pod2"
171195
labelPod3 := "pod3"
@@ -313,7 +337,7 @@ var _ = common.SIGDescribe("EndpointSlice", func() {
313337
// and takes some shortcuts with the assumption that those test cases will be
314338
// the only caller of this function.
315339
func expectEndpointsAndSlices(cs clientset.Interface, ns string, svc *v1.Service, pods []*v1.Pod, numSubsets, numSlices int, namedPort bool) {
316-
endpointSlices := []discoveryv1beta1.EndpointSlice{}
340+
endpointSlices := []discoveryv1.EndpointSlice{}
317341
if err := wait.PollImmediate(5*time.Second, 2*time.Minute, func() (bool, error) {
318342
endpointSlicesFound, hasMatchingSlices := hasMatchingEndpointSlices(cs, ns, svc.Name, len(pods), numSlices)
319343
if !hasMatchingSlices {
@@ -479,27 +503,27 @@ func expectEndpointsAndSlices(cs clientset.Interface, ns string, svc *v1.Service
479503

480504
// deleteEndpointSlices deletes EndpointSlices for the specified Service.
481505
func deleteEndpointSlices(cs clientset.Interface, ns string, svc *v1.Service) {
482-
listOptions := metav1.ListOptions{LabelSelector: fmt.Sprintf("%s=%s", discoveryv1beta1.LabelServiceName, svc.Name)}
483-
esList, err := cs.DiscoveryV1beta1().EndpointSlices(ns).List(context.TODO(), listOptions)
506+
listOptions := metav1.ListOptions{LabelSelector: fmt.Sprintf("%s=%s", discoveryv1.LabelServiceName, svc.Name)}
507+
esList, err := cs.DiscoveryV1().EndpointSlices(ns).List(context.TODO(), listOptions)
484508
framework.ExpectNoError(err, "Error fetching EndpointSlices for %s/%s Service", ns, svc.Name)
485509

486510
for _, endpointSlice := range esList.Items {
487-
err := cs.DiscoveryV1beta1().EndpointSlices(ns).Delete(context.TODO(), endpointSlice.Name, metav1.DeleteOptions{})
511+
err := cs.DiscoveryV1().EndpointSlices(ns).Delete(context.TODO(), endpointSlice.Name, metav1.DeleteOptions{})
488512
framework.ExpectNoError(err, "Error deleting %s/%s EndpointSlice", ns, endpointSlice.Name)
489513
}
490514
}
491515

492516
// hasMatchingEndpointSlices returns any EndpointSlices that match the
493517
// conditions along with a boolean indicating if all the conditions have been
494518
// met.
495-
func hasMatchingEndpointSlices(cs clientset.Interface, ns, svcName string, numEndpoints, numSlices int) ([]discoveryv1beta1.EndpointSlice, bool) {
496-
listOptions := metav1.ListOptions{LabelSelector: fmt.Sprintf("%s=%s", discoveryv1beta1.LabelServiceName, svcName)}
497-
esList, err := cs.DiscoveryV1beta1().EndpointSlices(ns).List(context.TODO(), listOptions)
519+
func hasMatchingEndpointSlices(cs clientset.Interface, ns, svcName string, numEndpoints, numSlices int) ([]discoveryv1.EndpointSlice, bool) {
520+
listOptions := metav1.ListOptions{LabelSelector: fmt.Sprintf("%s=%s", discoveryv1.LabelServiceName, svcName)}
521+
esList, err := cs.DiscoveryV1().EndpointSlices(ns).List(context.TODO(), listOptions)
498522
framework.ExpectNoError(err, "Error fetching EndpointSlice for Service %s/%s", ns, svcName)
499523

500524
if len(esList.Items) == 0 {
501525
framework.Logf("EndpointSlice for Service %s/%s not found", ns, svcName)
502-
return []discoveryv1beta1.EndpointSlice{}, false
526+
return []discoveryv1.EndpointSlice{}, false
503527
}
504528
// In some cases the EndpointSlice controller will create more
505529
// EndpointSlices than necessary resulting in some duplication. This is

‎test/e2e/network/endpointslicemirroring.go

+16-8
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import (
2323

2424
"github.com/onsi/ginkgo"
2525
v1 "k8s.io/api/core/v1"
26-
discoveryv1beta1 "k8s.io/api/discovery/v1beta1"
26+
discoveryv1 "k8s.io/api/discovery/v1"
2727
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
2828
"k8s.io/apimachinery/pkg/util/wait"
2929
clientset "k8s.io/client-go/kubernetes"
@@ -40,7 +40,15 @@ var _ = common.SIGDescribe("EndpointSliceMirroring", func() {
4040
cs = f.ClientSet
4141
})
4242

43-
ginkgo.It("should mirror a custom Endpoints resource through create update and delete", func() {
43+
/*
44+
Release: v1.21
45+
Testname: EndpointSlice Mirroring
46+
Description: The discovery.k8s.io API group MUST exist in the /apis discovery document.
47+
The discovery.k8s.io/v1 API group/version MUST exist in the /apis/discovery.k8s.io discovery document.
48+
The endpointslices resource MUST exist in the /apis/discovery.k8s.io/v1 discovery document.
49+
The endpointslices mirrorowing must mirror endpoint create, update, and delete actions.
50+
*/
51+
framework.ConformanceIt("should mirror a custom Endpoints resource through create update and delete", func() {
4452
svc := createServiceReportErr(cs, f.Namespace.Name, &v1.Service{
4553
ObjectMeta: metav1.ObjectMeta{
4654
Name: "example-custom-endpoints",
@@ -73,8 +81,8 @@ var _ = common.SIGDescribe("EndpointSliceMirroring", func() {
7381
framework.ExpectNoError(err, "Unexpected error creating Endpoints")
7482

7583
if err := wait.PollImmediate(2*time.Second, 12*time.Second, func() (bool, error) {
76-
esList, err := cs.DiscoveryV1beta1().EndpointSlices(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
77-
LabelSelector: discoveryv1beta1.LabelServiceName + "=" + svc.Name,
84+
esList, err := cs.DiscoveryV1().EndpointSlices(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
85+
LabelSelector: discoveryv1.LabelServiceName + "=" + svc.Name,
7886
})
7987
if err != nil {
8088
framework.Logf("Error listing EndpointSlices: %v", err)
@@ -125,8 +133,8 @@ var _ = common.SIGDescribe("EndpointSliceMirroring", func() {
125133

126134
// Expect mirrored EndpointSlice resource to be updated.
127135
if err := wait.PollImmediate(2*time.Second, 12*time.Second, func() (bool, error) {
128-
esList, err := cs.DiscoveryV1beta1().EndpointSlices(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
129-
LabelSelector: discoveryv1beta1.LabelServiceName + "=" + svc.Name,
136+
esList, err := cs.DiscoveryV1().EndpointSlices(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
137+
LabelSelector: discoveryv1.LabelServiceName + "=" + svc.Name,
130138
})
131139
if err != nil {
132140
return false, err
@@ -172,8 +180,8 @@ var _ = common.SIGDescribe("EndpointSliceMirroring", func() {
172180

173181
// Expect mirrored EndpointSlice resource to be updated.
174182
if err := wait.PollImmediate(2*time.Second, 12*time.Second, func() (bool, error) {
175-
esList, err := cs.DiscoveryV1beta1().EndpointSlices(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
176-
LabelSelector: discoveryv1beta1.LabelServiceName + "=" + svc.Name,
183+
esList, err := cs.DiscoveryV1().EndpointSlices(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{
184+
LabelSelector: discoveryv1.LabelServiceName + "=" + svc.Name,
177185
})
178186
if err != nil {
179187
return false, err

0 commit comments

Comments
 (0)