github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixing timing issues with examples

Browse Source
This commit is contained in:
goltermann
2016-06-08 18:45:58 -07:00
parent 7695ae6334
commit 4b722d33aa
2 changed files with 50 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
test/e2e/framework/util.go
View File

@@ -1333,7 +1333,7 @@ func WaitForService(c *client.Client, namespace, name string, exist bool, interv
//WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.
func WaitForServiceEndpointsNum(c *client.Client, namespace, serviceName string, expectNum int, interval, timeout time.Duration) error {
return wait.Poll(interval, timeout, func() (bool, error) {
Logf("Waiting for amount of service:%s endpoints to %d", serviceName, expectNum)
Logf("Waiting for amount of service:%s endpoints to be %d", serviceName, expectNum)
list, err := c.Endpoints(namespace).List(api.ListOptions{})
if err != nil {
return false, err
@@ -1386,7 +1386,7 @@ func WaitForEndpoint(c *client.Client, ns, name string) error {
return nil
}
}
return fmt.Errorf("Failed to get entpoints for %s/%s", ns, name)
return fmt.Errorf("Failed to get endpoints for %s/%s", ns, name)
}
// Context for checking pods responses by issuing GETs to them (via the API