Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 74 for proxyv2 (0.3 sec)

  1. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    // GetProxyServiceTargets returns service instances co-located with a given proxy
    // TODO: this code does not return k8s service instances when the proxy's IP is a workload entry
    // To tackle this, we need a ip2instance map like what we have in service entry.
    func (esc *endpointSliceController) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget {
    	eps := esc.slices.List(proxy.Metadata.Namespace, endpointSliceSelector)
    	var out []model.ServiceTarget
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/networkfilter_test.go

    				Services: []*model.Service{
    					buildServiceWithPort("example.com", 443, protocol.TLS, tnow),
    					buildServiceWithPort("tunnel-proxy.com", 3128, protocol.HTTP, tnow),
    				},
    			})
    			proxy := cg.SetupProxy(&model.Proxy{ConfigNamespace: ns})
    			lb := ListenerBuilder{node: proxy, push: cg.PushContext()}
    			filters := lb.buildOutboundNetworkFilters(tt.routeDestinations,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_traffic_policy.go

    	opts *buildClusterOpts,
    	proxyProtocol *networking.TrafficPolicy_ProxyProtocol,
    ) {
    	if proxyProtocol == nil {
    		return
    	}
    	c := opts.mutable
    	if c.cluster.TransportSocket != nil {
    		// add an upstream proxy protocol wrapper for transportSocket
    		c.cluster.TransportSocket = &core.TransportSocket{
    			Name: "envoy.transport_sockets.upstream_proxy_protocol",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 20K bytes
    - Viewed (0)
  4. pilot/pkg/xds/ads.go

    			Zone:    proxy.XdsNode.Locality.GetZone(),
    			SubZone: proxy.XdsNode.Locality.GetSubZone(),
    		}
    	}
    	// add topology labels to proxy labels
    	proxy.Labels = labelutil.AugmentLabels(
    		proxy.Labels,
    		proxy.Metadata.ClusterID,
    		util.LocalityToString(proxy.Locality),
    		proxy.GetNodeName(),
    		proxy.Metadata.Network,
    	)
    }
    
    func localityFromProxyLabels(proxy *model.Proxy) *core.Locality {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pkg/features/kube_features.go

    	// owner: @ksubrmnn
    	// alpha: v1.14
    	//
    	// Allows kube-proxy to create DSR loadbalancers for Windows
    	WinDSR featuregate.Feature = "WinDSR"
    
    	// owner: @ksubrmnn
    	// alpha: v1.14
    	// beta: v1.20
    	//
    	// Allows kube-proxy to run in Overlay mode for Windows
    	WinOverlay featuregate.Feature = "WinOverlay"
    
    	// owner: @marosset
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  6. pkg/config/validation/agent/validation.go

    	// but that requires additional test validation
    	if config.DiscoveryAddress == "" {
    		errs = multierror.Append(errs, errors.New("discovery address must be set to the proxy discovery service"))
    	} else if err := ValidateProxyAddress(config.DiscoveryAddress); err != nil {
    		errs = multierror.Append(errs, multierror.Prefix(err, "invalid discovery address:"))
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  7. pkg/security/security.go

    	ECCSigAlg string
    
    	// The type of curve to use when generating private keys with ECC. Currently only ECDSA is supported.
    	ECCCurve string
    
    	// FileMountedCerts indicates whether the proxy is using file
    	// mounted certs created by a foreign CA. Refresh is managed by the external
    	// CA, by updating the Secret or VM file. We will watch the file for changes
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  8. pilot/pkg/autoregistration/controller.go

    }
    
    func autoregisteredWorkloadEntryName(proxy *model.Proxy) string {
    	if proxy.Metadata.AutoRegisterGroup == "" {
    		return ""
    	}
    	if len(proxy.IPAddresses) == 0 {
    		log.Errorf("auto-registration of %v failed: missing IP addresses", proxy.ID)
    		return ""
    	}
    	if len(proxy.Metadata.Namespace) == 0 {
    		log.Errorf("auto-registration of %v failed: missing namespace", proxy.ID)
    		return ""
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  9. pilot/pkg/xds/delta.go

    		},
    	}
    	// SidecarScope for the proxy may has not been updated based on this pushContext.
    	// It can happen when `processRequest` comes after push context has been updated(s.initPushContext),
    	// but before proxy's SidecarScope has been updated(s.updateProxy).
    	if con.proxy.SidecarScope != nil && con.proxy.SidecarScope.Version != request.Push.PushVersion {
    		s.computeProxyState(con.proxy, request)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  10. 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)
Back to top