- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 503 for backref (0.21 sec)
-
pkg/scheduler/internal/queue/scheduling_queue_test.go
t.Errorf("pod %v is not in the backoff queue", podID) } // Check backoff duration. deadline := q.getBackoffTime(podInfo) backoff := deadline.Sub(timestamp) if backoff != step.wantBackoff { t.Errorf("got backoff %s, want %s", backoff, step.wantBackoff) } // Simulate routine that continuously flushes the backoff queue. cl.Step(time.Millisecond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/authorization.go
s.ClientTimeout = timeout } // WithCustomRetryBackoff sets the custom backoff parameters for the authorization webhook retry logic. func (s *DelegatingAuthorizationOptions) WithCustomRetryBackoff(backoff wait.Backoff) { s.WebhookRetryBackoff = &backoff } // WithCustomRoundTripper allows for specifying a middleware function for custom HTTP behaviour for the authorization webhook client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 9.3K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/resource/TextResourceIntegrationTest.groovy
class TextResourceIntegrationTest extends AbstractIntegrationSpec { @Rule TestResources resource = new TestResources(temporaryFolder) @Rule public final HttpServer server = new HttpServer() def "string backed text resource"() { when: run("stringText") then: result.assertTasksExecuted(":stringText") file("output.txt").text == "my config" when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go
maxControlledAttrCacheSize = 10000 ) // DefaultRetryBackoff returns the default backoff parameters for webhook retry. func DefaultRetryBackoff() *wait.Backoff { backoff := webhook.DefaultRetryBackoffWithInitialDelay(500 * time.Millisecond) return &backoff } // Ensure Webhook implements the authorizer.Authorizer interface. var _ authorizer.Authorizer = (*WebhookAuthorizer)(nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 18.4K bytes - Viewed (0) -
LICENSES/vendor/github.com/cenkalti/backoff/v4/LICENSE
= vendor/github.com/cenkalti/backoff/v4 licensed under: = The MIT License (MIT) Copyright (c) 2014 Cenk Altı Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 18 01:47:24 UTC 2022 - 1.2K bytes - Viewed (0) -
pkg/kubelet/events/event.go
StartedContainer = "Started" FailedToCreateContainer = "Failed" FailedToStartContainer = "Failed" KillingContainer = "Killing" PreemptContainer = "Preempting" BackOffStartContainer = "BackOff" ExceededGracePeriod = "ExceededGracePeriod" ) // Pod event reason list const ( FailedToKillPod = "FailedKillPod" FailedToCreatePodContainer = "FailedCreatePodContainer"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/authentication.go
TokenRequestTimeout: 10 * time.Second, } } // WithCustomRetryBackoff sets the custom backoff parameters for the authentication webhook retry logic. func (s *DelegatingAuthenticationOptions) WithCustomRetryBackoff(backoff wait.Backoff) { s.WebhookRetryBackoff = &backoff } // WithRequestTimeout sets the given timeout for requests made by the authentication webhook client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 21 14:51:22 UTC 2023 - 19.9K bytes - Viewed (0) -
platforms/software/publish/src/test/groovy/org/gradle/api/publish/internal/mapping/DefaultDependencyCoordinateResolverFactoryTest.groovy
projectDependencyResolver, moduleIdentifierFactory, attributeDesugaring ) def "returns project-only resolver when version mapping is disabled and variant is not resolution-backed"() { given: def variant = nonResolutionBacked() def versionMappingStrategy = versionMappingStrategy(false) expect:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 22:25:49 UTC 2023 - 9K bytes - Viewed (0) -
pkg/kubelet/config/file_linux.go
type retryableError struct { message string } func (e *retryableError) Error() string { return e.message } func (s *sourceFile) startWatch() { backOff := flowcontrol.NewBackOff(retryPeriod, maxRetryPeriod) backOffID := "watch" go wait.Forever(func() { if backOff.IsInBackOffSinceUpdate(backOffID, time.Now()) { return } if err := s.doWatch(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/authenticatorfactory/delegating.go
TokenAccessReviewTimeout time.Duration // WebhookRetryBackoff specifies the backoff parameters for the authentication webhook retry logic. // This allows us to configure the sleep time at each iteration and the maximum number of retries allowed // before we fail the webhook call in order to limit the fan out that ensues when the system is degraded. WebhookRetryBackoff *wait.Backoff
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 29 07:49:14 UTC 2021 - 5.1K bytes - Viewed (0)