- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for WaitForReadyWorkloads (0.25 sec)
-
pkg/test/framework/components/echo/kube/workload_manager.go
added: m.onPodAddOrUpdate, updated: m.onPodAddOrUpdate, deleted: m.onPodDeleted, }) return m, nil } // WaitForReadyWorkloads waits until all known workloads are ready. func (m *workloadManager) WaitForReadyWorkloads() (out echo.Workloads, err error) { err = retry.UntilSuccess(func() error { m.mutex.Lock() out, err = m.readyWorkloads()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
} } return nil } func (c *instance) Restart() error { // Wait for all current workloads to become ready and preserve the original count. origWorkloads, err := c.workloadMgr.WaitForReadyWorkloads() if err != nil { return fmt.Errorf("restart failed to get initial workloads: %v", err) } // Restart the deployment. if err := c.deployment.Restart(); err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0)