Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 273 for podMap (0.85 sec)

  1. pkg/test/framework/components/ambient/waypoint.go

    	inbound  istioKube.PortForwarder
    	outbound istioKube.PortForwarder
    	pod      v1.Pod
    }
    
    func (k kubeComponent) Namespace() namespace.Instance {
    	return k.ns
    }
    
    func (k kubeComponent) PodIP() string {
    	return k.pod.Status.PodIP
    }
    
    func (k kubeComponent) Inbound() string {
    	return k.inbound.Address()
    }
    
    func (k kubeComponent) Outbound() string {
    	return k.outbound.Address()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. pkg/kube/krt/krttest/helpers.go

    	t      test.Failer
    	inputs []any
    }
    
    // NewMock creates a helper to build Collections of static inputs for use with testing.
    // Example usage:
    //
    //	mock := krttest.NewMock(t, []any{serviceFoo, podBar, namespaceBaz})
    //	pods := krttest.GetMockCollection[Pod](mock) // makes a collection of all Pod types from inputs
    func NewMock(t test.Failer, inputs []any) *MockCollection {
    	t.Helper()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 21 19:33:01 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. 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)
  4. docs/es/docs/advanced/response-headers.md

    # Headers de Respuesta
    
    ## Usar un parámetro `Response`
    
    Puedes declarar un parámetro de tipo `Response` en tu *función de operación de path* (de manera similar como se hace con las cookies).
    
    Y entonces, podrás configurar las cookies en ese objeto de response *temporal*.
    
    ```Python hl_lines="1  7-8"
    {!../../../docs_src/response_headers/tutorial002.py!}
    ```
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Wed Feb 07 12:51:12 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. pilot/cmd/pilot-agent/options/statusserver.go

    	"istio.io/istio/pkg/model"
    )
    
    func NewStatusServerOptions(ipv6 bool, t model.NodeType, proxyConfig *meshconfig.ProxyConfig, agent *istioagent.Agent) *status.Options {
    	return &status.Options{
    		IPv6:           ipv6,
    		PodIP:          InstanceIPVar.Get(),
    		AdminPort:      uint16(proxyConfig.ProxyAdminPort),
    		StatusPort:     uint16(proxyConfig.StatusPort),
    		KubeAppProbers: kubeAppProberNameVar.Get(),
    		NodeType:       t,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 05 23:51:52 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  6. cni/pkg/repair/netns.go

    //
    // Instead, we traverse the procfs. Comments on this method are inline.
    func getPodNetNs(pod *corev1.Pod) (string, error) {
    	parsedPodAddr := net.ParseIP(pod.Status.PodIP)
    	if parsedPodAddr == nil {
    		return "", fmt.Errorf("failed to parse addr: %s", pod.Status.PodIP)
    	}
    
    	fs, err := procfs.NewFS("/host/proc")
    	if err != nil {
    		return "", fmt.Errorf("read procfs: %v", err)
    	}
    	procs, err := fs.AllProcs()
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 04:07:10 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. pkg/kubelet/prober/prober.go

    		if err != nil {
    			return probe.Unknown, "", err
    		}
    		host := p.TCPSocket.Host
    		if host == "" {
    			host = status.PodIP
    		}
    		klog.V(4).InfoS("TCP-Probe", "host", host, "port", port, "timeout", timeout)
    		return pb.tcp.Probe(host, port, timeout)
    
    	case p.GRPC != nil:
    		host := status.PodIP
    		service := ""
    		if p.GRPC.Service != nil {
    			service = *p.GRPC.Service
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:50:13 UTC 2024
    - 8.7K 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. tests/integration/pilot/mirror_test.go

    					// we only apply to config clusters
    					t.ConfigIstio().EvalFile(apps.Namespace.Name(), vsc, "testdata/traffic-mirroring-template.yaml").
    						ApplyOrFail(t)
    
    					for _, podA := range apps.A {
    						podA := podA
    						t.NewSubTest(fmt.Sprintf("from %s", podA.Config().Cluster.StableName())).Run(func(t framework.TestContext) {
    							for _, proto := range mirrorProtocols {
    								t.NewSubTest(string(proto)).Run(func(t framework.TestContext) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. pkg/kubelet/lifecycle/handlers.go

    			return err
    		}
    		if len(status.IPs) == 0 {
    			return fmt.Errorf("failed to find networking container: %v", status)
    		}
    		host = status.IPs[0]
    		podIP = host
    	}
    
    	req, err := httpprobe.NewRequestForHTTPGetAction(handler.HTTPGet, container, podIP, "lifecycle")
    	if err != nil {
    		return err
    	}
    	resp, err := hr.httpDoer.Do(req)
    	discardHTTPRespBody(resp)
    
    	if isHTTPResponseError(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 11:40:52 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top