- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 336 for podIps (0.23 sec)
-
pkg/controller/statefulset/stateful_pod_control.go
_, err := om.client.CoreV1().Pods(pod.Namespace).Create(ctx, pod, metav1.CreateOptions{}) return err } func (om *realStatefulPodControlObjectManager) GetPod(namespace, podName string) (*v1.Pod, error) { return om.podLister.Pods(namespace).Get(podName) } func (om *realStatefulPodControlObjectManager) UpdatePod(pod *v1.Pod) error {
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/scheduler/framework/interface.go
// and Pods rejected by these plugins are requeued based on this extension point. // Failures from other extension points are regarded as temporal errors (e.g., network failure), // and the scheduler requeue Pods without this extension point - always requeue Pods to activeQ after backoff. // This is because such temporal errors cannot be resolved by specific cluster events,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
patchBytes := fmt.Sprintf(`{"metadata":{"labels":{%q:%q}}}`, c.cfg.LabelKey, c.cfg.LabelValue) // Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead. _, err := c.client.Kube().CoreV1().Pods(pod.Namespace).Patch(context.Background(), pod.Name, types.MergePatchType, []byte(patchBytes), metav1.PatchOptions{}, "status") if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
// Overall node information. node *v1.Node // Pods running on the node. Pods []*PodInfo // The subset of pods with affinity. PodsWithAffinity []*PodInfo // The subset of pods with required anti-affinity. PodsWithRequiredAntiAffinity []*PodInfo // Ports allocated on the node. UsedPorts HostPortInfo // Total requested resources of all pods on this node. This includes assumed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
nodeInfoCopy := potentialNodes[(int(offset)+i)%len(potentialNodes)].Snapshot() stateCopy := ev.State.Clone() pods, numPDBViolations, status := ev.SelectVictimsOnNode(ctx, stateCopy, pod, nodeInfoCopy, pdbs) if status.IsSuccess() && len(pods) != 0 { victims := extenderv1.Victims{ Pods: pods, NumPDBViolations: int64(numPDBViolations), } c := &candidate{ victims: &victims,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
// Such as the pod have initContainer which is initialing. // See https://github.com/istio/istio/issues/48854 if (!IsPodRunning(p) && !IsPodPending(p)) || p.Spec.HostNetwork { return nil } podIP, err := netip.ParseAddr(p.Status.PodIP) if err != nil { // Is this possible? Probably not in typical case, but anyone could put garbage there. return nil } meshCfg := krt.FetchOne(ctx, MeshConfig.AsCollection())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
// statefulPodRegex is a regular expression that extracts the parent StatefulSet and ordinal from the Name of a Pod var statefulPodRegex = regexp.MustCompile("(.*)-([0-9]+)$") // getParentNameAndOrdinal gets the name of pod's parent StatefulSet and pod's ordinal as extracted from its Name. If // the Pod was not created by a StatefulSet, its parent is considered to be empty string, and its ordinal is considered // to be -1.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
return nil } // list all pods to include the pods that don't match the rs`s selector // anymore but has the stale controller ref. // TODO: Do the List and Filter in a single pass, or use an index. allPods, err := rsc.podLister.Pods(rs.Namespace).List(labels.Everything()) if err != nil { return err } // Ignore inactive pods. filteredPods := controller.FilterActivePods(logger, allPods)
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/kubelet/volumemanager/reconciler/reconstruct_common.go
// Find filesystem volume information // ex. filesystem volume: /pods/{podUid}/volumes/{escapeQualifiedPluginName}/{volumeName} volumesDirs := map[v1.PersistentVolumeMode]string{ v1.PersistentVolumeFilesystem: filepath.Join(podDir, config.DefaultKubeletVolumesDirName), } // Find block volume information // ex. block volume: /pods/{podUid}/volumeDevices/{escapeQualifiedPluginName}/{volumeName}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission_test.go
} // if the update of initialized pod is not ignored, an error will be returned because the pod's Tolerations conflicts with namespace's Tolerations. err = admissiontesting.WithReinvocationTesting(t, handler).Admit(context.TODO(), admission.NewAttributesRecord(pod, pod, api.Kind("Pod").WithVersion("version"), "testNamespace", pod.ObjectMeta.Name, api.Resource("pods").WithVersion("version"), "", admission.Update, &metav1.CreateOptions{}, false, nil), nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16K bytes - Viewed (0)