Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 345 for podMap (0.18 sec)

  1. pilot/pkg/serviceregistry/serviceregistry_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	// Apiserver doesn't allow Create/Update to modify the pod status. Creating doesn't result in
    	// events - since PodIP will be "".
    	newPod.Status.PodIP = pod.Status.PodIP
    	newPod.Status.PodIPs = []v1.PodIP{
    		{
    			IP: pod.Status.PodIP,
    		},
    	}
    	newPod.Status.Phase = v1.PodRunning
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  2. cni/pkg/util/podutil.go

    		return nil
    	}
    	return err
    }
    
    // Get any IPs currently assigned to the Pod.
    //
    // If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'),
    // otherwise fallback to 'PodIP'.
    //
    // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish)
    // K8S may not have received the pod IPs yet, and may not report the pod as having any.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. docs/sts/etcd.md

    ```
    rm -rf /tmp/etcd-data.tmp && mkdir -p /tmp/etcd-data.tmp && \
      podman rmi gcr.io/etcd-development/etcd:v3.3.9 || true && \
      podman run \
      -p 2379:2379 \
      -p 2380:2380 \
      --mount type=bind,source=/tmp/etcd-data.tmp,destination=/etcd-data \
      --name etcd-gcr-v3.3.9 \
      gcr.io/etcd-development/etcd:v3.3.9 \
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  4. pilot/pkg/controllers/untaint/nodeuntainter_test.go

    		pod.Status = corev1.PodStatus{}
    		newPod := s.pc.Create(pod)
    		if markReady {
    			setPodReady(newPod)
    		}
    		newPod.Status.PodIP = ip
    		newPod.Status.Phase = corev1.PodRunning
    		newPod.Status.PodIPs = []corev1.PodIP{
    			{
    				IP: ip,
    			},
    		}
    		s.pc.UpdateStatus(newPod)
    	} else {
    		s.pc.Update(pod)
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 00:50:31 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. 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)
  6. pkg/test/framework/components/echo/kube/testdata/two-workloads-one-nosidecar.yaml

            - containerPort: 8080
            - containerPort: 3333
              name: tcp-health-port
            env:
            - name: INSTANCE_IP
              valueFrom:
                fieldRef:
                  fieldPath: status.podIP
            - name: NAMESPACE
              valueFrom:
                fieldRef:
                  fieldPath: metadata.namespace
            readinessProbe:
              httpGet:
                path: /
                port: 8080
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Nov 17 04:28:06 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  7. pkg/probe/http/request.go

    // When httpGet.Host is empty, podIP will be used instead.
    func NewRequestForHTTPGetAction(httpGet *v1.HTTPGetAction, container *v1.Container, podIP string, userAgentFragment string) (*http.Request, error) {
    	scheme := strings.ToLower(string(httpGet.Scheme))
    	if scheme == "" {
    		scheme = "http"
    	}
    
    	host := httpGet.Host
    	if host == "" {
    		host = podIP
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 07:39:55 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  8. cni/pkg/util/podutil_test.go

    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    			PodIP:  "2.2.2.2",
    			PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}},
    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 03 19:29:42 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. pkg/test/framework/components/echo/kube/testdata/proxyless-custom-image.yaml

            - containerPort: 3333
              name: tcp-health-port
            - containerPort: 17777
            env:
            - name: INSTANCE_IP
              valueFrom:
                fieldRef:
                  fieldPath: status.podIP
            - name: NAMESPACE
              valueFrom:
                fieldRef:
                  fieldPath: metadata.namespace
            - name: EXPOSE_GRPC_ADMIN
              value: "true"
            readinessProbe:
              httpGet:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Nov 17 04:28:06 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  10. 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)
Back to top