- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 138 for proxyv2 (0.57 sec)
-
pkg/istio-agent/agent.go
// Shared properties with Pilot Proxy struct. type Proxy struct { ID string IPAddresses []string Type model.NodeType ipMode model.IPMode DNSDomain string } func (node *Proxy) DiscoverIPMode() { node.ipMode = model.DiscoverIPMode(node.IPAddresses) } // IsIPv6 returns true if proxy only supports IPv6 addresses. func (node *Proxy) IsIPv6() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster.go
return common.IsDiscoveryContainer(clusterVersion, container, r.Labels[PodKey(namespace, pod)]) } // PodIstioVersion returns the Istio version for the given pod, if either the proxy or discovery are one of its // containers and the tag is in a parseable format. func (r *Resources) PodIstioVersion(namespace, pod string) string { p := r.Pod[PodKey(namespace, pod)] if p == nil { return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 14 02:11:31 UTC 2023 - 10.9K bytes - Viewed (0) -
src/net/http/cgi/host.go
env = append(env, "SERVER_NAME="+req.Host) } if req.TLS != nil { env = append(env, "HTTPS=on") } for k, v := range req.Header { k = strings.Map(upperCaseAndUnderscore, k) if k == "PROXY" { // See Issue 16405 continue } joinStr := ", " if k == "COOKIE" { joinStr = "; " } env = append(env, "HTTP_"+k+"="+strings.Join(v, joinStr)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 10.4K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute.go
} return virtualHosts } func SidecarIgnorePort(node *model.Proxy) bool { return !node.IsProxylessGrpc() } // generateVirtualHostDomains generates the set of domain matches for a service being accessed from // a proxy node func generateVirtualHostDomains(service *model.Service, listenerPort int, port int, node *model.Proxy) ([]string, []string) { if SidecarIgnorePort(node) && listenerPort != 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 32.7K bytes - Viewed (0) -
cluster/images/etcd-version-monitor/etcd-version-monitor.go
for _, rewriter := range e.rewriters { new, err := rewriter(mf) if err != nil { return nil, err } results = append(results, new) } } } else { // Proxy all metrics without any rewrite rules directly. results = append(results, mf) } } return results, nil } // EtcdVersion struct for unmarshalling the json response from etcd's /version endpoint.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 06:50:02 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
// This provides a separate independent reconciliation loop for peer endpoint leases // which ensures that the peer kube-apiservers are fetching the updated endpoint info for a given apiserver // in the case when the peer wants to proxy the request to the given apiserver because it can not serve the // request itself due to version mismatch. type PeerEndpointLeaseController struct { reconciler PeerEndpointLeaseReconciler endpointInterval time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
} // HTTPFilters computes the HttpFilter for a given proxy/class func (t *Telemetries) HTTPFilters(proxy *Proxy, class networking.ListenerClass, svc *Service) []*hcm.HttpFilter { if res := t.telemetryFilters(proxy, class, networking.ListenerProtocolHTTP, svc); res != nil { return res.([]*hcm.HttpFilter) } return nil } // TCPFilters computes the TCPFilters for a given proxy/class
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
LICENSE
GNU Affero General Public License, you may choose any version ever published by the Free Software Foundation. If the Program specifies that a proxy can decide which future versions of the GNU Affero General Public License can be used, that proxy's public statement of acceptance of a version permanently authorizes you to choose that version for the Program. Later license versions may give you additional or different
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 33.7K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
err := s.isReady() s.mutex.Lock() if err != nil { w.WriteHeader(http.StatusServiceUnavailable) log.Warnf("Envoy proxy is NOT ready: %s", err.Error()) s.lastProbeSuccessful = false } else { w.WriteHeader(http.StatusOK) if !s.lastProbeSuccessful { log.Info("Envoy proxy is ready") } s.lastProbeSuccessful = true } s.mutex.Unlock() } func (s *Server) isReady() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
pilot/pkg/xds/workload_test.go
}) ads.ExpectEmptyResponse() // Create policy; it should push only the static strict policy // We expect a removal because the policy exists in the cluster but is not sent to the proxy (because it's not port-specific, STRICT, etc.) createPeerAuthentication(s, "policy1", "ns", &v1beta1.PeerAuthentication{}) expectAddedAndRemoved(ads.ExpectResponse(), []string{"istio-system/istio_converted_static_strict"}, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0)