Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 75 for proxyv2 (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top