- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 87 for bursty (0.12 sec)
-
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonEventSequenceBuilder.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonStartupMessageTest.groovy
*/ package org.gradle.launcher.daemon.client import spock.lang.Specification class DaemonStartupMessageTest extends Specification { def "starting message contains number of busy and incompatible daemons (#numBusy busy, #numIncompatible incompatible, #numStopped stopped)"() { given: def message = DaemonStartupMessage.generate(numBusy, numIncompatible, numStopped) expect:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
pkg/test/framework/components/istio/installer.go
} rc, err := kube.DefaultRestConfig(kubeConfigFile, "", func(config *rest.Config) { config.QPS = 50 config.Burst = 100 }) if err != nil { return err } kubeClient, err := kube.NewCLIClient(kube.NewClientConfigForRestConfig(rc)) if err != nil { return fmt.Errorf("create Kubernetes client: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.8K 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) -
platforms/core-runtime/build-profile/src/test/groovy/org/gradle/profile/TaskExecutionTest.groovy
def "knows task status"() { def skipped = Stub(TaskState) { getSkipped() >> true getSkipMessage() >> "Skipped for a good reason." } def busy = Stub(TaskState) { getSkipped() >> false getDidWork() >> true } def noWork = Stub(TaskState) { getSkipped() >> false getDidWork() >> false }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Dec 01 12:58:53 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/registry/EmbeddedDaemonRegistrySpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.1K bytes - Viewed (0)