- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 492 for CLOCK (0.03 sec)
-
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/source/DefaultStdOutLoggingSystem.java
import org.gradle.internal.logging.events.OutputEventListener; import org.gradle.internal.time.Clock; import java.io.PrintStream; public class DefaultStdOutLoggingSystem extends PrintStreamLoggingSystem implements StdOutLoggingSystem { public DefaultStdOutLoggingSystem(OutputEventListener listener, Clock clock) { super(listener, "system.out", clock); } @Override protected PrintStream get() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/testng/TestNgTestClassProcessorFactory.java
this.suiteFiles = suiteFiles; } @Override public TestClassProcessor create(IdGenerator<?> idGenerator, ActorFactory actorFactory, Clock clock) { return new TestNGTestClassProcessor(testReportDir, options, suiteFiles, idGenerator, clock, actorFactory); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 1.9K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/JUnitTestClassProcessorFactory.java
this.spec = spec; } @Override public TestClassProcessor create(IdGenerator<?> idGenerator, ActorFactory actorFactory, Clock clock) { return new JUnitTestClassProcessor(spec, idGenerator, actorFactory, clock); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 1.6K bytes - Viewed (0) -
pkg/credentialprovider/plugin/plugin.go
} clock := clock.RealClock{} return &pluginProvider{ clock: clock, matchImages: provider.MatchImages, cache: cache.NewExpirationStore(cacheKeyFunc, &cacheExpirationPolicy{clock: clock}), defaultCacheDuration: provider.DefaultCacheDuration.Duration, lastCachePurge: clock.Now(), plugin: &execPlugin{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 05 05:07:28 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager.go
ShutdownGracePeriodCriticalPods time.Duration ShutdownGracePeriodByPodPriority []kubeletconfig.ShutdownGracePeriodByPodPriority StateDirectory string Clock clock.Clock } // managerStub is a fake node shutdown managerImpl . type managerStub struct{} // Admit returns a fake Pod admission which always returns true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 24 09:20:34 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/kubelet/token/token_manager.go
cache map[string]*authenticationv1.TokenRequest // mocked for testing getToken func(name, namespace string, tr *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error) clock clock.Clock } // GetServiceAccountToken gets a service account token for a pod from cache or // from the TokenRequest API. This process is as follows: // * Check the cache for the current token request.
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/runtime/netpoll_wasip1.go
timeout := &subs[0] eventtype := timeout.u.eventtype() *eventtype = eventtypeClock clock := timeout.u.subscriptionClock() clock.id = clockMonotonic clock.precision = 1e3 } func netpollIsPollDescriptor(fd uintptr) bool { return false } func netpollopen(fd uintptr, pd *pollDesc) int32 { lock(&mtx) // We don't worry about pd.fdseq here, // as mtx protects us from stale pollDescs. pds = append(pds, pd)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kubelet/active_deadline_test.go
fakeRecorder := &record.FakeRecorder{} fakeClock := testingclock.NewFakeClock(time.Now()) testCases := []struct { podStatusProvider status.PodStatusProvider recorder record.EventRecorder clock clock.Clock }{ {podStatusProvider, fakeRecorder, fakeClock}, {podStatusProvider, fakeRecorder, nil}, {podStatusProvider, nil, fakeClock}, {podStatusProvider, nil, nil}, {nil, fakeRecorder, fakeClock},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 08 09:06:42 UTC 2022 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/eventclock/interface.go
limitations under the License. */ package eventclock import ( "time" baseclock "k8s.io/utils/clock" ) // EventFunc does some work that needs to be done at or after the // given time. type EventFunc func(time.Time) // EventClock is an active clock abstraction for use in code that is // testable with a fake clock that itself determines how time may be // advanced. The timing paradigm is invoking EventFuncs rather than
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 07 04:07:31 UTC 2021 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/object_count_tracker.go
// StorageObjectCountTracker interface that can be used to // keep track of the total number of objects for each resource. func NewStorageObjectCountTracker() StorageObjectCountTracker { return &objectCountTracker{ clock: &clock.RealClock{}, counts: map[string]*timestampedCount{}, } } // timestampedCount stores the count of a given resource with a last updated // timestamp so we can prune it after it goes stale for certain threshold.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 09:12:00 UTC 2022 - 5K bytes - Viewed (0)