- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 115 for qps (0.02 sec)
-
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) -
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) -
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)