- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for NewIndexer (0.19 sec)
-
pkg/controller/statefulset/stateful_pod_control_test.go
pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} podIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) gooPod := newStatefulSetPod(set, 0) gooPod.Name = "goo-0" podIndexer.Add(gooPod) podLister := corelisters.NewPodLister(podIndexer) claimIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater_test.go
} func TestStatefulSetStatusUpdaterUpdateReplicasFailure(t *testing.T) { set := newStatefulSet(3) status := apps.StatefulSetStatus{ObservedGeneration: 3, Replicas: 2} fakeClient := &fake.Clientset{} indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) indexer.Add(set) setLister := appslisters.NewStatefulSetLister(indexer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 13 15:37:10 UTC 2022 - 5.9K bytes - Viewed (0) -
pkg/serviceaccount/jwt_test.go
getter := serviceaccountcontroller.NewGetterFromClient( tc.Client, v1listers.NewSecretLister(newIndexer(func(namespace, name string) (interface{}, error) { return tc.Client.CoreV1().Secrets(namespace).Get(context.TODO(), name, metav1.GetOptions{}) })), v1listers.NewServiceAccountLister(newIndexer(func(namespace, name string) (interface{}, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 22:16:08 UTC 2024 - 17K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller_test.go
expectedRemoved: []string{"v2.group.com"}, }, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { registration := &fakeAPIServiceRegistration{} crdCache := cache.NewIndexer(cache.DeletionHandlingMetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) crdLister := crdlisters.NewCustomResourceDefinitionLister(crdCache) c := crdRegistrationController{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 02 17:48:26 UTC 2020 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller_test.go
} return c }(), expectErr: true, }, } for _, scenario := range scenarios { t.Run(scenario.name, func(t *testing.T) { // test data indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{}) if err := indexer.Add(scenario.cm); err != nil { t.Fatal(err.Error()) } target := newDefaultTarget()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy_test.go
services: nil, endpoints: nil, clusterMode: expectation{error: true}, endpointMode: expectation{error: true}, }, } for _, test := range tests { serviceCache := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) serviceLister := v1listers.NewServiceLister(serviceCache) for i := range test.services {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:16:27 UTC 2023 - 8.6K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission_test.go
}, }, }, } existingNodesIndex = cache.NewIndexer(cache.MetaNamespaceKeyFunc, nil) existingNodes = corev1lister.NewNodeLister(existingNodesIndex) noExistingPodsIndex = cache.NewIndexer(cache.MetaNamespaceKeyFunc, nil) noExistingPods = corev1lister.NewPodLister(noExistingPodsIndex) existingPodsIndex = cache.NewIndexer(cache.MetaNamespaceKeyFunc, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 73.2K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller_test.go
patch: "{\"metadata\":{\"annotations\":{\"node.alpha.kubernetes.io/ttl\":\"30\"}}}", }, } for i, testCase := range testCases { fakeClient := &fake.Clientset{} nodeStore := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{}) nodeStore.Add(testCase.node) ttlController := &Controller{ kubeClient: fakeClient, nodeStore: listers.NewNodeLister(nodeStore),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/flowschema_test.go
}, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { client := fake.NewSimpleClientset().FlowcontrolV1().FlowSchemas() indexer := toolscache.NewIndexer(toolscache.MetaNamespaceKeyFunc, toolscache.Indexers{}) if test.current != nil { client.Create(context.TODO(), test.current, metav1.CreateOptions{}) indexer.Add(test.current) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/index.go
type persistentVolumeOrderedIndex struct { store cache.Indexer } func newPersistentVolumeOrderedIndex() persistentVolumeOrderedIndex { return persistentVolumeOrderedIndex{cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{"accessmodes": accessModesIndexFunc})} } // accessModesIndexFunc is an indexing function that returns a persistent // volume's AccessModes as a string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 6.5K bytes - Viewed (0)