- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 904 for updatePod (0.87 sec)
-
plugin/pkg/auth/authorizer/node/graph_populator.go
} func (g *graphPopulator) addPod(obj interface{}) { g.updatePod(nil, obj) } func (g *graphPopulator) updatePod(oldObj, obj interface{}) { pod := obj.(*corev1.Pod) if len(pod.Spec.NodeName) == 0 { // No node assigned klog.V(5).Infof("updatePod %s/%s, no node", pod.Namespace, pod.Name) return } if oldPod, ok := oldObj.(*corev1.Pod); ok && oldPod != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go
tc.startingPod.APIVersion = examplev1.SchemeGroupVersion.String() // pod with rv=3 is found when attempting to persist the update tc.updatePod.Name = name tc.updatePod.Namespace = namespace tc.updatePod.UID = uid tc.updatePod.ResourceVersion = "3" tc.updatePod.APIVersion = examplev1.SchemeGroupVersion.String() // patches are submitted with a rv=2
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
holds map[types.UID]chan struct{} } // UpdatePod increments the clock after UpdatePod is called, but before the workers // are invoked, and then drains all workers before returning. The provided functions // are invoked while holding the lock to prevent workers from receiving updates. func (w *timeIncrementingWorkers) UpdatePod(options UpdatePodOptions, afterFns ...func()) { func() { w.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/pod/testing/mock_manager.go
} // UpdatePod mocks base method. func (m *MockManager) UpdatePod(pod *v1.Pod) { m.ctrl.T.Helper() m.ctrl.Call(m, "UpdatePod", pod) } // UpdatePod indicates an expected call of UpdatePod. func (mr *MockManagerMockRecorder) UpdatePod(pod any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdatePod", reflect.TypeOf((*MockManager)(nil).UpdatePod), pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
// SetPods replaces the internal pods with the new pods. // It is currently only used for testing. SetPods(pods []*v1.Pod) // AddPod adds the given pod to the manager. AddPod(pod *v1.Pod) // UpdatePod updates the given pod in the manager. UpdatePod(pod *v1.Pod) // RemovePod deletes the given pod from the manager. For mirror pods, // this means deleting the mappings related to mirror pods. For non-
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
t.Fatalf("failed to marshal original pod %s: %v", pod.Name, err) } updated, err := strategicpatch.StrategicMergePatch(original, patch, v1.Pod{}) if err != nil { t.Fatalf("failed to apply strategic merge patch %q on node %s: %v", patch, pod.Name, err) } if err := json.Unmarshal(updated, pod); err != nil { t.Fatalf("failed to unmarshal updated pod %s: %v", pod.Name, err) } return true, pod, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// // The podWorkerLoop is driven by updates delivered to UpdatePod and by SyncKnownPods. If a particular // sync method fails, p.workerQueue is updated with backoff but it is the responsibility of the kubelet // to trigger new UpdatePod calls. SyncKnownPods will only retry pods that are no longer known to the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
updateErr := spc.objectMgr.UpdatePod(pod) if updateErr == nil { return nil } if updated, err := spc.objectMgr.GetPod(set.Namespace, pod.Name); err == nil { // make a copy so we don't mutate the shared cache pod = updated.DeepCopy() } else { utilruntime.HandleError(fmt.Errorf("error getting updated Pod %s/%s: %w", set.Namespace, pod.Name, err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
for _, set := range sets { ssc.enqueueStatefulSet(set) } } // updatePod adds the statefulset for the current and old pods to the sync queue. func (ssc *StatefulSetController) updatePod(logger klog.Logger, old, cur interface{}) { curPod := cur.(*v1.Pod) oldPod := old.(*v1.Pod) if curPod.ResourceVersion == oldPod.ResourceVersion {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
} } func (dc *DisruptionController) updatePod(logger klog.Logger, _, cur interface{}) { pod := cur.(*v1.Pod) logger.V(4).Info("UpdatePod called on pod", "pod", klog.KObj(pod)) pdb := dc.getPdbForPod(logger, pod) if pdb == nil { logger.V(4).Info("No matching PDB for pod", "pod", klog.KObj(pod)) } else { logger.V(4).Info("updatePod -> PDB", "pod", klog.KObj(pod), "podDisruptionBudget", klog.KObj(pdb))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0)