- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 492 for CLOCK (0.03 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/integrator.go
} type integrator struct { name string clock clock.PassiveClock sync.Mutex lastTime time.Time x float64 moments Moments min, max float64 } // NewNamedIntegrator makes one that uses the given clock and name func NewNamedIntegrator(clock clock.PassiveClock, name string) Integrator { return &integrator{ name: name, clock: clock, lastTime: clock.Now(), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 17:37:20 UTC 2022 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring.go
"sync" "time" "k8s.io/utils/clock" ) // NewExpiring returns an initialized expiring cache. func NewExpiring() *Expiring { return NewExpiringWithClock(clock.RealClock{}) } // NewExpiringWithClock is like NewExpiring but allows passing in a custom // clock for testing. func NewExpiringWithClock(clock clock.Clock) *Expiring { return &Expiring{ clock: clock, cache: make(map[interface{}]entry), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/queue/metrics.go
depth monitoring.Metric latency monitoring.Metric workDuration monitoring.Metric id string clock clock.WithTicker } // Gets the time since the specified start in seconds. func (m *queueMetrics) sinceInSeconds(start time.Time) float64 { return m.clock.Since(start).Seconds() } func newQueueMetrics(id string) *queueMetrics { return &queueMetrics{ id: id,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
return newProxierHealthServer(stdNetListener{}, stdHTTPServerFactory{}, clock.RealClock{}, addr, healthTimeout) } func newProxierHealthServer(listener listener, httpServerFactory httpServerFactory, c clock.Clock, addr string, healthTimeout time.Duration) *ProxierHealthServer { return &ProxierHealthServer{ listener: listener, httpFactory: httpServerFactory, clock: c, addr: addr, healthTimeout: healthTimeout,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 12 18:41:53 UTC 2022 - 5.3K bytes - Viewed (0) -
pkg/controller/tainteviction/timed_workers.go
clock clock.WithDelayedExecution } // CreateWorkerQueue creates a new TimedWorkerQueue for workers that will execute // given function `f`. func CreateWorkerQueue(f func(ctx context.Context, fireAt time.Time, args *WorkArgs) error) *TimedWorkerQueue { return &TimedWorkerQueue{ workers: make(map[string]*TimedWorker), workFunc: f, clock: clock.RealClock{}, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 4.8K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/fixture/AbstractCrossBuildPerformanceTestRunner.groovy
final IntegrationTestBuildContext buildContext final GradleDistribution gradleDistribution final BuildExperimentRunner experimentRunner final Clock clock = Time.clock() String testClassName String testId String testGroup String testProject List<BuildExperimentSpec> specs = [] boolean measureGarbageCollection = true
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 25 14:54:56 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cache_simple.go
*/ package cache import ( "time" utilcache "k8s.io/apimachinery/pkg/util/cache" "k8s.io/utils/clock" ) type simpleCache struct { cache *utilcache.Expiring } func newSimpleCache(clock clock.Clock) cache { return &simpleCache{cache: utilcache.NewExpiringWithClock(clock)} } func (c *simpleCache) get(key string) (*cacheRecord, bool) { record, ok := c.cache.Get(key) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 1.2K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/operations/TestListenerBuildOperationAdapterTest.groovy
import org.gradle.internal.operations.BuildOperationListener import org.gradle.internal.time.Clock import spock.lang.Specification class TestListenerBuildOperationAdapterTest extends Specification { public static final int TEST_START_TIMESTAMP = 200 BuildOperationListener listener = Mock() Clock clock = Mock() BuildOperationIdFactory buildOperationIdFactory = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/DaemonInfo.java
private final byte[] token; private final Clock clock; private State state; private long lastBusy; public DaemonInfo(Address address, DaemonContext context, byte[] token, State state) { this(address, context, token, state, Time.clock()); } @VisibleForTesting DaemonInfo(Address address, DaemonContext context, byte[] token, State state, Clock busyClock) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0)