- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ReportWaiting (0.15 sec)
-
operator/pkg/util/progress/progress_test.go
bar.ReportProgress() // string buffer won't rewrite, so we append expect(`- Processing resources for ` + cnbo + `, ` + cnpo + `.`) bar.ReportProgress() bar.ReportProgress() bar.ReportWaiting([]string{"deployment"}) expect(`- Processing resources for ` + cnbo + `, ` + cnpo + `. Waiting for deployment`) bar.ReportError("some error") expect(`❌ ` + cnbo + ` encountered an error: some error`)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 2.1K bytes - Viewed (0) -
operator/pkg/util/progress/progress.go
p.report() } func (p *ManifestLog) ReportFinished() { if p == nil { return } p.mu.Lock() p.finished = true p.mu.Unlock() p.report() } func (p *ManifestLog) ReportWaiting(resources []string) { if p == nil { return } p.mu.Lock() p.waiting = resources p.mu.Unlock() p.report() } func (p *ManifestLog) waitingResources() []string { p.mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 6.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
nsr, nnr := namespacesReady(namespaces) pr, pnr := podsReady(pods) isReady := dr && nsr && dsr && stsr && pr notReady := append(append(append(append(nnr, dnr...), pnr...), dsnr...), stsnr...) if !isReady { l.ReportWaiting(notReady) } return isReady, notReady, resourceDebugInfo, nil } func waitForCRDs(objects object.K8sObjects, client kube.Client) error { var crdNames []string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0)