- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 492 for CLOCK (0.03 sec)
-
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/Clock.java
import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; /** * A device for obtaining the current time. * * @see Time#clock() */ @ServiceScope(Scope.Global.class) public interface Clock { /** * The current time in millis. */ long getCurrentTime();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 974 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/metrics/metrics.go
legacyregistry.MustRegister(failures) return &DialMetrics{starts: starts, latencies: latencies, failures: failures, clock: clock.RealClock{}} } // Clock returns the clock. func (m *DialMetrics) Clock() clock.Clock { return m.clock } // SetClock sets the clock. func (m *DialMetrics) SetClock(c clock.Clock) { m.clock = c } // Reset resets the metrics. func (m *DialMetrics) Reset() { m.starts.Reset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 01 23:36:51 UTC 2022 - 4.3K bytes - Viewed (0) -
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/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) -
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) -
subprojects/core/src/main/java/org/gradle/internal/buildevents/BuildResultLogger.java
private final DurationFormatter durationFormatter; private final WorkValidationWarningReporter workValidationWarningReporter; private final Clock clock; public BuildResultLogger( StyledTextOutputFactory textOutputFactory, BuildStartedTime buildStartedTime, Clock clock, DurationFormatter durationFormatter, WorkValidationWarningReporter workValidationWarningReporter ) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 08 10:17:53 UTC 2020 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_received_time.go
"net/http" "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/utils/clock" ) // WithRequestReceivedTimestamp attaches the ReceivedTimestamp (the time the request reached // the apiserver) to the context. func WithRequestReceivedTimestamp(handler http.Handler) http.Handler { return withRequestReceivedTimestampWithClock(handler, clock.RealClock{}) } // The clock is passed as a parameter, handy for unit testing.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 1.3K bytes - Viewed (0)