Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ParallelizeUntil (0.18 sec)

  1. pkg/scheduler/framework/parallelize/parallelism.go

    	s := int(math.Sqrt(float64(n)))
    
    	if r := n/parallelism + 1; s > r {
    		s = r
    	} else if s < 1 {
    		s = 1
    	}
    	return s
    }
    
    // Until is a wrapper around workqueue.ParallelizeUntil to use in scheduling algorithms.
    // A given operation will be a label that is recorded in the goroutine metric.
    func (p Parallelizer) Until(ctx context.Context, pieces int, doWorkPiece workqueue.DoWorkPieceFunc, operation string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 09 17:12:30 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    	// can take a while if we're processing each node serially as well. So we
    	// process them with bounded concurrency instead, since most of the time is
    	// spent waiting on io.
    	workqueue.ParallelizeUntil(ctx, nc.nodeUpdateWorkerSize, len(nodes), updateNodeFunc)
    
    	nc.handleDisruption(ctx, zoneToNodeConditions, nodes)
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.15.md

    - Removed the function Parallelize, please convert to use the function ParallelizeUntil. ([#76595](https://github.com/kubernetes/kubernetes/pull/76595), [@danielqsj](https://github.com/danielqsj))
    
    ### Apps
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 278.9K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.13.md

    * Replace Parallelize with function ParallelizeUntil and formally deprecate the Parallelize. ([#68403](https://github.com/kubernetes/kubernetes/pull/68403), [@wgliang](https://github.com/wgliang))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 273.1K bytes
    - Viewed (0)
Back to top