- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 291 for bursty (0.19 sec)
-
pkg/kubelet/images/image_manager.go
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
Raw: []byte(`{"foo":"bar"}`), }, }, }, }, }, }, 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: ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 22.2K bytes - Viewed (0) -
platforms/software/resources/src/test/groovy/org/gradle/internal/resource/ExternalResourceNameTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 02 17:19:47 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
LOGGER.lifecycle(DAEMON_WILL_STOP_MESSAGE + reason); if (state == State.Busy) { LOGGER.debug("Stop as soon as idle requested. The daemon is busy"); beginStopping(); } else { stopNow(reason); } } } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K 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
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
"--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", "--audit-policy-file=/policy",
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/deprecated_insecure_serving.go
// and those can be throttled in case of higher load on apiserver - see #22340 and #22422 // for more details. Once #22422 is fixed, we may want to remove it. QPS: 50, Burst: 100, }, nil } // InsecureSuperuser implements authenticator.Request to always return a superuser. // This is functionally equivalent to skipping authentication and authorization,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 27 15:58:45 UTC 2021 - 3.2K bytes - Viewed (0) -
pkg/proxy/apis/config/validation/validation_test.go
ccc: componentbaseconfig.ClientConnectionConfiguration{Burst: 0}, expectedErrs: field.ErrorList{}, }, "successful 5 value": { ccc: componentbaseconfig.ClientConnectionConfiguration{Burst: 5}, expectedErrs: field.ErrorList{}, }, "burst < 0": { ccc: componentbaseconfig.ClientConnectionConfiguration{Burst: -5},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 33.3K bytes - Viewed (0) -
guava/src/com/google/common/hash/Striped64.java
transient volatile int busy; /** Package-private default constructor */ Striped64() {} /** CASes the base field. */ final boolean casBase(long cmp, long val) { return UNSAFE.compareAndSwapLong(this, baseOffset, cmp, val); } /** CASes the busy field from 0 to 1 to acquire lock. */ final boolean casBusy() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/registry/DaemonRegistryUpdaterTest.groovy
when: updater.onCompleteActivity() then: noExceptionThrown() } def "marks busy"() { given: updater.onStart(address) when: updater.onStartActivity() then: 1 * registry.markState(address, Busy) } def "marks canceled"() { given: updater.onStart(address) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.6K bytes - Viewed (0)