Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 13 of 13 for EndpointPort (0.7 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top