Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for SetLimit (0.14 sec)

  1. staging/src/k8s.io/cli-runtime/pkg/resource/visitor.go

    	// as it preserves the previous behavior, but allows components to opt into
    	// concurrency.
    	concurrency := 1
    	if l.concurrency > concurrency {
    		concurrency = l.concurrency
    	}
    	g.SetLimit(concurrency)
    
    	for i := range l.visitors {
    		i := i
    		g.Go(func() error {
    			return l.visitors[i].Visit(fn)
    		})
    	}
    
    	return g.Wait()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 10:17:56 UTC 2023
    - 21.3K bytes
    - Viewed (0)
Back to top