Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 244 for limiter (0.95 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top