- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for serviceTargets (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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)