- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 75 for proxyv2 (0.15 sec)
-
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) -
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 (0) -
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) -
go.mod
github.com/google/s2a-go v0.1.7 // indirect github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510 // indirect github.com/googleapis/enterprise-certificate-proxy v0.3.2 // indirect github.com/googleapis/gax-go/v2 v2.12.4 // indirect github.com/gorilla/websocket v1.5.2 // indirect github.com/hashicorp/errwrap v1.1.0 // indirect github.com/hashicorp/go-hclog v1.2.0 // indirect
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:53:53 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
// DestinationRuleConfig returns merged destination rules for a svc. func (sc *SidecarScope) DestinationRuleConfig(direction TrafficDirection, proxy *Proxy, svc host.Name) *config.Config { cdr := sc.DestinationRule(direction, proxy, svc) if cdr == nil { return nil } return cdr.rule } // Services returns the list of services that are visible to a sidecar. func (sc *SidecarScope) Services() []*Service { return sc.services
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
tools/istio-iptables/pkg/capture/run.go
// handle this case, we exclude port 53 from this rule. Note: We cannot just move the // port 53 redirection rule further up the list, as we will want to avoid capturing // DNS requests from the proxy UID/GID cfg.ruleBuilder.AppendRule(iptableslog.UndefinedCommand, constants.ISTIOOUTPUT, constants.NAT, "-o", "lo", "-p", "tcp", "!", "--dport", "53", "-m", "owner", "!", "--uid-owner", uid, "-j", constants.RETURN)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 03:53:23 UTC 2024 - 35.4K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
dummySvc := &corev1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: dummySvcName, Namespace: echos.Namespace.Name(), Annotations: map[string]string{ // Export the service nowhere, so that no proxy will receive it or its VIP. annotation.NetworkingExportTo.Name: "~", }, }, Spec: corev1.ServiceSpec{ Type: corev1.ServiceTypeClusterIP, Ports: svc.Spec.Ports, }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/bootstrap/instance_test.go
if c.setup != nil { c.setup() } if c.teardown != nil { defer c.teardown() } proxyConfig, err := loadProxyConfig(c.base, out, t) if err != nil { t.Fatalf("unable to load proxy config: %s\n%v", c.base, err) } _, localEnv := createEnv(t, map[string]string{}, c.annotations) for k, v := range c.envVars { localEnv = append(localEnv, k+"="+v) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 19.5K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
// then at least conceptually it currently doesn't matter // where we publish it. // // The long-term goal is to move the handling of // ResourceSlice objects into the driver, with kubelet // just acting as a REST proxy. The advantage of that will // be that kubelet won't need to support the same // resource API version as the driver and the control plane. // With that approach, the driver will be able to match
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
_, etcdserver, apiserverCfg, _ := newInstance(t) defer etcdserver.Terminate(t) storageProvider, err := corerest.New(corerest.Config{ GenericConfig: *apiserverCfg.ControlPlane.NewCoreGenericConfig(), Proxy: corerest.ProxyConfig{ Transport: apiserverCfg.ControlPlane.Extra.ProxyTransport, KubeletClientConfig: apiserverCfg.Extra.KubeletClientConfig, }, Services: corerest.ServicesConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0)