- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,167 for clock3 (0.28 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
resetInterval time.Duration clock clock.Clock lock sync.Mutex lastStart time.Time timer clock.Timer } // Step returns the expected next duration to wait. func (b *backoffManager) Step() time.Duration { b.lock.Lock() defer b.lock.Unlock() switch { case b.resetInterval == 0: b.backoff = b.initialBackoff case b.clock.Now().Sub(b.lastStart) > b.resetInterval:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/metrics.go
return newInstrumentedAuthenticatorWithClock(jwtIssuer, delegate, clock.RealClock{}) } func newInstrumentedAuthenticatorWithClock(jwtIssuer string, delegate AuthenticatorTokenWithHealthCheck, clock clock.PassiveClock) *instrumentedAuthenticator { RegisterMetrics() return &instrumentedAuthenticator{ jwtIssuerHash: getHash(jwtIssuer), delegate: delegate, clock: clock, } } type instrumentedAuthenticator struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/legacy/DefaultBuildScanClock.java
import org.gradle.internal.time.Clock; import javax.inject.Inject; public class DefaultBuildScanClock implements BuildScanClock { private final Clock clock; @Inject public DefaultBuildScanClock(Clock clock) { this.clock = clock; } @Override public long getCurrentTime() { return clock.getCurrentTime(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 15 17:58:47 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/progress/DefaultProgressLoggerFactory.java
public DefaultProgressLoggerFactory(ProgressListener progressListener, Clock clock, BuildOperationIdFactory buildOperationIdFactory) { this.progressListener = progressListener; this.clock = clock; this.buildOperationIdFactory = buildOperationIdFactory; } @Override public ProgressLogger newOperation(Class<?> loggerCategory) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/active_deadline.go
recorder record.EventRecorder, clock clock.Clock, ) (*activeDeadlineHandler, error) { // check for all required fields if clock == nil || podStatusProvider == nil || recorder == nil { return nil, fmt.Errorf("required arguments must not be nil: %v, %v, %v", clock, podStatusProvider, recorder) } return &activeDeadlineHandler{ clock: clock, podStatusProvider: podStatusProvider,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
"k8s.io/klog/v2" "k8s.io/klog/v2/ktesting" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) var ( pollPeriod = time.Millisecond minimalNoChange = 20 * time.Millisecond pollTimeout = 5 * time.Second ) func TestConditionalProgressRequester(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx) clock := testingclock.NewFakeClock(time.Now())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/SuiteTestClassProcessor.java
Clock clock) { this.suiteDescriptor = suiteDescriptor; this.processor = processor; this.clock = clock; } @Override public void startProcessing(TestResultProcessor testResultProcessor) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/processors/TestMainAction.java
this.detector = detector; this.processor = processor; this.resultProcessor = new AttachParentTestResultProcessor(resultProcessor); this.workerLeaseService = workerLeaseService; this.clock = clock; this.rootTestSuiteId = rootTestSuiteId;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/time/src/test/groovy/org/gradle/internal/time/MonotonicClockTest.groovy
1 * nanoTime() >> START_NANOS } private Clock clock = new MonotonicClock(timeSource, SYNC_INTERVAL) def "prevents time from going backwards"() { when: setNanos 0 then: clock.currentTime == START_MILLIS + 0 when: setNanos 10 then: clock.currentTime == START_MILLIS + 10 when: setNanos 8
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 2.8K bytes - Viewed (0) -
platforms/core-runtime/build-profile/src/main/java/org/gradle/profile/ProfileCoordinator.java
import org.gradle.internal.time.Clock; @ServiceScope(Scope.BuildTree.class) public class ProfileCoordinator implements RootBuildLifecycleListener { private final BuildProfile profile; private final ReportGeneratingProfileListener generator; private final Clock clock; public ProfileCoordinator(BuildProfile profile, ReportGeneratingProfileListener generator, Clock clock) { this.profile = profile;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.5K bytes - Viewed (0)