Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for doProcess (0.08 sec)

  1. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	// at the same time high enough to start listing before we process
    	// the whole page.
    	chanSize := 2 * workersNumber
    	if chanSize < 256 {
    		chanSize = 256
    	}
    	toProcess := make(chan runtime.Object, chanSize)
    	errs := make(chan error, workersNumber+1)
    	workersExited := make(chan struct{})
    
    	wg.Add(workersNumber)
    	for i := 0; i < workersNumber; i++ {
    		go func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
Back to top