- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 273 for podMap (0.85 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)