in cmd/root.go [358:385]
func runWaitCmd(c *cobra.Command, _ []string) error {
a, _ := c.Flags().GetString(httpAddressFlag)
p, _ := c.Flags().GetString(httpPortFlag)
addr := fmt.Sprintf("http://%v:%v/startup", a, p)
wait, err := c.Flags().GetDuration(waitMaxFlag)
if err != nil {
// This error should always be nil. If the error occurs, it means the
// wait flag name has changed where it was registered.
return err
}
c.SilenceUsage = true
t := time.After(wait)
for {
select {
case <-t:
return errors.New("command failed to complete successfully")
default:
resp, err := http.Get(addr)
if err != nil || resp.StatusCode != http.StatusOK {
time.Sleep(time.Second)
break
}
return nil
}
}
}