Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 468 for limiter (0.21 sec)

  1. src/runtime/mgcpacer_test.go

    				}
    			},
    		},
    		{
    			// The most basic test case with a memory limit: a steady-state heap.
    			// Growth to an O(MiB) heap, then constant heap size, alloc/scan rates.
    			// Provide a lot of room for the limit. Essentially, this should behave just like
    			// the "Steady" test. Note that we don't simulate non-heap overheads, so the
    			// memory limit and the heap limit are identical.
    			name:          "SteadyMemoryLimit",
    			gcPercent:     100,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 19 13:53:21 UTC 2023
    - 39.3K bytes
    - Viewed (0)
  2. src/runtime/metrics.go

    			deps: makeStatDepSet(heapStatsDep),
    			compute: func(in *statAggregate, out *metricValue) {
    				out.kind = metricKindUint64
    				out.scalar = in.heapStats.tinyAllocCount
    			},
    		},
    		"/gc/limiter/last-enabled:gc-cycle": {
    			compute: func(_ *statAggregate, out *metricValue) {
    				out.kind = metricKindUint64
    				out.scalar = uint64(gcCPULimiter.lastEnabledCycle.Load())
    			},
    		},
    		"/gc/pauses:seconds": {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 08 21:03:13 UTC 2024
    - 26K bytes
    - Viewed (0)
  3. pkg/controller/deployment/deployment_controller.go

    			dc.deletePod(logger, obj)
    		},
    	})
    
    	dc.syncHandler = dc.syncDeployment
    	dc.enqueueDeployment = dc.enqueue
    
    	dc.dLister = dInformer.Lister()
    	dc.rsLister = rsInformer.Lister()
    	dc.podLister = podInformer.Lister()
    	dc.dListerSynced = dInformer.Informer().HasSynced
    	dc.rsListerSynced = rsInformer.Informer().HasSynced
    	dc.podListerSynced = podInformer.Informer().HasSynced
    	return dc, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repairip.go

    		interval:          interval,
    		client:            client,
    		serviceLister:     serviceInformer.Lister(),
    		servicesSynced:    serviceInformer.Informer().HasSynced,
    		serviceCIDRLister: serviceCIDRInformer.Lister(),
    		serviceCIDRSynced: serviceCIDRInformer.Informer().HasSynced,
    		ipAddressLister:   ipAddressInformer.Lister(),
    		ipAddressSynced:   ipAddressInformer.Informer().HasSynced,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  5. pkg/controller/endpoint/endpoints_controller.go

    		},
    		DeleteFunc: e.onServiceDelete,
    	})
    	e.serviceLister = serviceInformer.Lister()
    	e.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    e.addPod,
    		UpdateFunc: e.updatePod,
    		DeleteFunc: e.deletePod,
    	})
    	e.podLister = podInformer.Lister()
    	e.podsSynced = podInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. src/runtime/runtime2.go

    	// Per-P GC state
    	gcAssistTime         int64 // Nanoseconds in assistAlloc
    	gcFractionalMarkTime int64 // Nanoseconds in fractional mark worker (atomic)
    
    	// limiterEvent tracks events for the GC CPU limiter.
    	limiterEvent limiterEvent
    
    	// gcMarkWorkerMode is the mode for the next mark worker to run in.
    	// That is, this is used to communicate with the worker goroutine
    	// selected for immediate execution by
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/flowcontrol/v1beta1/types.go

    	Type PriorityLevelEnablement `json:"type" protobuf:"bytes,1,opt,name=type"`
    
    	// `limited` specifies how requests are handled for a Limited priority level.
    	// This field must be non-empty if and only if `type` is `"Limited"`.
    	// +optional
    	Limited *LimitedPriorityLevelConfiguration `json:"limited,omitempty" protobuf:"bytes,2,opt,name=limited"`
    
    	// `exempt` specifies how requests are handled for an exempt priority level.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 09:27:57 UTC 2023
    - 31.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/flowcontrol/v1/types_swagger_doc_generated.go

    	"limited": "`limited` specifies how requests are handled for a Limited priority level. This field must be non-empty if and...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 21.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/flowcontrol/v1beta3/types_swagger_doc_generated.go

    	"limited": "`limited` specifies how requests are handled for a Limited priority level. This field must be non-empty if and...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 01:00:06 UTC 2023
    - 21.5K bytes
    - Viewed (0)
  10. pkg/apis/flowcontrol/validation/validation.go

    		}
    
    		if spec.Limited == nil {
    			allErrs = append(allErrs, field.Required(fldPath.Child("limited"), "must not be empty when type is Limited"))
    		} else {
    			allErrs = append(allErrs, ValidateLimitedPriorityLevelConfiguration(spec.Limited, requestGV, fldPath.Child("limited"), opts)...)
    		}
    	default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 26.7K bytes
    - Viewed (0)
Back to top