Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for serviceTargets (0.15 sec)

  1. pilot/pkg/serviceregistry/memory/discovery.go

    // 'in' services.
    func (sd *ServiceDiscovery) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget {
    	sd.mutex.Lock()
    	defer sd.mutex.Unlock()
    	if sd.WantGetProxyServiceTargets != nil {
    		return sd.WantGetProxyServiceTargets
    	}
    	out := make([]model.ServiceTarget, 0)
    	for _, ip := range node.IPAddresses {
    		si, found := sd.ip2instance[ip]
    		if found {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 23:10:01 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/aggregate/controller.go

    	return !r.Cluster().Equals(nodeClusterID)
    }
    
    // GetProxyServiceTargets lists service instances co-located with a given proxy
    func (c *Controller) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget {
    	out := make([]model.ServiceTarget, 0)
    	nodeClusterID := nodeClusterID(node)
    	for _, r := range c.GetRegistries() {
    		if skipSearchingRegistryForProxy(nodeClusterID, r) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. pilot/pkg/model/gateway.go

    				if s.GetTls().GetMode() == networking.ServerTLSSettings_AUTO_PASSTHROUGH {
    					hosts.InsertAll(s.Hosts...)
    				}
    			}
    		}
    	}
    	return hosts
    }
    
    func udpSupportedPort(number uint32, instances []ServiceTarget) bool {
    	for _, w := range instances {
    		if int(number) == w.Port.Port && w.Port.Protocol == protocol.UDP {
    			return true
    		}
    	}
    	return false
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go

    			return fmt.Errorf("expected 0 service instance, found %d", len(instances))
    		}
    
    		return nil
    	}, serviceImportTimeout)
    }
    
    func (ic *serviceImportCacheImpl) getProxyServiceTargets() []model.ServiceTarget {
    	return ic.GetProxyServiceTargets(&model.Proxy{
    		Type:            model.SidecarProxy,
    		IPAddresses:     []string{serviceImportPodIP},
    		Locality:        &core.Locality{Region: "r", Zone: "z"},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 18:50:38 UTC 2023
    - 15.2K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    	return i
    }
    
    // nolint: unparam
    func makeTarget(cfg *config.Config, address string, port int,
    	svcPort *networking.ServicePort, svcLabels map[string]string, mtlsMode MTLSMode,
    ) model.ServiceTarget {
    	services := convertServices(*cfg)
    	svc := services[0] // default
    	for _, s := range services {
    		if string(s.Hostname) == address {
    			svc = s
    			break
    		}
    	}
    	if mtlsMode == MTLS {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceentry/controller.go

    // NOTE: The service objects in these instances do not have the auto allocated IP set.
    func (s *Controller) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget {
    	out := make([]model.ServiceTarget, 0)
    	s.mutex.RLock()
    	defer s.mutex.RUnlock()
    	for _, ip := range node.IPAddresses {
    		instances := s.serviceInstances.getByIP(ip)
    		for _, i := range instances {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top