| // WaitFor polls a predicate function, once per second, up to a timeout limit. |
| // It usually does this to wait for a resource to transition to a certain state. |
| // Resource packages will wrap this in a more convenient function that's |
| // specific to a certain resource, but it can also be useful on its own. |
| func WaitFor(timeout int, predicate func() (bool, error)) error { |
| start := time.Now().Second() |
| time.Sleep(1 * time.Second) |
| // If a timeout is set, and that's been exceeded, shut it down |
| if timeout >= 0 && time.Now().Second()-start >= timeout { |
| return errors.New("A timeout occurred") |
| satisfied, err := predicate() |
| // NormalizeURL is an internal function to be used by provider clients. |
| // It ensures that each endpoint URL has a closing `/`, as expected by |
| // ServiceClient's methods. |
| func NormalizeURL(url string) string { |
| if !strings.HasSuffix(url, "/") { |