- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 568 for podIps (0.49 sec)
-
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/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
for _, group := range groups { // If there are no pods in a particular range, // then do not wait for pods in that priority range. if len(group.Pods) == 0 { continue } var wg sync.WaitGroup wg.Add(len(group.Pods)) for _, pod := range group.Pods { go func(pod *v1.Pod, group podShutdownGroup) { defer wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage.go
err = storeerr.InterpretGetError(err, api.Resource("pods"), podID) err = storeerr.InterpretUpdateError(err, api.Resource("pods"), podID) if _, ok := err.(*errors.StatusError); !ok { err = errors.NewConflict(api.Resource("pods/binding"), podID, err) } } return } var _ = rest.Creater(&LegacyBindingREST{}) // LegacyBindingREST implements the REST endpoint for binding pods to nodes when etcd is in use.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 20 14:29:25 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/kubelet/lifecycle/predicate.go
return true } return false } // rejectPodAdmissionBasedOnOSField rejects pods if their OS field doesn't match runtime.GOOS. // TODO: Relax this restriction when we start supporting LCOW in kubernetes where podOS may not match // node's OS. func rejectPodAdmissionBasedOnOSField(pod *v1.Pod) bool { if pod.Spec.OS == nil { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 00:47:50 UTC 2023 - 10.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/example/v1/zz_generated.conversion.go
out.Phase = example.PodPhase(in.Phase) out.Conditions = *(*[]example.PodCondition)(unsafe.Pointer(&in.Conditions)) out.Message = in.Message out.Reason = in.Reason out.HostIP = in.HostIP out.PodIP = in.PodIP out.StartTime = (*metav1.Time)(unsafe.Pointer(in.StartTime)) return nil } // Convert_v1_PodStatus_To_example_PodStatus is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 10.6K 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) -
CHANGELOG/CHANGELOG-1.2.md
Jobs (instead of Pods) by default. * Pods can now consume Secret data in environment variables and inject those environment variables into a container’s command-line args. * Stable version of Heapster which scales up to 1000 nodes: more metrics, reduced latency, reduced cpu/memory consumption (~4mb per monitored node). * Pods now have a security context which allows users to specify:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 04 06:36:19 UTC 2020 - 41.4K bytes - Viewed (0) -
pkg/kubelet/stats/helper.go
} logStats, err := hostStatsProvider.getPodLogStats(podNs, podName, podUID, rootFsInfo) if err != nil { klog.V(6).ErrorS(err, "Unable to fetch pod log stats", "pod", klog.KRef(podNs, podName)) // If people do in-place upgrade, there might be pods still using // the old log path. For those pods, no pod log stats is returned. // We should continue generating other stats in that case.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 23:40:02 UTC 2023 - 14.8K 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)