- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for addService (0.45 sec)
-
pilot/pkg/serviceregistry/memory/discovery.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
s.assertEvent(t, s.wleXdsName("name3")) // Non-existent IP should have no response s.assertWorkloads(t, s.addrXdsName("10.0.0.1"), workloadapi.WorkloadStatus_HEALTHY) s.clearEvents() s.addService(t, "svc1", map[string]string{}, // labels map[string]string{}, // annotations []int32{80}, map[string]string{"app": "a"}, // selector "10.0.0.1", ) // Service shouldn't change workload list
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
s.addWaypoint(t, "10.0.0.10", "test-wp", c.trafficType, true) s.addPods(t, "127.0.0.1", "pod1", "sa1", map[string]string{"app": "a"}, nil, true, corev1.PodRunning) s.assertEvent(t, s.podXdsName("pod1")) s.addService(t, "svc1", map[string]string{}, map[string]string{}, []int32{80}, map[string]string{"app": "a"}, "10.0.0.1") s.assertEvent(t, s.svcXdsName("svc1"), s.podXdsName("pod1"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
registries[0].DiscoveryController.(*memory.ServiceDiscovery).AddService(mock.HelloService) registries[1].DiscoveryController.(*memory.ServiceDiscovery).AddService(mock.HelloService) ctrl.DeleteRegistry(registries[1].Cluster(), registries[1].Provider()) ctrl.UnRegisterHandlersForCluster(registries[1].Cluster()) registries[0].DiscoveryController.(*memory.ServiceDiscovery).AddService(mock.HelloService) if registry1Counter.Load() != 3 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
{ Name: "http", Port: 80, Protocol: protocol.HTTP, }, } svc := &model.Service{ Ports: ports, Hostname: host.Name("test1"), } s.MemRegistry.AddService(svc) if _, err := ads.Wait(time.Second*10, watchAll...); err != nil { t.Fatal(err) } i := &model.ServiceInstance{ Service: svc, ServicePort: svc.Ports[0], Endpoint: &model.IstioEndpoint{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
if err != nil { t.Fatal(err) } _ = s.Send(&discovery.DiscoveryRequest{}) }) } }) } func addIstiod(sd *memory.ServiceDiscovery, xdsPort int) { sd.AddService(&model.Service{ Attributes: model.ServiceAttributes{ Name: "istiod", Namespace: "istio-system", }, Hostname: host.Name(testSvcHost), DefaultAddress: "127.0.1.12",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
hostname := host.Name(name) configsUpdated.Insert(model.ConfigKey{ Kind: kind.ServiceEntry, Name: string(hostname), Namespace: ns, }) s.MemRegistry.AddService(&model.Service{ Hostname: hostname, DefaultAddress: "10.11.0.1", Ports: []*model.Port{ { Name: "http-main", Port: 2080, Protocol: protocol.HTTP, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pkg/proxy/servicechangetracker_test.go
}, } } func makeServiceMap(fake *FakeProxier, allServices ...*v1.Service) { for i := range allServices { fake.addService(allServices[i]) } } func (proxier *FakeProxier) addService(service *v1.Service) { proxier.serviceChanges.Update(nil, service) } func (proxier *FakeProxier) updateService(oldService *v1.Service, service *v1.Service) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.7K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
if httpRoute.GetMirror() != nil { addService(host.Name(httpRoute.GetMirror().GetHost())) } for _, mirror := range httpRoute.GetMirrors() { if mirror.GetDestination() != nil { addService(host.Name(mirror.GetDestination().GetHost())) } } for _, route := range httpRoute.GetRoute() { if route.GetDestination() != nil { addService(host.Name(route.GetDestination().GetHost())) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters_test.go
// - 1 IP gateway for network3 // - 0 gateways for network4 ds := environment(t) origServices := ds.Env().Services() origGateways := ds.Env().NetworkGateways() ds.MemRegistry.AddService(&model.Service{ Hostname: "istio-ingressgateway.istio-system.svc.cluster.local", Attributes: model.ServiceAttributes{ ClusterExternalAddresses: &model.AddressMap{ Addresses: map[cluster.ID][]string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0)