- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 85 for clock3 (0.11 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/LauncherServices.java
if (!requestMetaData.isInteractive()) { return new NonInteractiveUserInputHandler(); } return new DefaultUserInputHandler(outputEventListenerManager.getBroadcaster(), clock, inputReader); } @Provides
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 13:01:53 UTC 2024 - 12.9K bytes - Viewed (0) -
manifests/addons/dashboards/jsonnetfile.lock.json
John Howard <******@****.***> 1717524306 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 18:05:06 UTC 2024 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
startBucketID int64 clock clock.Clock bookmarkFrequency time.Duration } func newTimeBucketWatchers(clock clock.Clock, bookmarkFrequency time.Duration) *watcherBookmarkTimeBuckets { return &watcherBookmarkTimeBuckets{ watchersBuckets: make(map[int64][]*cacheWatcher), createTime: clock.Now(), startBucketID: 0, clock: clock, bookmarkFrequency: bookmarkFrequency,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
} func (i *objectCacheItem) setLastAccessTime(time time.Time) { i.lock.Lock() defer i.lock.Unlock() i.lastAccessTime = time } func (i *objectCacheItem) setImmutable() { i.lock.Lock() defer i.lock.Unlock() i.immutable = true } func (i *objectCacheItem) stopIfIdle(now time.Time, maxIdleTime time.Duration) bool { i.lock.Lock() defer i.lock.Unlock() // Ensure that we don't try to stop not yet initialized reflector.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
w.setBookmarkAfterResourceVersion(0) return w } clock := testingclock.NewFakeClock(time.Now()) watchers := newTimeBucketWatchers(clock, defaultBookmarkFrequency) now := clock.Now() watchers.addWatcherThreadUnsafe(newWatcher(now.Add(10 * time.Second))) watchers.addWatcherThreadUnsafe(newWatcher(now.Add(20 * time.Second)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
orphanQueue: workqueue.NewTypedRateLimitingQueueWithConfig(workqueue.NewTypedItemExponentialFailureRateLimiter[string](DefaultJobApiBackOff, MaxJobApiBackOff), workqueue.TypedRateLimitingQueueConfig[string]{Name: "job_orphan_pod", Clock: clock}), broadcaster: eventBroadcaster,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/build/relnote/relnote.go
slices.Sort(filenames) return filenames, nil } // lastBlock returns the last block in the document. // It panics if the document has no blocks. func lastBlock(doc *md.Document) md.Block { return doc.Blocks[len(doc.Blocks)-1] } // addLines adds n lines to the position of b. // n can be negative. func addLines(b md.Block, n int) { pos := position(b) pos.StartLine += n pos.EndLine += n }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
indexerFuncs map[string]storage.IndexerFunc clock clock.WithTicker } type setupOption func(*setupOptions) func withDefaults(options *setupOptions) { prefix := "/pods" options.resourcePrefix = prefix options.keyFunc = func(obj runtime.Object) (string, error) { return storage.NamespaceKeyFunc(prefix, obj) } options.clock = clock.RealClock{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} } func (w *timeIncrementingWorkers) tick() { w.lock.Lock() defer w.lock.Unlock() w.w.clock.(*clocktesting.FakePassiveClock).SetTime(w.w.clock.Now().Add(time.Second)) } // createTimeIncrementingPodWorkers will guarantee that each call to UpdatePod and each worker goroutine invocation advances the clock by one second, // although multiple workers will advance the clock in an unpredictable order. Use to observe
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0)