Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 64 for podMap (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top