From 76833e2c375ee0eec6732973d22072cdce26c5d5 Mon Sep 17 00:00:00 2001 From: Kenichi Omichi Date: Fri, 10 Apr 2020 18:07:03 +0000 Subject: [PATCH] Make WaitForAvailableEndpoint() local WaitForAvailableEndpoint() is only used in e2eservice. So this makes the function() local clearly. --- test/e2e/framework/service/jig.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/test/e2e/framework/service/jig.go b/test/e2e/framework/service/jig.go index ddcc2190fbf..72c2c5dd7c2 100644 --- a/test/e2e/framework/service/jig.go +++ b/test/e2e/framework/service/jig.go @@ -325,8 +325,8 @@ func (j *TestJig) WaitForEndpointOnNode(nodeName string) error { }) } -// WaitForAvailableEndpoint waits for at least 1 endpoint to be available till timeout -func (j *TestJig) WaitForAvailableEndpoint(timeout time.Duration) error { +// waitForAvailableEndpoint waits for at least 1 endpoint to be available till timeout +func (j *TestJig) waitForAvailableEndpoint(timeout time.Duration) error { //Wait for endpoints to be created, this may take longer time if service backing pods are taking longer time to run endpointSelector := fields.OneTermEqualSelector("metadata.name", j.Name) stopCh := make(chan struct{}) @@ -842,7 +842,7 @@ func (j *TestJig) checkClusterIPServiceReachability(svc *v1.Service, pod *v1.Pod clusterIP := svc.Spec.ClusterIP servicePorts := svc.Spec.Ports - err := j.WaitForAvailableEndpoint(ServiceEndpointsTimeout) + err := j.waitForAvailableEndpoint(ServiceEndpointsTimeout) if err != nil { return err } @@ -875,7 +875,7 @@ func (j *TestJig) checkNodePortServiceReachability(svc *v1.Service, pod *v1.Pod) return err } - err = j.WaitForAvailableEndpoint(ServiceEndpointsTimeout) + err = j.waitForAvailableEndpoint(ServiceEndpointsTimeout) if err != nil { return err }