Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AddIndexers (0.54 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    					return
    				}
    			}
    			nc.podUpdated(pod, nil)
    		},
    	})
    	nc.podInformerSynced = podInformer.Informer().HasSynced
    	podInformer.Informer().AddIndexers(cache.Indexers{
    		nodeNameKeyIndex: func(obj interface{}) ([]string, error) {
    			pod, ok := obj.(*v1.Pod)
    			if !ok {
    				return []string{}, nil
    			}
    			if len(pod.Spec.NodeName) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top