- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 99 for lobster (0.13 sec)
-
pkg/controller/volume/persistentvolume/framework_test.go
continue } ctrl.volumes.store.Add(volume) } reactor.AddClaims(test.initialClaims) reactor.AddVolumes(test.initialVolumes) // Inject classes into controller via a custom lister. indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{}) for _, class := range storageClasses { indexer.Add(class) } ctrl.classLister = storagelisters.NewStorageClassLister(indexer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
} public void testInitialCapacity_large() { CacheBuilder.newBuilder().initialCapacity(Integer.MAX_VALUE); // that the builder didn't blow up is enough; // don't actually create this monster! } public void testConcurrencyLevel_zero() { CacheBuilder<Object, Object> builder = CacheBuilder.newBuilder(); try { builder.concurrencyLevel(0); fail();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Oct 03 20:10:02 UTC 2023 - 23.2K bytes - Viewed (0) -
src/regexp/find_test.go
func TestFindReaderSubmatchIndex(t *testing.T) { for _, test := range findTests { testFindSubmatchIndex(&test, MustCompile(test.pat).FindReaderSubmatchIndex(strings.NewReader(test.text)), t) } } // Now come the monster AllSubmatch cases. func TestFindAllSubmatch(t *testing.T) { for _, test := range findTests { result := MustCompile(test.pat).FindAllSubmatch([]byte(test.text), -1) switch {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 11 15:28:50 UTC 2021 - 16.3K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
if controllerRef == nil { return []string{}, nil } return []string{string(controllerRef.UID)}, nil }, }) rsc.rsIndexer = rsInformer.Informer().GetIndexer() rsc.rsLister = rsInformer.Lister() rsc.rsListerSynced = rsInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rsc.addPod(logger, obj) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission.go
func (s *Plugin) SetExternalKubeInformerFactory(f informers.SharedInformerFactory) { serviceAccountInformer := f.Core().V1().ServiceAccounts() s.serviceAccountLister = serviceAccountInformer.Lister() s.SetReadyFunc(func() bool { return serviceAccountInformer.Informer().HasSynced() }) } // ValidateInitialization ensures an authorizer is set. func (s *Plugin) ValidateInitialization() error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 18.6K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
workqueue.TypedRateLimitingQueueConfig[secretQueueKey]{Name: "serviceaccount_tokens_service"}, ), maxRetries: maxRetries, } e.serviceAccounts = serviceAccounts.Lister() e.serviceAccountSynced = serviceAccounts.Informer().HasSynced serviceAccounts.Informer().AddEventHandlerWithResyncPeriod( cache.ResourceEventHandlerFuncs{ AddFunc: e.queueServiceAccountSync,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator.go
lastAddress: ipLast, rangeOffset: rangeOffset, offsetAddress: offsetAddress, size: size, family: family, client: client, ipAddressLister: ipAddressInformer.Lister(), ipAddressSynced: ipAddressInformer.Informer().HasSynced, metrics: &emptyMetricsRecorder{}, // disabled by default metricLabel: cidr.String(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
fci := config.InformerFactory.Flowcontrol().V1() pli := fci.PriorityLevelConfigurations() fsi := fci.FlowSchemas() cfgCtlr.plLister = pli.Lister() cfgCtlr.plInformerSynced = pli.Informer().HasSynced cfgCtlr.fsLister = fsi.Lister() cfgCtlr.fsInformerSynced = fsi.Informer().HasSynced pli.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/cost.go
case types.String: return uint64(float64(len(string(vt))) * common.StringTraversalCostFactor) case types.Bytes: return uint64(float64(len([]byte(vt))) * common.StringTraversalCostFactor) case traits.Lister: cost := uint64(0) for it := vt.Iterator(); it.HasNext() == types.True; { i := it.Next() cost += traversalCost(i) } return cost case traits.Mapper: // maps and objects cost := uint64(0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 17:22:44 UTC 2024 - 20.6K bytes - Viewed (0)