Skip to content

Commit f13051c

Browse files
authored
Merge pull request kubernetes#90060 from oomichi/WaitForAvailableEndpoint
Make WaitForAvailableEndpoint() local
2 parents 3c871ad + 76833e2 commit f13051c

File tree

1 file changed

+4
-4
lines changed
  • test/e2e/framework/service

1 file changed

+4
-4
lines changed

test/e2e/framework/service/jig.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -325,8 +325,8 @@ func (j *TestJig) WaitForEndpointOnNode(nodeName string) error {
325325
})
326326
}
327327

328-
// WaitForAvailableEndpoint waits for at least 1 endpoint to be available till timeout
329-
func (j *TestJig) WaitForAvailableEndpoint(timeout time.Duration) error {
328+
// waitForAvailableEndpoint waits for at least 1 endpoint to be available till timeout
329+
func (j *TestJig) waitForAvailableEndpoint(timeout time.Duration) error {
330330
//Wait for endpoints to be created, this may take longer time if service backing pods are taking longer time to run
331331
endpointSelector := fields.OneTermEqualSelector("metadata.name", j.Name)
332332
stopCh := make(chan struct{})
@@ -842,7 +842,7 @@ func (j *TestJig) checkClusterIPServiceReachability(svc *v1.Service, pod *v1.Pod
842842
clusterIP := svc.Spec.ClusterIP
843843
servicePorts := svc.Spec.Ports
844844

845-
err := j.WaitForAvailableEndpoint(ServiceEndpointsTimeout)
845+
err := j.waitForAvailableEndpoint(ServiceEndpointsTimeout)
846846
if err != nil {
847847
return err
848848
}
@@ -875,7 +875,7 @@ func (j *TestJig) checkNodePortServiceReachability(svc *v1.Service, pod *v1.Pod)
875875
return err
876876
}
877877

878-
err = j.WaitForAvailableEndpoint(ServiceEndpointsTimeout)
878+
err = j.waitForAvailableEndpoint(ServiceEndpointsTimeout)
879879
if err != nil {
880880
return err
881881
}

0 commit comments

Comments
 (0)