- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 122 for QPS (0.05 sec)
-
cmd/kubelet/app/options/options.go
fs.Int32Var(&c.RegistryPullQPS, "registry-qps", c.RegistryPullQPS, "If > 0, limit registry pull QPS to this value. If 0, unlimited.") fs.Int32Var(&c.RegistryBurst, "registry-burst", c.RegistryBurst, "Maximum size of a bursty pulls, temporarily allows pulls to burst to this number, while still not exceeding registry-qps. Only used if --registry-qps > 0")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:05 UTC 2024 - 41.6K bytes - Viewed (0) -
plugin/pkg/admission/eventratelimit/limitenforcer.go
func newLimitEnforcer(config eventratelimitapi.Limit, clock flowcontrol.Clock) (*limitEnforcer, error) { rateLimiterFactory := func() flowcontrol.RateLimiter { return flowcontrol.NewTokenBucketRateLimiterWithClock(float32(config.QPS), int(config.Burst), clock) } if config.Type == eventratelimitapi.ServerLimitType { return &limitEnforcer{ limitType: config.Type, cache: &singleCache{ rateLimiter: rateLimiterFactory(), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 08 02:31:37 UTC 2021 - 3.8K bytes - Viewed (0) -
pkg/kubelet/apis/config/validation/validation.go
} if kc.EventRecordQPS < 0 { allErrors = append(allErrors, fmt.Errorf("invalid configuration: eventRecordQPS (--event-qps) %v must not be a negative number", kc.EventRecordQPS)) } if kc.HealthzPort != 0 && utilvalidation.IsValidPortNum(int(kc.HealthzPort)) != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 18.2K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go
// instantiating them multiple times. usePersistentConfig bool // Allows increasing burst used for discovery, this is useful // in clusters with many registered resources discoveryBurst int // Allows increasing qps used for discovery, this is useful // in clusters with many registered resources discoveryQPS float32 // Allows all possible warnings are printed in a standardized // format. warningPrinter *printers.WarningPrinter
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 15:04:11 UTC 2023 - 16.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/fake_kuberuntime_manager.go
kubeRuntimeManager, flowcontrol.NewBackOff(time.Second, 300*time.Second), false, utilpointer.Int32Ptr(0), // No limit on max parallel image pulls, 0, // Disable image pull throttling by setting QPS to 0, 0, &fakePodPullingTimeRecorder{}, ) kubeRuntimeManager.runner = lifecycle.NewHandlerRunner( &fakeHTTP{}, kubeRuntimeManager, kubeRuntimeManager, recorder)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 5.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
"k8s.io/client-go/dynamic" ) func TestChangeCRD(t *testing.T) { tearDown, config, _, err := fixtures.StartDefaultServer(t) if err != nil { t.Fatal(err) } defer tearDown() config.QPS = 1000 config.Burst = 1000 apiExtensionsClient, err := clientset.NewForConfig(config) if err != nil { t.Fatal(err) } dynamicClient, err := dynamic.NewForConfig(config) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
for (double qps : qpsToTest) { // If warmupPermits = maxPermits - thresholdPermits then // warmupPeriod = (1 + coldFactor) * warmupPermits * stableInterval / 2 long warmupMillis = (long) ((1 + coldFactor) * warmupPermits / (2.0 * qps) * 1000.0); RateLimiter rateLimiter = RateLimiter.create(qps, warmupMillis, MILLISECONDS, coldFactor, stopwatch);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
for (double qps : qpsToTest) { // If warmupPermits = maxPermits - thresholdPermits then // warmupPeriod = (1 + coldFactor) * warmupPermits * stableInterval / 2 long warmupMillis = (long) ((1 + coldFactor) * warmupPermits / (2.0 * qps) * 1000.0); RateLimiter rateLimiter = RateLimiter.create(qps, warmupMillis, MILLISECONDS, coldFactor, stopwatch);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner.go
timer: timer, } if minInterval == 0 { bfr.limiter = nullLimiter{} } else { // allow burst updates in short succession qps := float32(time.Second) / float32(minInterval) bfr.limiter = flowcontrol.NewTokenBucketRateLimiterWithClock(qps, burstRuns, timer) } return bfr } // Loop handles the periodic timer and run requests. This is expected to be // called as a goroutine.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 9.4K bytes - Viewed (0) -
cmd/kube-scheduler/app/server_test.go
}, wantClientConnection: &componentbaseconfig.ClientConnectionConfiguration{ Kubeconfig: configKubeconfig, ContentType: "application/vnd.kubernetes.protobuf", QPS: 50, Burst: 100, }, }, { name: "leader election CLI args, without --config arg", flags: []string{ "--leader-elect=false", "--leader-elect-lease-duration=2h",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.2K bytes - Viewed (0)