Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for WantGetProxyServiceTargets (0.42 sec)

  1. pilot/pkg/serviceregistry/memory/discovery.go

    // 'in' services.
    func (sd *ServiceDiscovery) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget {
    	sd.mutex.Lock()
    	defer sd.mutex.Unlock()
    	if sd.WantGetProxyServiceTargets != nil {
    		return sd.WantGetProxyServiceTargets
    	}
    	out := make([]model.ServiceTarget, 0)
    	for _, ip := range node.IPAddresses {
    		si, found := sd.ip2instance[ip]
    		if found {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 23:10:01 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. tests/fuzz/pilot_model_fuzzer.go

    	if err != nil {
    		return 0
    	}
    
    	env := &model.Environment{}
    	store := model.NewFakeStore()
    
    	env.ConfigStore = store
    	sd := memory.NewServiceDiscovery(services...)
    	sd.WantGetProxyServiceTargets = slices.Map(serviceInstances, model.ServiceInstanceToTarget)
    	env.ServiceDiscovery = sd
    
    	env.Watcher = mesh.NewFixedWatcher(m)
    	env.EndpointIndex = model.NewEndpointIndex(model.DisabledCache{})
    	env.Init()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 18:13:06 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  3. pilot/pkg/model/context_test.go

    		},
    		{
    			Service: &model.Service{
    				CreationTime: tnow,
    				Hostname:     host.Name("test2.com"),
    			},
    		},
    	}
    
    	serviceDiscovery := memory.NewServiceDiscovery()
    	serviceDiscovery.WantGetProxyServiceTargets = instances
    
    	env := &model.Environment{
    		ServiceDiscovery: serviceDiscovery,
    	}
    
    	proxy := &model.Proxy{}
    	proxy.SetServiceTargets(env)
    
    	assert.Equal(t, len(proxy.ServiceTargets), 3)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 05 23:51:52 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster_builder_test.go

    				}
    			}
    
    			cg := NewConfigGenTest(t, TestOptions{
    				ConfigPointers: []*config.Config{cfg},
    				Services:       []*model.Service{tc.service},
    			})
    
    			cg.MemRegistry.WantGetProxyServiceTargets = targets
    			proxy := cg.SetupProxy(nil)
    			cb := NewClusterBuilder(proxy, &model.PushRequest{Push: cg.PushContext()}, nil)
    			ec := newClusterWrapper(tc.cluster)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/gateway_test.go

    			Configs = append(Configs, tt.gateways...)
    			Configs = append(Configs, tt.virtualServices...)
    			cg := NewConfigGenTest(t, TestOptions{
    				Configs: Configs,
    			})
    			cg.MemRegistry.WantGetProxyServiceTargets = tt.node.ServiceTargets
    			proxy := cg.SetupProxy(&proxyGateway)
    			if tt.node.Metadata != nil {
    				proxy.Metadata = tt.node.Metadata
    			} else {
    				proxy.Metadata = &proxyGatewayMetadata
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 144K bytes
    - Viewed (0)
Back to top