- Sort Score
- Result 10 results
- Languages All
Results 21 - 27 of 27 for serviceTargets (0.26 sec)
-
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) -
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) -
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) -
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)