Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for DeletionHandlingMetaNamespaceKeyFunc (0.7 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    				klog.V(7).Infof("No trigger API priority and fairness config reloading in %s due to spec non-change of PLC %s", cfgCtlr.name, newPL.Name)
    			}
    		},
    		DeleteFunc: func(obj interface{}) {
    			name, _ := cache.DeletionHandlingMetaNamespaceKeyFunc(obj)
    			klog.V(7).Infof("Triggered API priority and fairness config reloading in %s due to deletion of PLC %s", cfgCtlr.name, name)
    			cfgCtlr.configQueue.Add(0)
    
    		}})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  2. pkg/controller/volume/persistentvolume/pv_controller_base.go

    	controller := &PersistentVolumeController{
    		volumes:                       newPersistentVolumeOrderedIndex(),
    		claims:                        cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc),
    		kubeClient:                    p.KubeClient,
    		eventBroadcaster:              eventBroadcaster,
    		eventRecorder:                 eventRecorder,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	}
    
    	adc.processVolumesInUse(logger, nodeName, node.Status.VolumesInUse)
    }
    
    func (adc *attachDetachController) enqueuePVC(obj interface{}) {
    	key, err := kcache.DeletionHandlingMetaNamespaceKeyFunc(obj)
    	if err != nil {
    		runtime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err))
    		return
    	}
    	adc.pvcQueue.Add(key)
    }
    
    // pvcWorker processes items from pvcQueue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  4. pkg/controller/controller_utils.go

    	Jitter:   1.0,
    }
    
    var UpdateLabelBackoff = wait.Backoff{
    	Steps:    5,
    	Duration: 100 * time.Millisecond,
    	Jitter:   1.0,
    }
    
    var (
    	KeyFunc           = cache.DeletionHandlingMetaNamespaceKeyFunc
    	podPhaseToOrdinal = map[v1.PodPhase]int{v1.PodPending: 0, v1.PodUnknown: 1, v1.PodRunning: 2}
    )
    
    type ResyncPeriodFunc func() time.Duration
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  5. pkg/controller/endpoint/endpoints_controller_test.go

    					ClusterIP: "3000::1",
    				},
    			},
    			expectError: true,
    		},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			podStore := cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc)
    			ns := "test"
    			addPods(podStore, ns, 1, 1, 0, tc.ipFamilies)
    			pods := podStore.List()
    			if len(pods) != 1 {
    				t.Fatalf("podStore size: expected: %d, got: %d", 1, len(pods))
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  6. pkg/controller/daemon/daemon_controller_test.go

    	}
    
    	fakeRecorder := record.NewFakeRecorder(100)
    	dsc.eventRecorder = fakeRecorder
    
    	fakePodControl := newFakePodControl()
    	fakePodControl.podStore = cache.NewStore(cache.DeletionHandlingMetaNamespaceKeyFunc) // fake store that we don't use
    	fakePodControl.expectations = controller.NewControllerExpectations()                 // fake expectations that we don't use
    	dsc.podControl = fakePodControl
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
Back to top