Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 124 for EndpointPort (0.4 sec)

  1. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go

    			servers: []serverInfo{{
    				existingIP:     "4.3.2.1",
    				id:             "server-1",
    				ports:          []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}},
    				expectEndpoint: "4.3.2.1:8080",
    			}, {
    				existingIP:     "1.2.3.4",
    				id:             "server-2",
    				ports:          []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}},
    				expectEndpoint: "1.2.3.4:8080",
    			}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. pkg/controller/endpointslicemirroring/reconciler_test.go

    	}
    }
    
    func portsMatch(epPorts []corev1.EndpointPort, epsPorts []discovery.EndpointPort) bool {
    	if len(epPorts) != len(epsPorts) {
    		return false
    	}
    
    	portsToBeMatched := map[int32]corev1.EndpointPort{}
    
    	for _, epPort := range epPorts {
    		portsToBeMatched[epPort.Port] = epPort
    	}
    
    	for _, epsPort := range epsPorts {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  3. pkg/proxy/endpointslicecache_test.go

    				Ports:      []discovery.EndpointPort{port443, port80},
    			},
    			updatedSlice: &discovery.EndpointSlice{
    				ObjectMeta: objMeta,
    				Ports:      []discovery.EndpointPort{port443},
    			},
    			expectChanged: true,
    		},
    		"port added": {
    			cache: NewEndpointSliceCache("", v1.IPv4Protocol, nil, nil),
    			initialSlice: &discovery.EndpointSlice{
    				ObjectMeta: objMeta,
    				Ports:      []discovery.EndpointPort{port443},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. pkg/apis/discovery/v1beta1/defaults_test.go

    		expected *discovery.EndpointSlice
    	}{
    		"should set appropriate defaults": {
    			original: &discovery.EndpointSlice{Ports: []discovery.EndpointPort{{
    				Port: utilpointer.Int32(80),
    			}}},
    			expected: &discovery.EndpointSlice{
    				Ports: []discovery.EndpointPort{{
    					Name:     &emptyStr,
    					Protocol: &protoTCP,
    					Port:     utilpointer.Int32(80),
    				}},
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 08 12:14:37 UTC 2023
    - 2K bytes
    - Viewed (0)
  5. pkg/apis/discovery/fuzzer/fuzzer.go

    			obj.AddressType = addressTypes[c.Rand.Intn(len(addressTypes))]
    
    			for i, endpointPort := range obj.Ports {
    				if endpointPort.Name == nil {
    					emptyStr := ""
    					obj.Ports[i].Name = &emptyStr
    				}
    
    				if endpointPort.Protocol == nil {
    					protos := []api.Protocol{api.ProtocolTCP, api.ProtocolUDP, api.ProtocolSCTP}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 12 17:03:53 UTC 2019
    - 1.6K bytes
    - Viewed (0)
  6. pkg/api/v1/endpoints/util.go

    	// offer it.
    	allAddrs := map[addressKey]*v1.EndpointAddress{}
    	portToAddrReadyMap := map[v1.EndpointPort]addressSet{}
    	for i := range subsets {
    		if len(subsets[i].Ports) == 0 {
    			// Don't discard endpoints with no ports defined, use a sentinel.
    			mapAddressesByPort(&subsets[i], v1.EndpointPort{Port: -1}, allAddrs, portToAddrReadyMap)
    		} else {
    			for _, port := range subsets[i].Ports {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 07 07:01:25 UTC 2018
    - 8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/discovery/v1/zz_generated.deepcopy.go

    		*out = new(string)
    		**out = **in
    	}
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointPort.
    func (in *EndpointPort) DeepCopy() *EndpointPort {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointPort)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/discovery/v1beta1/zz_generated.deepcopy.go

    		*out = new(string)
    		**out = **in
    	}
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointPort.
    func (in *EndpointPort) DeepCopy() *EndpointPort {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointPort)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.5K bytes
    - Viewed (0)
  9. pilot/pkg/model/validation_test.go

    	},
    }
    
    func TestServiceInstanceValidate(t *testing.T) {
    	endpointWithLabels := func(lbls labels.Instance) *IstioEndpoint {
    		return &IstioEndpoint{
    			Address:      "192.168.1.1",
    			EndpointPort: 10001,
    			Labels:       lbls,
    		}
    	}
    
    	cases := []struct {
    		name     string
    		instance *ServiceInstance
    		valid    bool
    	}{
    		{
    			name: "nil service",
    			instance: &ServiceInstance{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 23 19:35:35 UTC 2023
    - 4K bytes
    - Viewed (0)
  10. pkg/apis/discovery/zz_generated.deepcopy.go

    		*out = new(string)
    		**out = **in
    	}
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointPort.
    func (in *EndpointPort) DeepCopy() *EndpointPort {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointPort)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.6K bytes
    - Viewed (0)
Back to top