- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Hurst (0.22 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
int oneSecWorthOfWork = rate; stopwatch.sleepMillis(rate * 1000); limiter.setRate(rate); long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // we allow one second worth of work to go in a burst (i.e. take less than a second) assertTrue(burst <= 1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens need := len(buf) // number of bytes requested by caller hdr := r.opts.HeaderSize // remaining header bytes var tokens int // number of tokens to request
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
cni/pkg/ambient/server.go
func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) { config.QPS = 80 config.Burst = 160 }) if err != nil { return nil, fmt.Errorf("failed creating kube config: %v", err) } client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "") if err != nil {
Go - Registered: Wed Jan 24 22:53:09 GMT 2024 - Last Modified: Tue Nov 21 01:17:13 GMT 2023 - 8.7K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 20:49:02 GMT 2024 - 6K bytes - Viewed (0) -
istioctl/pkg/cli/context.go
// We are running a one-off command locally, so we don't need to worry too much about rate limiting // Bumping this up greatly decreases install time config.QPS = 50 config.Burst = 100 }) if err != nil { return nil, err } return kube.NewCLIClient(kube.NewClientConfigForRestConfig(rc), revision) } func NewCLIContext(rootFlags *RootFlags) Context { if rootFlags == nil {
Go - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Fri Jan 26 18:01:27 GMT 2024 - 6.4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) { config.QPS = 80 config.Burst = 160 }) if err != nil { return nil, fmt.Errorf("failed creating kube config: %v", err) } client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "") if err != nil {
Go - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 17:46:23 GMT 2024 - 7.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
testenv = &envtest.Environment{} testRestConfig, err := testenv.Start() if err != nil { return err } _, err = kubernetes.NewForConfig(testRestConfig) testRestConfig.QPS = 50 testRestConfig.Burst = 100 if err != nil { return err } s := scheme.Scheme s.AddKnownTypes(v1alpha1.SchemeGroupVersion, &v1alpha1.IstioOperator{}) testClient, err = client.New(testRestConfig, client.Options{Scheme: s})
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (0) -
cmd/peer-rest-server.go
rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) // Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 17:19:14 GMT 2024 - 51.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.25.md
- Kube-controller-manager: Removed flags `deleting-pods-qps`, `deleting-pods-burst`, and `register-retry-count`. ([#109612](https://github.com/kubernetes/kubernetes/pull/109612), [@pandaamanda](https://github.com/pandaamanda))
Plain Text - Registered: Fri Mar 22 09:05:09 GMT 2024 - Last Modified: Thu Nov 16 11:30:31 GMT 2023 - 419K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// MaxLimitRequestRatio if specified, the named resource must have a request and limit that are both non-zero where limit divided by request is less than or equal to the enumerated value; this represents the max burst for the named resource. // +optional map<string, k8s.io.apimachinery.pkg.api.resource.Quantity> maxLimitRequestRatio = 6; } // LimitRangeList is a list of LimitRange items. message LimitRangeList {
Plain Text - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 255.8K bytes - Viewed (0)