- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for podIps (0.11 sec)
-
cni/pkg/nodeagent/net_test.go
var podStatus corev1.PodStatus if v6IP { podStatus = corev1.PodStatus{ PodIP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164", PodIPs: []corev1.PodIP{{IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164"}, {IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3165"}}, } } else { podStatus = corev1.PodStatus{ PodIP: "2.2.2.2", PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}}, } } return &corev1.Pod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
var addedIPSnapshot []netip.Addr for _, pod := range ambientPods { podIPs := util.GetPodIPsIfPresent(pod) if len(podIPs) == 0 { log.Warnf("pod %s does not appear to have any assigned IPs, not syncing with ipset", pod.Name) } else { addedIps, err := addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// the CNI plugin chain, and have a PodIP. // // If PodIPs exists, it is preferred, otherwise fallback to PodIP. // // If we get to this point and have a pod that really and truly has no IP in either of those, // it's not routable at this point and something is wrong/we should discard this event. podIPs := util.GetPodIPsIfPresent(pod) if len(podIPs) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
tests/integration/pilot/gateway_test.go
RequiresLocalControlPlane(). Run(func(t framework.TestContext) { c := t.Clusters().Default() podIPs, err := i.PodIPsFor(c, i.Settings().SystemNamespace, "app=istio-ingressgateway") if err != nil { t.Fatalf("error getting ingress gateway pod ips: %v", err) } for _, ip := range podIPs { t.NewSubTest("gateway-metrics-endpoints-" + ip.IP).Run(func(t framework.TestContext) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) pods := handlers.GetActiveAmbientPodSnapshot() // Should only return pods with the annotation indicating they are actually redirected at this time, // not pods that are just scheduled to be enrolled. assert.Equal(t, len(pods), 1) assert.Equal(t, pods[0], redirectedNotEnrolled) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K 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) -
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/registry/core/pod/storage/eviction_test.go
expectError: "Cannot evict pod as it would violate the pod's disruption budget.: TooManyRequests: The disruption budget foo needs 0 healthy pods and has 0 currently", podPhase: api.PodRunning, podName: "t1", policies: []*policyv1.UnhealthyPodEvictionPolicyType{nil, unhealthyPolicyPtr(policyv1.IfHealthyBudget)}, // AlwaysAllow would terminate the pod since Running pods are not guarded by this policy }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// Specifies the action taken on a pod failure when the requirements are satisfied. // Possible values are: // // - FailJob: indicates that the pod's job is marked as Failed and all // running pods are terminated. // - FailIndex: indicates that the pod's index is marked as Failed and will // not be restarted. // This value is beta-level. It can be used when the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
allowedPodNumber := nodeInfo.Allocatable.AllowedPodNumber if len(nodeInfo.Pods)+1 > allowedPodNumber { insufficientResources = append(insufficientResources, InsufficientResource{ ResourceName: v1.ResourcePods, Reason: "Too many pods", Requested: 1, Used: int64(len(nodeInfo.Pods)), Capacity: int64(allowedPodNumber), }) } if podRequest.MilliCPU == 0 &&
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0)