- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for ServiceHostname (0.24 sec)
-
pilot/pkg/serviceregistry/kube/conversion.go
}) } return out } // ServiceHostname produces FQDN for a k8s service func ServiceHostname(name, namespace, domainSuffix string) host.Name { return host.Name(name + "." + namespace + "." + "svc" + "." + domainSuffix) // Format: "%s.%s.svc.%s" } // ServiceHostnameForKR calls ServiceHostname with the name and namespace of the given kubernetes resource.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion_test.go
} if service.External() { t.Fatal("service should not be external") } if service.Hostname != ServiceHostname(serviceName, namespace, domainSuffix) { t.Fatalf("service hostname incorrect => %q, want %q", service.Hostname, ServiceHostname(serviceName, namespace, domainSuffix)) } ips := service.ClusterVIPs.GetAddressesFor(clusterID) if len(ips) != 1 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go
retry.UntilOrFail(t, func() bool { if svc := ec.GetService(ec.serviceHostname()); svc == nil { return false } inst := ec.getEndpoint(c.Endpoints) return inst != nil }, serviceExportTimeout) return ec, c.Endpoints } func (ec *serviceExportCacheImpl) serviceHostname() host.Name { return kube.ServiceHostname(serviceExportName, serviceExportNamespace, ec.opts.DomainSuffix) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
expectedSvcList := []*model.Service{ { Hostname: kube.ServiceHostname("svc1", "nsA", defaultFakeDomainSuffix), DefaultAddress: "10.0.0.1", Ports: model.PortList{ &model.Port{ Name: "tcp-port", Port: 8080, Protocol: protocol.TCP, }, }, }, { Hostname: kube.ServiceHostname("svc2", "nsA", defaultFakeDomainSuffix), DefaultAddress: "10.0.0.1",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
}, } for name, tt := range cases { t.Run(name, func(t *testing.T) { g := NewWithT(t) clusters := xdstest.ExtractClusters(buildTestClusters(clusterTest{ t: t, serviceHostname: "*.example.org", nodeType: model.SidecarProxy, mesh: testMesh(), destRule: tt.destrule, sidecar: tt.sidecar, })) for c, expected := range tt.want {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
if features.EnableMCSHost { return []host.Name{ kube.ServiceHostname(name.Name, name.Namespace, c.opts.DomainSuffix), serviceClusterSetLocalHostname(name), } } return []host.Name{ kube.ServiceHostname(name.Name, name.Namespace, c.opts.DomainSuffix), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
addPods(t, controller, fx, pods...) createServiceWait(controller, svcName, ns, nil, nil, []int32{8080}, map[string]string{"app": appName}, t) // Ensure that the service is available. hostname := kube.ServiceHostname(svcName, ns, controller.opts.DomainSuffix) svc := controller.GetService(hostname) if svc == nil { t.Fatal("failed to get service") } // Create an endpoint that indicates it's an MCS endpoint for the service.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
return nil } func (c *autoServiceExportController) isClusterLocalService(svc *v1.Service) bool { hostname := serviceRegistryKube.ServiceHostname(svc.Name, svc.Namespace, c.DomainSuffix) return c.ClusterLocal.GetClusterLocalHosts().IsClusterLocal(hostname)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
discoverability: make(map[host.Name]string), } // Generate the map of all hosts for this service to their discoverability policies. clusterLocalHost := kubesr.ServiceHostname(uExport.GetName(), uExport.GetNamespace(), ec.opts.DomainSuffix) clusterSetLocalHost := serviceClusterSetLocalHostname(es.namespacedName) for _, hostName := range []host.Name{clusterLocalHost, clusterSetLocalHost} {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0)