- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 492 for CLOCK (0.03 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/cache_test.go
test: func(t *testing.T, cache *simpleCache, clock *clocktesting.FakeClock) { cache.set(key1, twi1) got := cache.get(info2, key1) twiPtrEquals(t, nil, got) cacheLenEquals(t, cache, 1) }, }, { name: "expired get after set", test: func(t *testing.T, cache *simpleCache, clock *clocktesting.FakeClock) { cache.set(key1, twi1) clock.Step(time.Hour) got := cache.get(info1, key1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 3.5K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
mu sync.RWMutex CurrentState map[status.Resource]map[string]Progress ObservationTime map[string]time.Time UpdateInterval time.Duration dynamicClient dynamic.Interface clock clock.Clock workers *status.Controller StaleInterval time.Duration cmInformer cache.SharedIndexInformer cmHandle cache.ResourceEventHandlerRegistration }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/timer.go
if t.t == nil { return } t.t.Stop() t.t = nil } var ( // RealTimer can be passed to methods that need a clock.Timer. RealTimer = clock.RealClock{}.NewTimer ) var ( // internalClock is used for test injection of clocks internalClock = clock.RealClock{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 04 01:19:55 UTC 2022 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/source/PrintStreamLoggingSystem.java
private final OutputEventListener listener; private final String category; private final Clock clock; public OutputEventDestination(OutputEventListener listener, String category, Clock clock) { this.listener = listener; this.category = category; this.clock = clock; } @Override public void onOutput(CharSequence output) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 5.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/BuildOperationProgressEventListenerAdapter.java
private final ProgressLoggerFactory progressLoggerFactory; private final Clock clock; private ProgressLogger progressLogger; private ProgressLogger statusProgressLogger; public BuildOperationProgressEventListenerAdapter(BuildOperationListener buildOperationListener, ProgressLoggerFactory progressLoggerFactory, Clock clock) { this.buildOperationListener = buildOperationListener;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:53:27 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/ConnectorServices.java
return new DefaultExecutorServiceFactory(); } @Provides protected Clock createTimeProvider() { return Time.clock(); } @Provides protected DistributionFactory createDistributionFactory(Clock clock) { return new DistributionFactory(clock); } @Provides
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 09:21:42 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/kubelet/util/cache/object_cache_test.go
expirationcache "k8s.io/client-go/tools/cache" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) type testObject struct { key string val string } // A fake objectCache for unit test. func NewFakeObjectCache(f func() (interface{}, error), ttl time.Duration, clock clock.Clock) *ObjectCache { ttlPolicy := &expirationcache.TTLPolicy{TTL: ttl, Clock: clock} deleteChan := make(chan string, 1) return &ObjectCache{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 2.6K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/TestClassExecutionEventGenerator.java
private TestDescriptorInternal currentTestClass; public TestClassExecutionEventGenerator(TestResultProcessor resultProcessor, IdGenerator<?> idGenerator, Clock clock) { this.resultProcessor = resultProcessor; this.idGenerator = idGenerator; this.clock = clock; } @Override public void testClassStarted(String testClassName) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 06 06:58:24 UTC 2024 - 4.4K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/DefaultBuildOperationProgressEventEmitter.java
private final BuildOperationTimeSupplier clock; private final CurrentBuildOperationRef current; private final BuildOperationListener listener; public DefaultBuildOperationProgressEventEmitter(BuildOperationTimeSupplier clock, CurrentBuildOperationRef current, BuildOperationListener listener) { this.clock = clock; this.current = current; this.listener = listener; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Feb 20 14:53:39 UTC 2024 - 2.8K bytes - Viewed (0)