- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 121 for QPS (0.17 sec)
-
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* calling thread wait for that time. * * The simplest way to maintain a rate of QPS is to keep the timestamp of the last granted * request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of * QPS=5 (5 tokens per second), if we ensure that a request isn't granted earlier than 200ms after
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/options_test.go
"--audit-log-mode=blocking", "--audit-log-batch-buffer-size=46", "--audit-log-batch-max-size=47", "--audit-log-batch-max-wait=48s", "--audit-log-batch-throttle-enable=true", "--audit-log-batch-throttle-qps=49.5", "--audit-log-batch-throttle-burst=50", "--audit-log-truncate-enabled=true", "--audit-log-truncate-max-batch-size=45", "--audit-log-truncate-max-event-size=44", "--audit-log-version=audit.k8s.io/v1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/audit.go
defaultBatchMaxWait = 30 * time.Second // Send events at least twice a minute. defaultBatchThrottleQPS = 10 // Limit the send rate by 10 QPS. defaultBatchThrottleBurst = 15 // Allow up to 15 QPS burst. ) func appendBackend(existing, newBackend audit.Backend) audit.Backend { if existing == nil { return newBackend } if newBackend == nil { return existing }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 24 06:30:04 UTC 2022 - 20.3K bytes - Viewed (0) -
pkg/controller/podautoscaler/metrics/client_test.go
"test-pod-2": {Value: 10000, Timestamp: offsetTimestampBy(targetTimestamp), Window: metricServerDefaultMetricWindow}, }, metricName: "qps", targetTimestamp: targetTimestamp, reportedMetricPoints: []metricPoint{{10000, 1}, {20000, 1}, {10000, 1}}, } tc.runTest(t) } func TestRESTClientSingleObject(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 09 02:34:54 UTC 2021 - 16.4K bytes - Viewed (0) -
pkg/kubelet/images/image_manager.go
func NewImageManager(recorder record.EventRecorder, imageService kubecontainer.ImageService, imageBackOff *flowcontrol.Backoff, serialized bool, maxParallelImagePulls *int32, qps float32, burst int, podPullingTimeRecorder ImagePodPullingTimeRecorder) ImageManager { imageService = throttleImagePulling(imageService, qps, burst) var puller imagePuller if serialized { puller = newSerialImagePuller(imageService) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 00:30:31 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/scheduler/apis/config/scheme/scheme_test.go
}, }, }, }, }, want: `apiVersion: kubescheduler.config.k8s.io/v1 clientConnection: acceptContentTypes: "" burst: 0 contentType: "" kubeconfig: "" qps: 0 kind: KubeSchedulerConfiguration leaderElection: leaderElect: null leaseDuration: 0s renewDeadline: 0s resourceLock: "" resourceName: "" resourceNamespace: "" retryPeriod: 0s
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 22.2K bytes - Viewed (0) -
manifests/addons/dashboards/lib/panels.libsonnet
self.base(title, targets, desc) + timeSeries.standardOptions.withUnit('cps'), dns(title, targets, desc=''): self.base(title, targets, desc) + timeSeries.standardOptions.withUnit('qps'), bytes(title, targets, desc=''): self.base(title, targets, desc) + timeSeries.standardOptions.withUnit('bytes'), bytesRate(title, targets, desc=''): self.base(title, targets, desc)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 4.5K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
return desiredStatus } return status }), } // client-go defaults to 5 QPS, with 10 Boost, which is insufficient for updating status on all the config // in the mesh. These values can be configured using environment variables for tuning (see pilot/pkg/features) restConfig.QPS = float32(features.StatusQPS) restConfig.Burst = features.StatusBurst var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
"--audit-log-mode=blocking", "--audit-log-batch-buffer-size=46", "--audit-log-batch-max-size=47", "--audit-log-batch-max-wait=48s", "--audit-log-batch-throttle-enable=true", "--audit-log-batch-throttle-qps=49.5", "--audit-log-batch-throttle-burst=50", "--audit-log-truncate-enabled=true", "--audit-log-truncate-max-batch-size=45", "--audit-log-truncate-max-event-size=44", "--audit-log-version=audit.k8s.io/v1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/authorization.go
} return nil, nil } } if err != nil { return nil, fmt.Errorf("failed to get delegated authorization kubeconfig: %v", err) } // set high qps/burst limits since this will effectively limit API server responsiveness clientConfig.QPS = 200 clientConfig.Burst = 400 clientConfig.Timeout = s.ClientTimeout if s.CustomRoundTripperFn != nil { clientConfig.Wrap(s.CustomRoundTripperFn) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 9.3K bytes - Viewed (0)