- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ImportedServices (0.25 sec)
-
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
// The real k8s Service can live anywhere in the mesh and does not have to reside in the same // cluster as the ServiceImport. type serviceImportCache interface { Run(stop <-chan struct{}) HasSynced() bool ImportedServices() []importedService } // newServiceImportCache creates a new cache of ServiceImport resources in the cluster. func newServiceImportCache(c *Controller) serviceImportCache { if features.EnableMCSHost {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
importedServices = append(importedServices, svc) continue } } // Check if there is an import of form */host or */* if wnsFound { if svc := matchingAliasService(wildcardHosts, matchingService(wildcardHosts, s, ilw)); svc != nil { importedServices = append(importedServices, svc) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
mcsService.Exported = true mcsService.Discoverability = se.discoverability outMap[se.namespacedName] = mcsService } // Add the ServiceImport info. for _, si := range c.imports.ImportedServices() { mcsService := outMap[si.namespacedName] mcsService.Cluster = c.Cluster() mcsService.Name = si.namespacedName.Name mcsService.Namespace = si.namespacedName.Namespace mcsService.Imported = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0)