- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,302 for itemout (0.13 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go
var timeout time.Duration if opts.TimeoutSeconds != nil { timeout = time.Duration(*opts.TimeoutSeconds) * time.Second } result = &v1beta1.CustomResourceDefinitionList{} err = c.client.Get(). Resource("customresourcedefinitions"). VersionedParams(&opts, scheme.ParameterCodec). Timeout(timeout). Do(ctx). Into(result) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go
func newMockEnvelopeService(ctx context.Context, endpoint string, timeout time.Duration) (envelope.Service, error) { return &testEnvelopeService{nil}, nil } // The factory method to create mock envelope service which always returns error. func newMockErrorEnvelopeService(endpoint string, timeout time.Duration) (envelope.Service, error) { return &testEnvelopeService{errors.New("test")}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 72.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
} /** @since 28.0 */ @Override public final void awaitRunning(Duration timeout) throws TimeoutException { Service.super.awaitRunning(timeout); } /** @since 15.0 */ @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException { delegate.awaitRunning(timeout, unit); } /** @since 15.0 */ @Override public final void awaitTerminated() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 7.9K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/concurrent/JavaSystemPropertiesAsyncIOScopeSettingsTest.kt
@JvmField val setSystemProperties = SetSystemProperties() @Test fun `use default timeout when property is not set`() { val settings = JavaSystemPropertiesAsyncIOScopeSettings() assertEquals(DEFAULT_IO_ACTION_TIMEOUT, settings.ioActionTimeoutMs) } @Test fun `use default timeout when property is an empty string`() { System.setProperty(IO_ACTION_TIMEOUT_SYSTEM_PROPERTY, "")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 3.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
} override fun timeout(): Timeout = timeout } /** * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source] in * the current part. If this returns 0 the current part is exhausted; otherwise it has at least * one byte left to read. */ private fun currentPartBytesRemaining(maxResult: Long): Long {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.1K bytes - Viewed (0) -
tests/integration/security/remote_jwks/remote_jwks_test.go
"X-Test-Payload": payload1, })) }, }, { name: "remote-jwks-with-service-entry", policyFile: "./testdata/requestauthn-with-se-timeout.yaml.tmpl", timeout: "10ms", delay: "30ms", customizeCall: func(t framework.TestContext, from echo.Instance, opts *echo.CallOptions) { opts.HTTP.Path = "/valid-token-forward-remote-jwks"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.1K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
func (r *JwksResolver) GetPublicKey(issuer string, jwksURI string, timeout time.Duration) (string, error) { now := time.Now() key := jwtKey{issuer: issuer, jwksURI: jwksURI} if val, found := r.keyEntries.Load(key); found { e := val.(jwtPubKeyEntry) // Update cached key's last used time. e.lastUsedTime = now e.timeout = timeout r.keyEntries.Store(key, e) if e.pubKey == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/fetch.go
var src string duration, timeout := time.Duration(s.Seconds)*time.Second, time.Duration(s.Timeout)*time.Second if fetcher != nil { p, src, err = fetcher.Fetch(source, duration, timeout) if err != nil { return } } if err != nil || p == nil { // Fetch the profile over HTTP or from a file. p, src, err = fetch(source, duration, timeout, ui, tr) if err != nil { return } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 19K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolutionstrategy/DefaultCachePolicySpec.groovy
assert !atTimeout.mustCheck assert atTimeout.keepFor == Duration.ZERO def almostExpired = cachePolicy.versionListExpiry(null, [moduleId] as Set, Duration.ofMillis(timeout - 1)) assert !almostExpired.mustCheck assert almostExpired.keepFor == Duration.ofMillis(1) def expired = cachePolicy.versionListExpiry(null, [moduleId] as Set, Duration.ofMillis(timeout + 1))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Oct 30 22:04:14 UTC 2023 - 22.3K bytes - Viewed (0) -
ci/official/containers/linux_arm64/builder.devtoolset/build_devtoolset.sh
devtoolset-9) wget --retry-connrefused --waitretry=1 --read-timeout=20 --timeout=15 --tries=5 "https://vault.centos.org/centos/7/sclo/Source/rh/devtoolset-9-gcc-9.3.1-2.2.el7.src.rpm" rpm2cpio "devtoolset-9-gcc-9.3.1-2.2.el7.src.rpm" |cpio -idmv tar -xvf "gcc-9.3.1-20200408.tar.xz" --strip 1 ;; devtoolset-10)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Sep 29 00:26:34 UTC 2023 - 6.1K bytes - Viewed (0)