Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for serviceTargets (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    		expectServiceInstances(t, sd, httpStaticOverlayUpdatedInstance, 0, instances)
    		proxyInstances := []model.ServiceTarget{
    			makeTarget(httpStaticOverlay, "6.6.6.6", 4567, httpStaticOverlay.Spec.(*networking.ServiceEntry).Ports[0], map[string]string{"other": "bar"}, PlainText),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  6. pilot/pkg/model/push_context_test.go

    	return l.services
    }
    
    func (l *localServiceDiscovery) GetService(host.Name) *Service {
    	panic("implement me")
    }
    
    func (l *localServiceDiscovery) GetProxyServiceTargets(*Proxy) []ServiceTarget {
    	panic("implement me")
    }
    
    func (l *localServiceDiscovery) GetProxyWorkloadLabels(*Proxy) labels.Instance {
    	panic("implement me")
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/cluster_builder_test.go

    		t.Run(tc.name, func(t *testing.T) {
    			test.SetForTest(t, &features.EnableAutoSni, tc.enableAutoSni)
    			test.SetForTest(t, &features.VerifyCertAtClient, tc.enableVerifyCertAtClient)
    
    			targets := []model.ServiceTarget{
    				{
    					Service: tc.service,
    					Port: model.ServiceInstancePort{
    						ServicePort: tc.port,
    						TargetPort:  10001,
    					},
    				},
    			}
    
    			var cfg *config.Config
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
Back to top