- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 244 for limiter (0.95 sec)
-
src/runtime/mgclimit.go
func (l *gcCPULimiterState) limiting() bool { return l.enabled.Load() } // startGCTransition notifies the limiter of a GC transition. // // This call takes ownership of the limiter and disables all other means of // updating the limiter. Release ownership by calling finishGCTransition. // // It is safe to call concurrently with other operations.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
src/runtime/export_test.go
return l } func (l *GCCPULimiter) Fill() uint64 { return l.limiter.bucket.fill } func (l *GCCPULimiter) Capacity() uint64 { return l.limiter.bucket.capacity } func (l *GCCPULimiter) Overflow() uint64 { return l.limiter.overflow } func (l *GCCPULimiter) Limiting() bool { return l.limiter.limiting() } func (l *GCCPULimiter) NeedUpdate(now int64) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
if limiter := pl.Spec.Limited; limiter != nil { return limiter.NominalConcurrencyShares, limiter.LendablePercent, limiter.BorrowingLimitPercent } limiter := pl.Spec.Exempt var nominalConcurrencyShares int32 if limiter.NominalConcurrencyShares != nil { nominalConcurrencyShares = *limiter.NominalConcurrencyShares }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
src/runtime/metrics/doc.go
runtime, only their block. Each block is already accounted for in allocs-by-size and frees-by-size. /gc/limiter/last-enabled:gc-cycle GC cycle the last time the GC CPU limiter was enabled. This metric is useful for diagnosing the root cause of an out-of-memory error, because the limiter trades memory for CPU time when the GC's CPU time gets too high. This is most likely
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:58:43 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
if prober != nil { prober.Close() clientErr = fmt.Errorf("server is shutting down") } }() // limit to a request every half of the configured timeout with a maximum burst of one // rate limited requests will receive the last request sent error (note: not the last received response) limiter := rate.NewLimiter(rate.Every(timeout/2), 1) // initial state is the clientErr
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
// cleanup is to delete the workload entry // queue contains workloadEntry that need to be unregistered queue controllers.Queue // cleanupLimit rate limit's auto registered WorkloadEntry cleanup calls to k8s cleanupLimit *rate.Limiter // cleanupQueue delays the cleanup of auto registered WorkloadEntries to allow for grace period cleanupQueue queue.Delayed adsConnections *adsConnections
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
// 10 qps, 100 bucket size. This is only for retry speed and its // only the overall factor (not per item). &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "endpoint_slice_mirroring", }, ), workerLoopPeriod: time.Second, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
}) c.serviceLister = serviceInformer.Lister() c.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addPod, UpdateFunc: c.updatePod, DeleteFunc: c.deletePod, }) c.podLister = podInformer.Lister() c.podsSynced = podInformer.Informer().HasSynced c.nodeLister = nodeInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
DeleteFunc: c.deleteServiceCIDR, }) c.serviceCIDRLister = serviceCIDRInformer.Lister() c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced _, _ = ipAddressInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addIPAddress, DeleteFunc: c.deleteIPAddress, }) c.ipAddressLister = ipAddressInformer.Lister() c.ipAddressSynced = ipAddressInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
ProxyNeedsPush func(proxy *model.Proxy, req *model.PushRequest) bool // concurrentPushLimit is a semaphore that limits the amount of concurrent XDS pushes. concurrentPushLimit chan struct{} // RequestRateLimit limits the number of new XDS requests allowed. This helps prevent thundering hurd of incoming requests. RequestRateLimit *rate.Limiter // InboundUpdates describes the number of configuration updates the discovery server has received
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0)