- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 336 for podIps (0.16 sec)
-
pilot/pkg/serviceregistry/kube/controller/pod.go
// just in case the proxy ID is bad formatted pods := pc.getPodsByIP(proxyIP) switch len(pods) { case 0: return nil case 1: return pods[0] default: // This should only happen with hostNetwork pods, which cannot be proxy clients... log.Errorf("unexpected: found multiple pods for proxy %v (%v)", proxy.ID, proxyIP) // Try to handle it gracefully for _, p := range pods { // At least filter out wrong namespaces...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
return fmt.Errorf("pod is missing, skipping (%s/%s)", addr.TargetRef.Namespace, addr.TargetRef.Name) } for _, podIP := range pod.Status.PodIPs { if podIP.IP == addr.IP { return nil } } return fmt.Errorf("pod ip(s) doesn't match endpoint ip, skipping: %v vs %s (%s/%s)", pod.Status.PodIPs, addr.IP, addr.TargetRef.Namespace, addr.TargetRef.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
// able to get necessary informations like the RunContainerOptions, DNS settings, Host IP. type RuntimeHelper interface { GenerateRunContainerOptions(ctx context.Context, pod *v1.Pod, container *v1.Container, podIP string, podIPs []string) (contOpts *RunContainerOptions, cleanupAction func(), err error) GetPodDNS(pod *v1.Pod) (dnsConfig *runtimeapi.DNSConfig, err error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Pod.yaml
name: nameValue readOnly: true recursiveReadOnly: recursiveReadOnlyValue message: messageValue nominatedNodeName: nominatedNodeNameValue phase: phaseValue podIP: podIPValue podIPs: - ip: ipValue qosClass: qosClassValue reason: reasonValue resize: resizeValue resourceClaimStatuses: - name: nameValue resourceClaimName: resourceClaimNameValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 33.2K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Pod.yaml
name: nameValue readOnly: true recursiveReadOnly: recursiveReadOnlyValue message: messageValue nominatedNodeName: nominatedNodeNameValue phase: phaseValue podIP: podIPValue podIPs: - ip: ipValue qosClass: qosClassValue reason: reasonValue resize: resizeValue resourceClaimStatuses: - name: nameValue resourceClaimName: resourceClaimNameValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 33.6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
if utilnet.IsIPv6String(pod.Status.PodIP) { ipFamily = v1.IPv6Protocol } } } // find an ip that matches the family for _, podIP := range pod.Status.PodIPs { if (ipFamily == v1.IPv6Protocol) == utilnet.IsIPv6String(podIP.IP) { endpointIP = podIP.IP break } } if endpointIP == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/test/framework/components/istio/kube.go
func (i *istioImpl) PodIPsFor(c cluster.Cluster, namespace string, label string) ([]corev1.PodIP, error) { // Find the pod with the specified label in the specified namespace fetchFn := testKube.NewSinglePodFetch(c, namespace, label) pods, err := testKube.WaitUntilPodsAreReady(fetchFn) if err != nil { return nil, err } pod := pods[0] return pod.Status.PodIPs, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin.go
} logger.V(5).Info("a scheduled pod was updated but it doesn't match the target pod's affinity or does match the target pod's anti-affinity", "pod", klog.KObj(pod), "modifiedPod", klog.KObj(modifiedPod)) return framework.QueueSkip, nil } // Pod is added. Return Queue when the added pod matching the target pod's affinity. if modifiedPod != nil { if podMatchesAllAffinityTerms(terms, modifiedPod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kube/krt/collection_test.go
Named Labeled IP string } func SimplePodCollection(pods krt.Collection[*corev1.Pod]) krt.Collection[SimplePod] { return krt.NewCollection(pods, func(ctx krt.HandlerContext, i *corev1.Pod) *SimplePod { if i.Status.PodIP == "" { return nil } return &SimplePod{ Named: NewNamed(i), Labeled: NewLabeled(i.Labels), IP: i.Status.PodIP, } }) } type SizedPod struct { Named
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0)