- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 4,994 for Hour (0.05 sec)
-
pkg/controlplane/controller/kubernetesservice/controller_test.go
t.Run(test.testName, func(t *testing.T) { master := Controller{} fakeClient := fake.NewSimpleClientset(test.service) serviceInformer := v1informers.NewServiceInformer(fakeClient, metav1.NamespaceDefault, 12*time.Hour, cache.Indexers{}) serviceStore := serviceInformer.GetIndexer() err := serviceStore.Add(test.service) if err != nil { t.Fatalf("unexpected error adding service %v to the store: %v", test.service, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 10:41:06 UTC 2023 - 15.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/SearchLogService.java
createSearchLogCondition(pager, cb); cb.aggregation().setRequestedAt_DateHistogram(SearchLogPager.LOG_TYPE_SEARCH_COUNT_HOUR, op -> { op.calendarInterval(DateHistogramInterval.HOUR); op.minDocCount(0); op.order(BucketOrder.key(true)); }, null); });
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 28.4K bytes - Viewed (0) -
cmd/bucket-stats.go
// // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 13.1K bytes - Viewed (0) -
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) -
src/main/java/jcifs/smb1/smb1/ServerMessageBlock.java
} else { // t not in DST so subtract 1 hour t -= 3600000; } } else { // not in DST if( TZ.inDaylightTime( new Date( t ))) { // t is in DST so add 1 hour t += 3600000; } else { // t isn't in DST either
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 21K 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) -
pkg/kubelet/token/token_manager.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" "k8s.io/klog/v2" "k8s.io/utils/clock" ) const ( maxTTL = 24 * time.Hour gcPeriod = time.Minute maxJitter = 10 * time.Second ) // NewManager returns a new token manager. func NewManager(c clientset.Interface) *Manager {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 6.1K 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)