- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for AddIndexers (0.54 sec)
-
pkg/controller/volume/common/common.go
func AddIndexerIfNotPresent(indexer cache.Indexer, indexName string, indexFunc cache.IndexFunc) error { indexers := indexer.GetIndexers() if _, ok := indexers[indexName]; ok { return nil } return indexer.AddIndexers(cache.Indexers{indexName: indexFunc})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 11 18:54:20 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
"AddIndexer": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) { podInformer := handle.SharedInformerFactory().Core().V1().Pods() err := podInformer.Informer().AddIndexers(cache.Indexers{ "nodeName": indexByPodSpecNodeName, }) return &TestPlugin{name: "AddIndexer"}, err }, }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
DeleteFunc: func(obj interface{}) { logger.V(6).Info("deleted claim", "claimDump", obj) ec.enqueueResourceClaim(logger, obj, true) }, }); err != nil { return nil, err } if err := ec.podIndexer.AddIndexers(cache.Indexers{podResourceClaimIndex: podResourceClaimIndexFunc}); err != nil { return nil, fmt.Errorf("could not initialize ResourceClaim controller: %w", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
}, UpdateFunc: func(oldObj, newObj interface{}) { rsc.updateRS(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { rsc.deleteRS(logger, obj) }, }) rsInformer.Informer().AddIndexers(cache.Indexers{ controllerUIDIndex: func(obj interface{}) ([]string, error) { rs, ok := obj.(*apps.ReplicaSet) if !ok { return []string{}, nil } controllerRef := metav1.GetControllerOf(rs)
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/scheduler/framework/plugins/dynamicresources/dynamicresources.go
} if err := pl.claimParametersIndexer.AddIndexers(cache.Indexers{generatedFromIndex: claimParametersGeneratedFromIndexFunc}); err != nil { return nil, fmt.Errorf("add claim parameters cache indexer: %w", err) } if err := pl.classParametersIndexer.AddIndexers(cache.Indexers{generatedFromIndex: classParametersGeneratedFromIndexFunc}); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0)