- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for PodUpdate (0.17 sec)
-
pkg/kubelet/config/config_test.go
// should register an empty PodUpdate operation podUpdate := CreatePodUpdate(kubetypes.SET, TestSource) channel <- podUpdate expectPodUpdate(t, ch, CreatePodUpdate(test.op, TestSource)) // should ignore following empty sets podUpdate = CreatePodUpdate(kubetypes.SET, TestSource) channel <- podUpdate podUpdate = CreatePodUpdate(kubetypes.ADD, TestSource, CreateValidPod("foo", "new"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
} func (tc *Controller) handlePodUpdate(ctx context.Context, podUpdate podUpdateItem) { pod, err := tc.podLister.Pods(podUpdate.podNamespace).Get(podUpdate.podName) logger := klog.FromContext(ctx) if err != nil { if apierrors.IsNotFound(err) { // Delete podNamespacedName := types.NamespacedName{Namespace: podUpdate.podNamespace, Name: podUpdate.podName} logger.V(4).Info("Noticed pod deletion", "pod", podNamespacedName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/kubelet/config/config.go
} s.pods[source] = pods adds = &kubetypes.PodUpdate{Op: kubetypes.ADD, Pods: copyPods(addPods), Source: source} updates = &kubetypes.PodUpdate{Op: kubetypes.UPDATE, Pods: copyPods(updatePods), Source: source} deletes = &kubetypes.PodUpdate{Op: kubetypes.DELETE, Pods: copyPods(deletePods), Source: source} removes = &kubetypes.PodUpdate{Op: kubetypes.REMOVE, Pods: copyPods(removePods), Source: source}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/config/file_linux_test.go
} func TestUpdateOnNonExistentFile(t *testing.T) { ch := make(chan interface{}) NewSourceFile("random_non_existent_path", "localhost", time.Millisecond, ch) select { case got := <-ch: update := got.(kubetypes.PodUpdate) expected := CreatePodUpdate(kubetypes.SET, kubetypes.FileSource) if !apiequality.Semantic.DeepDerivative(expected, update) { t.Fatalf("expected %#v, Got %#v", expected, update) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 12.3K bytes - Viewed (0) -
pkg/kubelet/config/http_test.go
nodeName := "different-value" grace := int64(30) enableServiceLinks := v1.DefaultEnableServiceLinks var testCases = []struct { desc string pods runtime.Object expected kubetypes.PodUpdate }{ { desc: "Single pod", pods: &v1.Pod{ TypeMeta: metav1.TypeMeta{ Kind: "Pod", APIVersion: "", }, ObjectMeta: metav1.ObjectMeta{ Name: "foo",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 11.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
podInformer.Informer().AddEventHandler(kcache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { adc.podAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { adc.podUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { adc.podDelete(logger, obj) }, }) // This custom indexer will index pods by its PVC keys. Then we don't need
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
func (f *Fit) EventsToRegister() []framework.ClusterEventWithHint { podActionType := framework.Delete if f.enableInPlacePodVerticalScaling { // If InPlacePodVerticalScaling (KEP 1287) is enabled, then PodUpdate event should be registered // for this plugin since a Pod update may free up resources that make other Pods schedulable. podActionType |= framework.Update } return []framework.ClusterEventWithHint{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0)