Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ReportWaiting (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top