- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for lobster (0.21 sec)
-
pkg/controller/podautoscaler/horizontal.go
UpdateFunc: hpaController.updateHPA, DeleteFunc: hpaController.deleteHPA, }, resyncPeriod, ) hpaController.hpaLister = hpaInformer.Lister() hpaController.hpaListerSynced = hpaInformer.Informer().HasSynced hpaController.podLister = podInformer.Lister() hpaController.podListerSynced = podInformer.Informer().HasSynced replicaCalc := NewReplicaCalculator( metricsClient, hpaController.podLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
src/cmd/compile/internal/types2/api_test.go
// Verify the invariant that re-instantiating the corresponding generic // type with TypeArgs results in an identical instance. ptype := useMap[inst.Name].Type() lister, _ := ptype.(interface{ TypeParams() *TypeParamList }) if lister == nil || lister.TypeParams().Len() == 0 { t.Fatalf("info.Types[%v] = %v, want parameterized type", inst.Name, ptype) } inst2, err := Instantiate(nil, ptype, targs, true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 93.3K bytes - Viewed (0) -
src/go/types/api_test.go
// Verify the invariant that re-instantiating the corresponding generic // type with TypeArgs results in an identical instance. ptype := useMap[inst.Ident].Type() lister, _ := ptype.(interface{ TypeParams() *TypeParamList }) if lister == nil || lister.TypeParams().Len() == 0 { t.Fatalf("info.Types[%v] = %v, want parameterized type", inst.Ident, ptype) } inst2, err := Instantiate(nil, ptype, targs, true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 94.2K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
}, DeleteFunc: func(obj interface{}) { jm.deleteJob(logger, obj) }, }); err != nil { return nil, fmt.Errorf("adding Job event handler: %w", err) } jm.jobLister = jobInformer.Lister() jm.jobStoreSynced = jobInformer.Informer().HasSynced if _, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.addPod(logger, obj) },
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/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
ret := &crdHandler{ versionDiscoveryHandler: versionDiscoveryHandler, groupDiscoveryHandler: groupDiscoveryHandler, customStorage: atomic.Value{}, crdLister: crdInformer.Lister(), delegate: delegate, restOptionsGetter: restOptionsGetter, admission: admission, establishingController: establishingController, masterCount: masterCount,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
pkg/controller/podautoscaler/replica_calculator_test.go
informerFactory := informers.NewSharedInformerFactory(testClient, controller.NoResyncPeriodFunc()) informer := informerFactory.Core().V1().Pods() replicaCalc := NewReplicaCalculator(metricsClient, informer.Lister(), defaultTestingTolerance, defaultTestingCPUInitializationPeriod, defaultTestingDelayOfInitialReadinessStatus) stop := make(chan struct{}) defer close(stop) informerFactory.Start(stop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 68.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
return e.NewFunc() } // Destroy cleans up its resources on shutdown. func (e *Store) Destroy() { if e.DestroyFunc != nil { e.DestroyFunc() } } // NewList implements rest.Lister. func (e *Store) NewList() runtime.Object { return e.NewListFunc() } // NamespaceScoped indicates whether the resource is namespaced func (e *Store) NamespaceScoped() bool { if e.CreateStrategy != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
now := metav1.Now() rs.DeletionTimestamp = &now stopCh := make(chan struct{}) defer close(stopCh) manager, fakePodControl, informers := setupManagerWithGCEnabled(t, stopCh, rs) // Lister (cache) says it's NOT deleted. rs2 := *rs rs2.DeletionTimestamp = nil informers.Apps().V1().ReplicaSets().Informer().GetIndexer().Add(&rs2) // Recheck occurs if a matching orphan is present.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)