Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for IsWaypointProxy (0.18 sec)

  1. pilot/pkg/xds/proxy_dependencies.go

    func ConfigAffectsProxy(req *model.PushRequest, proxy *model.Proxy) bool {
    	// Empty changes means "all" to get a backward compatibility.
    	if len(req.ConfigsUpdated) == 0 {
    		return true
    	}
    	if proxy.IsWaypointProxy() || proxy.IsZTunnel() {
    		// Optimizations do not apply since scoping uses different mechanism
    		// TODO: implement ambient aware scoping
    		return true
    	}
    
    	for config := range req.ConfigsUpdated {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. pilot/pkg/model/policyattachment.go

    	}
    }
    
    func PolicyMatcherForProxy(proxy *Proxy) WorkloadPolicyMatcher {
    	return WorkloadPolicyMatcher{
    		Namespace:      proxy.ConfigNamespace,
    		WorkloadLabels: proxy.Labels,
    		IsWaypoint:     proxy.IsWaypointProxy(),
    	}
    }
    
    func (p WorkloadPolicyMatcher) WithService(service *Service) WorkloadPolicyMatcher {
    	if service == nil {
    		return p
    	}
    	if service.Attributes.Namespace != p.Namespace {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_inbound.go

    			port:              port,
    			clusterName:       model.BuildInboundSubsetKey(int(port.TargetPort)),
    			bind:              actualWildcards[0],
    			bindToPort:        bindToPort,
    			hbone:             lb.node.IsWaypointProxy(),
    		}
    		// for inbound only generate a standalone listener when bindToPort=true
    		if bindToPort && conflictWithReservedListener(lb.node, nil, cc.bind, int(port.TargetPort), port.Protocol) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  4. pilot/pkg/model/context.go

    func (node *Proxy) InCluster(cluster cluster.ID) bool {
    	return node == nil || identifier.IsSameOrEmpty(cluster.String(), node.Metadata.ClusterID.String())
    }
    
    // IsWaypointProxy returns true if the proxy is acting as a waypoint proxy in an ambient mesh.
    func (node *Proxy) IsWaypointProxy() bool {
    	return node.Type == Waypoint
    }
    
    // IsZTunnel returns true if the proxy is acting as a ztunnel in an ambient mesh.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  5. pilot/pkg/networking/grpcgen/lds.go

    	if len(names) == 0 {
    		return nil
    	}
    	var out model.Resources
    	mtlsPolicy := authn.NewMtlsPolicy(push, node.Metadata.Namespace, node.Labels, node.IsWaypointProxy())
    	serviceInstancesByPort := map[uint32]model.ServiceTarget{}
    	for _, si := range node.ServiceTargets {
    		serviceInstancesByPort[si.Port.TargetPort] = si
    	}
    
    	for _, name := range names {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  6. pilot/pkg/xds/endpoints/endpoint_builder.go

    		return b.filterIstioEndpoint(ep)
    	})
    
    	localityEpMap := make(map[string]*LocalityEndpoints)
    	for _, ep := range eps {
    		mtlsEnabled := b.mtlsChecker.checkMtlsEnabled(ep, b.proxy.IsWaypointProxy())
    		eep := buildEnvoyLbEndpoint(b, ep, mtlsEnabled)
    		if eep == nil {
    			continue
    		}
    		locLbEps, found := localityEpMap[ep.Locality.Label]
    		if !found {
    			locLbEps = &LocalityEndpoints{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 02:18:19 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/cluster_builder.go

    		passThroughBindIPs: getPassthroughBindIPs(proxy.GetIPMode()),
    		supportsIPv4:       proxy.SupportsIPv4(),
    		supportsIPv6:       proxy.SupportsIPv6(),
    		sendHbone:          features.EnableHBONESend || proxy.IsWaypointProxy(),
    		locality:           proxy.Locality,
    		proxyLabels:        proxy.Labels,
    		proxyView:          proxy.GetView(),
    		proxyIPAddresses:   proxy.IPAddresses,
    		configNamespace:    proxy.ConfigNamespace,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/listener.go

    	case model.Router:
    		builder = configgen.buildGatewayListeners(builder)
    	}
    
    	builder.patchListeners()
    	l := builder.getListeners()
    	if features.EnableHBONESend && !builder.node.IsWaypointProxy() {
    		l = append(l, buildConnectOriginateListener())
    	}
    
    	return l
    }
    
    func BuildListenerTLSContext(serverTLSSettings *networking.ServerTLSSettings,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
Back to top