Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ImportedServices (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top