Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for serviceTargets (0.34 sec)

  1. pilot/pkg/model/context_test.go

    	}
    
    	proxy := &model.Proxy{}
    	proxy.SetServiceTargets(env)
    
    	assert.Equal(t, len(proxy.ServiceTargets), 3)
    	assert.Equal(t, proxy.ServiceTargets[0].Service.Hostname, "test2.com")
    	assert.Equal(t, proxy.ServiceTargets[1].Service.Hostname, "test3.com")
    	assert.Equal(t, proxy.ServiceTargets[2].Service.Hostname, "test1.com")
    }
    
    func TestGlobalUnicastIP(t *testing.T) {
    	cases := []struct {
    		name   string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 05 23:51:52 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. pilot/pkg/xds/proxy_dependencies.go

    	if ConfigAffectsProxy(req, proxy) {
    		return true
    	}
    
    	// If the proxy's service updated, need push for it.
    	if len(proxy.ServiceTargets) > 0 && req.ConfigsUpdated != nil {
    		for _, svc := range proxy.ServiceTargets {
    			if _, ok := req.ConfigsUpdated[model.ConfigKey{
    				Kind:      kind.ServiceEntry,
    				Name:      string(svc.Service.Hostname),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_builder.go

    }
    
    // NewClusterBuilder builds an instance of ClusterBuilder.
    func NewClusterBuilder(proxy *model.Proxy, req *model.PushRequest, cache model.XdsCache) *ClusterBuilder {
    	cb := &ClusterBuilder{
    		serviceTargets:     proxy.ServiceTargets,
    		proxyID:            proxy.ID,
    		proxyType:          proxy.Type,
    		proxyVersion:       proxy.Metadata.IstioVersion,
    		sidecarScope:       proxy.SidecarScope,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/plugin/authn/authentication.go

    			if port == ingressListener.Port.Number {
    				return false
    			}
    		}
    		return true
    	}
    
    	// If there is no Sidecar, check if the port is appearing in any service.
    	for _, si := range node.ServiceTargets {
    		if port == si.Port.TargetPort {
    			return false
    		}
    	}
    	return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    func (esc *endpointSliceController) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget {
    	eps := esc.slices.List(proxy.Metadata.Namespace, endpointSliceSelector)
    	var out []model.ServiceTarget
    	for _, ep := range eps {
    		instances := esc.serviceTargets(ep, proxy)
    		out = append(out, instances...)
    	}
    
    	return out
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  6. pilot/pkg/model/context.go

    	PrevMergedGateway *PrevMergedGateway
    
    	// ServiceTargets contains a list of all Services associated with the proxy, contextualized for this particular proxy.
    	// These are unique to this proxy, as the port information is specific to it - while a ServicePort is shared with the
    	// service, the target port may be distinct per-endpoint. So this maintains a view specific to this proxy.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  7. pilot/pkg/model/service.go

    	// will return an empty slice.
    	//
    	// There are two reasons why this returns multiple ServiceTargets instead of one:
    	// - A ServiceTargets has a single Port.  But a Service
    	//   may have many ports.  So a workload implementing such a Service would need
    	//   multiple ServiceTargets, one for each port.
    	// - A single workload may implement multiple logical Services.
    	//
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  8. pilot/pkg/networking/grpcgen/lds.go

    		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 {
    		listenAddress := strings.TrimPrefix(name, grpcxds.ServerListenerNamePrefix)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/cluster.go

    type buildClusterOpts struct {
    	mesh            *meshconfig.MeshConfig
    	mutable         *clusterWrapper
    	policy          *networking.TrafficPolicy
    	port            *model.Port
    	serviceAccounts []string
    	serviceTargets  []model.ServiceTarget
    	// Used for traffic across multiple network clusters
    	// the east-west gateway in a remote cluster will use this value to route
    	// traffic to the appropriate service
    	istioMtlsSni    string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  10. pilot/pkg/model/push_context.go

    			gwsvcs := strings.Split(gwsvcstr, ",")
    			known := sets.New[string](gwsvcs...)
    			matchingInstances := make([]ServiceTarget, 0, len(proxy.ServiceTargets))
    			for _, si := range proxy.ServiceTargets {
    				if _, f := known[string(si.Service.Hostname)]; f && si.Service.Attributes.Namespace == cfg.Namespace {
    					matchingInstances = append(matchingInstances, si)
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
Back to top