- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for crBlock (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
// This handler is run at the end of every Add/Update/Delete method // and additionally gets the previous value of the object. eventHandler func(*watchCacheEvent) // for testing timeouts. clock clock.Clock // An underlying storage.Versioner. versioner storage.Versioner // cacher's group resource groupResource schema.GroupResource // For testing cache interval invalidation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
startBucketID int64 clock clock.Clock bookmarkFrequency time.Duration } func newTimeBucketWatchers(clock clock.Clock, bookmarkFrequency time.Duration) *watcherBookmarkTimeBuckets { return &watcherBookmarkTimeBuckets{ watchersBuckets: make(map[int64][]*cacheWatcher), createTime: clock.Now(), startBucketID: 0, clock: clock, bookmarkFrequency: bookmarkFrequency,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
} // Option configures a PriorityQueue type Option func(*priorityQueueOptions) // WithClock sets clock for PriorityQueue, the default clock is clock.RealClock. func WithClock(clock clock.Clock) Option { return func(o *priorityQueueOptions) { o.clock = clock } } // WithPodInitialBackoffDuration sets pod initial backoff duration for PriorityQueue.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
cmd/handler-api.go
} func (t *apiConfig) odirectEnabled() bool { t.mu.RLock() defer t.mu.RUnlock() return t.enableODirect } func (t *apiConfig) shouldGzipObjects() bool { t.mu.RLock() defer t.mu.RUnlock() return t.gzipObjects } func (t *apiConfig) permitRootAccess() bool { t.mu.RLock() defer t.mu.RUnlock() return t.rootAccess }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 08:13:12 UTC 2024 - 10.4K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/TestGlobalScopeServices.java
return loggingManagerFactory.create(); } @Provides @Override protected BuildOperationProgressEventEmitter createBuildOperationProgressEventEmitter( Clock clock, CurrentBuildOperationRef currentBuildOperationRef, BuildOperationListenerManager listenerManager ) { return new NoOpBuildOperationProgressEventEmitter(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
orphanQueue: workqueue.NewTypedRateLimitingQueueWithConfig(workqueue.NewTypedItemExponentialFailureRateLimiter[string](DefaultJobApiBackOff, MaxJobApiBackOff), workqueue.TypedRateLimitingQueueConfig[string]{Name: "job_orphan_pod", Clock: clock}), broadcaster: eventBroadcaster,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" "k8s.io/utils/pointer" ) func newTestCacherWithoutSyncing(s storage.Interface) (*Cacher, storage.Versioner, error) { prefix := "pods" config := Config{ Storage: s,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
indexerFuncs map[string]storage.IndexerFunc clock clock.WithTicker } type setupOption func(*setupOptions) func withDefaults(options *setupOptions) { prefix := "/pods" options.resourcePrefix = prefix options.keyFunc = func(obj runtime.Object) (string, error) { return storage.NamespaceKeyFunc(prefix, obj) } options.clock = clock.RealClock{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
cmd/iam-store.go
cache := store.rlock() defer store.runlock() u, ok := cache.iamUsersMap[user] if !ok { // Check the sts map u, ok = cache.iamSTSAccountsMap[user] } return u, ok } // GetMappedPolicy - fetches mapped policy from memory. func (store *IAMStoreSys) GetMappedPolicy(name string, isGroup bool) (MappedPolicy, bool) { cache := store.rlock() defer store.runlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/GlobalScopeServices.java
@Provides protected BuildOperationProgressEventEmitter createBuildOperationProgressEventEmitter( Clock clock, CurrentBuildOperationRef currentBuildOperationRef, BuildOperationListenerManager listenerManager ) { return new DefaultBuildOperationProgressEventEmitter( clock::getCurrentTime, currentBuildOperationRef, listenerManager.getBroadcaster() );
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.4K bytes - Viewed (0)