- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 3,584 for Hour (0.05 sec)
-
pkg/credentialprovider/plugin/plugin_test.go
cache: cache.NewExpirationStore(cacheKeyFunc, &cacheExpirationPolicy{clock: tclock}), plugin: &fakeExecPlugin{ cacheKeyType: credentialproviderapi.RegistryPluginCacheKeyType, cacheDuration: time.Hour, auth: map[string]credentialproviderapi.AuthConfig{ "*.registry.io": { Username: "user", Password: "password", }, }, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 09 06:11:06 UTC 2022 - 26.5K bytes - Viewed (0) -
internal/rest/client.go
// https://www.awsarchitectureblog.com/2015/03/backoff.html func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration { if attempt > 16 { // Protect against integer overflow attempt = 16 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
type Reactor struct { verb string objectType string reaction fakeclient.ReactionFunc } func testTryAcquireOrRenew(t *testing.T, objectType string) { future := time.Now().Add(1000 * time.Hour) past := time.Now().Add(-1000 * time.Hour) tests := []struct { name string observedRecord rl.LeaderElectionRecord observedTime time.Time reactors []Reactor key string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
} // instead of using the shared informers from the controlplane instance, we construct our own informer // because we need such a small subset of the information available, only the kubernetes.default ServiceCIDR c.serviceCIDRInformer = networkingv1alpha1informers.NewFilteredServiceCIDRInformer(client, 12*time.Hour, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, func(options *metav1.ListOptions) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0) -
src/crypto/tls/generate_cert.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 08 15:22:02 UTC 2022 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
defer klog.InfoS("Shutting down controller", "name", c.name) // we have a personal informer that is narrowly scoped, start it. go c.configMapInformer.Run(ctx.Done()) // wait for your secondary caches to fill before starting your work if !cache.WaitForNamedCacheSync(c.name, ctx.Done(), c.preRunCaches...) { return } // doesn't matter what workers say, only start one.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/globals.go
// tmp directory are deemed stale. GlobalStaleUploadsExpiry = time.Hour * 24 // 24 hrs. // GlobalStaleUploadsCleanupInterval - Cleanup interval when the stale uploads cleanup is initiated. GlobalStaleUploadsCleanupInterval = time.Hour * 6 // 6 hrs. // Refresh interval to update in-memory iam config cache. globalRefreshIAMInterval = 10 * time.Minute
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/x509/x509_test.go
CurrentTime: time.Now().Add(time.Duration(-100 * time.Hour * 24 * 365)), Roots: getRootCertPool(t), }, Certs: getCerts(t, clientCNCert), User: CommonNameUserConversion, ExpectOK: false, ExpectErr: true, }, "expired cert": { Opts: x509.VerifyOptions{ CurrentTime: time.Now().Add(time.Duration(100 * time.Hour * 24 * 365)), Roots: getRootCertPool(t), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 23:23:03 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
} func newController(cs kubernetes.Interface, cl clock.Clock, limiter *rate.Limiter) *Controller { informer := corev1informers.NewFilteredConfigMapInformer(cs, metav1.NamespaceSystem, 12*time.Hour, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, func(options *metav1.ListOptions) { options.FieldSelector = fields.OneTermEqualSelector("metadata.name", ConfigMapName).String() }) c := &Controller{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/registry/certificates/certificates/strategy_test.go
t.Errorf("object diff: %s", cmp.Diff(obj, tc.expectedObj)) } }) } } func TestStatusUpdate(t *testing.T) { now := metav1.Now() later := metav1.NewTime(now.Add(time.Hour)) nowFunc = func() metav1.Time { return now } defer func() { nowFunc = metav1.Now }() tests := []struct { name string newObj *certapi.CertificateSigningRequest
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 7.6K bytes - Viewed (0)