github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 19:01:49 +00:00
Code Issues Projects Releases Wiki Activity

Make WaitForAvailableEndpoint() local

Browse Source 
WaitForAvailableEndpoint() is only used in e2eservice.
So this makes the function() local clearly.
This commit is contained in:
Kenichi Omichi 2020-04-10 18:07:03 +00:00
parent 95c3a69b19
commit 76833e2c37
1 changed files with 4 additions and 4 deletions
Show Stats 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
}