- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 492 for CLOCK (0.03 sec)
-
platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/DevelocityPluginBuildStateIntegrationTest.groovy
assert buildState.buildStartedTime == services.get(${BuildStartedTime.name}).startTime def clock = services.get(${Clock.name}) def timeDifference = Math.abs(buildState.currentTime - clock.currentTime) assert timeDifference < 1000
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 10:49:16 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/controller/job/backoff_utils.go
return &finishTime } return nil } func (backoff backoffRecord) getRemainingTime(clock clock.WithTicker, defaultBackoff time.Duration, maxBackoff time.Duration) time.Duration { return getRemainingTimeForFailuresCount(clock, defaultBackoff, maxBackoff, backoff.failuresAfterLastSuccess, backoff.lastFailureTime) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/testng/TestNGTestResultProcessorAdapter.java
public TestNGTestResultProcessorAdapter(TestResultProcessor resultProcessor, IdGenerator<?> idGenerator, Clock clock) { this.resultProcessor = resultProcessor; this.idGenerator = idGenerator; this.clock = clock; } @Override public void onStart(ISuite suite) { TestDescriptorInternal testInternal; synchronized (lock) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager.go
type objectStore struct { getObject GetObjectFunc clock clock.Clock lock sync.Mutex items map[objectKey]*objectStoreItem defaultTTL time.Duration getTTL GetObjectTTLFunc } // NewObjectStore returns a new ttl-based instance of Store interface. func NewObjectStore(getObject GetObjectFunc, clock clock.Clock, getTTL GetObjectTTLFunc, ttl time.Duration) Store { return &objectStore{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 8.3K bytes - Viewed (0) -
plugin/pkg/admission/eventratelimit/admission.go
func newEventRateLimit(config *eventratelimitapi.Configuration, clock flowcontrol.Clock) (*Plugin, error) { limitEnforcers := make([]*limitEnforcer, 0, len(config.Limits)) for _, limitConfig := range config.Limits { enforcer, err := newLimitEnforcer(limitConfig, clock) if err != nil { return nil, err } limitEnforcers = append(limitEnforcers, enforcer) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 14 15:26:57 UTC 2021 - 3.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
groupResource schema.GroupResource, clock clock.Clock, maxIdleTime time.Duration, stopCh <-chan struct{}) Store { if maxIdleTime < minIdleTime { maxIdleTime = minIdleTime } store := &objectCache{ listObject: listObject, watchObject: watchObject, newObject: newObject, isImmutable: isImmutable, groupResource: groupResource, clock: clock, maxIdleTime: maxIdleTime,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/WorkerTestClassProcessorFactory.java
import org.gradle.internal.actor.ActorFactory; import org.gradle.internal.id.IdGenerator; import org.gradle.internal.time.Clock; public interface WorkerTestClassProcessorFactory { TestClassProcessor create(IdGenerator<?> idGenerator, ActorFactory actorFactory, Clock clock);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 947 bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/slf4j/OutputEventListenerBackedLoggerContext.java
private final AtomicReference<OutputEventListener> outputEventListener = new AtomicReference<OutputEventListener>(); private final Clock clock; public OutputEventListenerBackedLoggerContext(Clock clock) { this.clock = clock; applyDefaultLoggersConfig(); reset(); } private void applyDefaultLoggersConfig() { addNoOpLogger("java.lang.ProcessBuilder");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/cache.go
"unsafe" utilcache "k8s.io/apimachinery/pkg/util/cache" "k8s.io/apiserver/pkg/storage/value" "k8s.io/utils/clock" ) type simpleCache struct { cache *utilcache.Expiring ttl time.Duration } func newSimpleCache(clock clock.Clock, ttl time.Duration) *simpleCache { cache := utilcache.NewExpiringWithClock(clock) // "Stale" entries are always valid for us because the TTL is just used to prevent
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cache_test.go
"testing" "time" "github.com/google/uuid" "k8s.io/apiserver/pkg/authentication/authenticator" "k8s.io/apiserver/pkg/authentication/user" "k8s.io/utils/clock" ) func TestSimpleCache(t *testing.T) { testCache(newSimpleCache(clock.RealClock{}), t) } // Note: the performance profile of this benchmark may not match that in the production.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 3.1K bytes - Viewed (0)