- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WantGetProxyServiceTargets (0.44 sec)
-
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) -
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) -
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) -
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) -
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)