- Sort Score
- Result 10 results
- Languages All
Results 11 - 13 of 13 for EndpointPort (0.7 sec)
-
pilot/pkg/networking/core/sidecar_simulation_test.go
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) { proxy := &model.Proxy{ IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{}, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pkg/apis/core/v1/defaults_test.go
} } } func TestSetDefaultEndpointsProtocol(t *testing.T) { in := &v1.Endpoints{Subsets: []v1.EndpointSubset{ {Ports: []v1.EndpointPort{{}, {Protocol: "UDP"}, {}}}, }} obj := roundTrip(t, runtime.Object(in)) out := obj.(*v1.Endpoints) for i := range out.Subsets { for j := range out.Subsets[i].Ports {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
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)) xdstest.ValidateListeners(t, listeners)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0)