add logs for waiting
parent
c9eb446eb3
commit
b880469cd7
|
|
@ -42,7 +42,7 @@ var (
|
|||
// NoWaitComponents is map of componets to wait for if specified 'none' or 'false'
|
||||
NoComponents = map[string]bool{APIServerWaitKey: false, SystemPodsWaitKey: false, DefaultSAWaitKey: false, AppsRunning: false}
|
||||
// AllComponents is map for waiting for all components.
|
||||
AllComponents = map[string]bool{APIServerWaitKey: true, SystemPodsWaitKey: true, DefaultSAWaitKey: true}
|
||||
AllComponents = map[string]bool{APIServerWaitKey: true, SystemPodsWaitKey: true, DefaultSAWaitKey: true, AppsRunning: true}
|
||||
// DefaultWaitList is list of all default components to wait for. only names to be used for start flags.
|
||||
DefaultWaitList = []string{APIServerWaitKey, SystemPodsWaitKey}
|
||||
// AllComponentsList list of all valid components keys to wait for. only names to be used used for start flags.
|
||||
|
|
|
|||
|
|
@ -111,6 +111,7 @@ func ExpectAppsRunning(cs *kubernetes.Clientset, expected []string) error {
|
|||
|
||||
// WaitForAppsRunning waits for expected Apps To be running
|
||||
func WaitForAppsRunning(cs *kubernetes.Clientset, expected []string, timeout time.Duration) error {
|
||||
glog.Info("waiting for k8s-apps to be running ...")
|
||||
start := time.Now()
|
||||
checkRunning := func() error { return ExpectAppsRunning(cs, expected) }
|
||||
if err := retry.Expo(checkRunning, 500*time.Millisecond, timeout); err != nil {
|
||||
|
|
|
|||
Loading…
Reference in New Issue