github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-16 06:32:32 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #90060 from oomichi/WaitForAvailableEndpoint

Browse Source 
Make WaitForAvailableEndpoint() local
This commit is contained in:
Kubernetes Prow Robot
2020-04-10 22:05:47 -07:00
committed by GitHub
parent 3c871adc5f 76833e2c37
commit f13051c28c
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
test/e2e/framework/service/jig.go
View File

@@ -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
}