- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 64 for podMap (0.1 sec)
-
pilot/pkg/serviceregistry/kube/controller/pod.go
changed := labelsChanged || relevantAnnotationsChanged if cur.Status.PodIP != "" && changed { pc.proxyUpdates(cur, true) } // always continue calling pc.onEvent return false } // onEvent updates the IP-based index (pc.podsByIP). func (pc *PodCache) onEvent(_, pod *v1.Pod, ev model.Event) error { ip := pod.Status.PodIP // PodIP will be empty when pod is just created, but before the IP is assigned
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
&v1.Pod{ObjectMeta: pod1, Status: v1.PodStatus{Conditions: notReadyCondition, PodIP: ip, Phase: v1.PodPending}}, model.EventUpdate); err != nil { t.Error(err) } if handled != 0 { t.Errorf("notified workload handler %d times, want %d", handled, 0) } if err := f(nil, &v1.Pod{ObjectMeta: pod1, Status: v1.PodStatus{Conditions: readyCondition, PodIP: ip, Phase: v1.PodPending}}, model.EventUpdate); err != nil { t.Error(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go
name: "simple pod not running and not have podIP", inputs: []any{}, pod: &v1.Pod{ TypeMeta: metav1.TypeMeta{}, ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "ns", }, Spec: v1.PodSpec{}, Status: v1.PodStatus{ Phase: v1.PodPending, }, }, result: nil, }, { name: "simple pod not running but have podIP", inputs: []any{}, pod: &v1.Pod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.3K bytes - Viewed (0) -
cluster/gce/windows/smoke-test.sh
cat <<EOF > $windows_webserver_deployment.yaml # A multi-arch Windows container that runs an HTTP server on port # $windows_webserver_port that serves the container's hostname. # curl -s http://<pod_ip>:$windows_webserver_port apiVersion: apps/v1 kind: Deployment metadata: name: $windows_webserver_deployment labels: app: $windows_webserver_pod_label spec: replicas: $windows_webserver_replicas
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
{ pod: api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo"}, Status: api.PodStatus{PodIPs: []api.PodIP{{IP: expectedIP}}}, }, query: "foo", location: expectedIP, }, { pod: api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo"}, Status: api.PodStatus{PodIPs: []api.PodIP{{IP: expectedIP}}}, }, query: "foo:12345", location: expectedIP + ":12345", }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
pkg/bootstrap/testdata/stats_inclusion_golden.json
StatTags":"dlp_status,dlp_error","sidecar.istio.io/statsHistogramBuckets":"{\"istio\":[1,5,10,50,100,500,1000,5000,10000],\"envoy\":[1,5,10,25,50,100,250,500,1000,2500,5000,10000]}","sidecar.istio.io/statsInclusionPrefixes":"prefix1,prefix2,http.{pod_ip}_","sidecar.istio.io/statsInclusionRegexps":"http.[0-9]*\\.[0-9]*\\.[0-9]*\\.[0-9]*_8080.downstream_rq_time","sidecar.istio.io/statsInclusionSuffixes":"suffix1,suffix2,upstream_rq_1xx,upstream_rq_2xx,upstream_rq_3xx,upstream_rq_4xx,upstream_rq_5x...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 14:41:40 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/registry/core/pod/strategy.go
} podSpecificFieldsSet["status.phase"] = string(pod.Status.Phase) // TODO: add podIPs as a downward API value(s) with proper format podIP := "" if len(pod.Status.PodIPs) > 0 { podIP = string(pod.Status.PodIPs[0].IP) } podSpecificFieldsSet["status.podIP"] = podIP podSpecificFieldsSet["status.nominatedNodeName"] = string(pod.Status.NominatedNodeName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 29.8K bytes - Viewed (0) -
pkg/bootstrap/config.go
// Inbound downstream metrics are named as: http.{pod_ip}_{port}.downstream_rq_* // Other outbound downstream metrics are numerous and not very interesting for a sidecar. // specifying http.{pod_ip}_ as a prefix will capture these downstream metrics. return substituteValues(inclusionOption, "{pod_ip}", nodeIPs) } extraStatTags := make([]string, 0, len(config.ExtraStatTags))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 27.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox.go
} // pick additional ips, if cri reported them for _, podIP := range podSandbox.Network.AdditionalIps { if nil == netutils.ParseIPSloppy(podIP.Ip) { klog.InfoS("Pod Sandbox reported an unparseable additional IP", "pod", klog.KRef(podNamespace, podName), "IP", podIP.Ip) return nil } podIPs = append(podIPs, podIP.Ip) } return podIPs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/cmd.go
return fmt.Errorf("Invalid proxy Type: " + string(proxyArgs.Type)) } } podIP, _ := netip.ParseAddr(options.InstanceIPVar.Get()) // protobuf encoding of IP_ADDRESS type if podIP.IsValid() { // The first one must be the pod ip as we pick the first ip as pod ip in istiod. proxyArgs.IPAddresses = []string{podIP.String()} } // Obtain all the IPs from the node proxyAddrs := make([]string, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0)