util.go

package gophercloud

import (
	"fmt"
	"strings"
	"time"
)

// WaitFor polls a predicate function once per second up to secs times to wait for a certain state to arrive.
func WaitFor(secs int, predicate func() (bool, error)) error {
	for i := 0; i < secs; i++ {
		time.Sleep(1 * time.Second)

		satisfied, err := predicate()
		if err != nil {
			return err
		}
		if satisfied {
			return nil
		}
	}
	return fmt.Errorf("Time out in WaitFor.")
}

// NormalizeURL ensures that each endpoint URL has a closing `/`, as expected by ServiceClient.
func NormalizeURL(url string) string {
	if !strings.HasSuffix(url, "/") {
		return url + "/"
	}
	return url
}

// BuildQuery constructs the query section of a URI from a map.
func BuildQuery(params map[string]string) string {
	if len(params) == 0 {
		return ""
	}

	query := "?"
	for k, v := range params {
		query += k + "=" + v + "&"
	}
	query = query[:len(query)-1]
	return query
}