- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for istioEndpoints (0.21 sec)
-
pilot/pkg/serviceregistry/serviceentry/controller_test.go
svcs := convertServices(*cfg) if len(svcs) != len(expected) { t.Fatalf("got more services than expected: %v vs %v", len(svcs), len(expected)) } expe := [][]*model.IstioEndpoint{} for _, o := range expected { res := []*model.IstioEndpoint{} for _, i := range o { res = append(res, i.Endpoint) } expe = append(expe, res) } // The system is eventually consistent, so add some retries
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Name: "ratings-1", Namespace: "bookinfo-ratings", Endpoint: &model.IstioEndpoint{ Labels: labels.Instance{"app": "ratings"}, Address: "2.2.2.21", EndpointPort: 8080, }, } wiDetails1 := &model.WorkloadInstance{ Name: "details-1", Namespace: "bookinfo-details", Endpoint: &model.IstioEndpoint{ Labels: labels.Instance{"app": "details"}, Address: "2.2.2.21",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
instancesByPort map[string]map[int][]*IstioEndpoint } func newServiceIndex() serviceIndex { return serviceIndex{ public: []*Service{}, privateByNamespace: map[string][]*Service{}, exportedToNamespace: map[string][]*Service{}, HostnameAndNamespace: map[host.Name]map[string]*Service{}, instancesByPort: map[string]map[int][]*IstioEndpoint{}, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
retry.UntilSuccessOrFail(t, func() error { endpoints := GetEndpointsForPort(svc, ei, port) if endpoints == nil { endpoints = []*model.IstioEndpoint{} // To simplify tests a bit } got := slices.Map(endpoints, func(e *model.IstioEndpoint) EndpointResponse { return EndpointResponse{ Address: e.Address, Port: e.EndpointPort, } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
Configs: filterTestConfigs, } cg := NewConfigGenTest(t, o) p := getProxy() for _, s := range o.Services { i := &model.ServiceInstance{ Service: s, Endpoint: &model.IstioEndpoint{ Address: "1.1.1.1", EndpointPort: uint32(s.Ports[0].Port), }, ServicePort: s.Ports[0], } cg.MemRegistry.AddInstance(i) } listeners := cg.Listeners(cg.SetupProxy(p))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
for _, p := range svc.Ports { if p.Port != servicePort { continue } ret = append(ret, &model.ServiceInstance{ Service: svc, ServicePort: p, Endpoint: &model.IstioEndpoint{ Address: proxy.IPAddresses[0], ServicePortName: p.Name, EndpointPort: uint32(targetPort), }, }) } return ret } func TestInboundClusters(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0)