Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ServiceRegistries (0.17 sec)

  1. pkg/config/analysis/analyzers/multicluster/meshnetworks.go

    	c.ForEach(gvk.Secret, func(r *resource.Instance) bool {
    		if r.Metadata.Labels[multicluster.MultiClusterSecretLabel] == "true" {
    			s := r.Message.(*v1.Secret)
    			for c := range s.Data {
    				serviceRegistries = append(serviceRegistries, provider.ID(c))
    			}
    		}
    		return true
    	})
    
    	// only one meshnetworks config should exist.
    	c.ForEach(gvk.MeshNetworks, func(r *resource.Instance) bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 01 01:34:15 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/fake.go

    	MeshConfig      *meshconfig.MeshConfig
    	NetworksWatcher mesh.NetworksWatcher
    
    	// Additional service registries to use. A ServiceEntry and memory registry will always be created.
    	ServiceRegistries []serviceregistry.Instance
    
    	// Base ConfigController to use. If not set, a in-memory store will be used
    	ConfigController model.ConfigStoreController
    
    	// Additional ConfigStoreController to use
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. tests/fuzz/v1alpha3_fuzzer.go

    }
    
    func ValidateTestOptions(to core.TestOptions) error {
    	for _, csc := range to.ConfigStoreCaches {
    		if csc == nil {
    			return errors.New("a ConfigStoreController was nil")
    		}
    	}
    	for _, sr := range to.ServiceRegistries {
    		if sr == nil {
    			return errors.New("a ServiceRegistry was nil")
    		}
    	}
    	return nil
    }
    
    func FuzzValidateClusters(data []byte) int {
    	proxy := model.Proxy{}
    	f := fuzz.NewConsumer(data)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  4. pilot/pkg/model/network.go

    	mgr.mu.Lock()
    	defer mgr.mu.Unlock()
    	log.Infof("reloading network gateways")
    
    	// Generate a snapshot of the state of gateways by merging the contents of
    	// MeshNetworks and the ServiceRegistries.
    
    	// Store all gateways in a set initially to eliminate duplicates.
    	gatewaySet := make(NetworkGatewaySet)
    
    	// First, load gateways from the static MeshNetworks config.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  5. pilot/test/xds/fake.go

    		ConfigTemplateInput: opts.ConfigTemplateInput,
    		ConfigController:    configController,
    		MeshConfig:          m,
    		XDSUpdater:          xdsUpdater,
    		NetworksWatcher:     opts.NetworksWatcher,
    		ServiceRegistries:   registries,
    		ConfigStoreCaches:   []model.ConfigStoreController{ingr},
    		CreateConfigStore: func(c model.ConfigStoreController) model.ConfigStoreController {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top