INNER CODE UNIT · Go

ticker

kubernetes-sigs/kueue · cmd/experimental/webhook-conversion-repro/main.go:180

		ticker := time.NewTicker(10 * time.Second)
		defer ticker.Stop()
		for {
			select {
			case <-ticker.C:
				s := atomic.LoadInt32(&success)
				f := atomic.LoadInt32(&failed)
				fmt.Printf("\r\033[KProgress: %d / %d (Failed: %d)", s, cfg.Count, f)
			case <-done:
				return
			}
		}
	}()

	for range cfg.Workers {
		wg.Go(func() {
			for idx := range jobs {
				wl := createWorkloadObj(idx, cfg.Containers, cfg.Envs)

View source record →