INNER CODE UNIT · Go

waitForPredicate

kubernetes/dns · cmd/sidecar-e2e/main.go:99

func waitForPredicate(predicate func() (bool, error), duration time.Duration, interval time.Duration) error {
	var err error

	start := time.Now()

	for time.Since(start) < duration {
		var stop bool
		stop, err = predicate()
		if stop {
			return err
		}
		time.Sleep(interval)
	}

	return fmt.Errorf("timeout (last error was %v)", err)
}

func waitForTcpOrExit(cmd *exec.Cmd, endpoint string) error {

View source record →