Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 77 for EndpointPort (0.18 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. pilot/pkg/serviceregistry/serviceregistry_test.go

    	ports []v1.EndpointPort, ips []string, addrType discovery.AddressType,
    ) {
    	esps := make([]discovery.EndpointPort, 0)
    	for _, name := range ports {
    		n := name // Create a stable reference to take the pointer from
    		esps = append(esps, discovery.EndpointPort{
    			Name:        &n.Name,
    			Protocol:    &n.Protocol,
    			Port:        &n.Port,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  5. pkg/controlplane/reconcilers/endpointsadapter_test.go

    	for i, port := range ports {
    		endpointPort := corev1.EndpointPort{
    			Name:     fmt.Sprintf("port-%d", i),
    			Port:     int32(port),
    			Protocol: corev1.ProtocolTCP,
    		}
    		subset.Ports = append(subset.Ports, endpointPort)
    		epSlice.Ports = append(epSlice.Ports, discovery.EndpointPort{
    			Name:     &endpointPort.Name,
    			Port:     &endpointPort.Port,
    			Protocol: &endpointPort.Protocol,
    		})
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go

    		Labels:                b.labels,
    		ServiceAccount:        b.serviceAccount,
    		Locality:              b.locality,
    		TLSMode:               b.tlsMode,
    		Address:               endpointAddress,
    		EndpointPort:          uint32(endpointPort),
    		ServicePortName:       svcPortName,
    		Network:               networkID,
    		WorkloadName:          b.workloadName,
    		Namespace:             b.namespace,
    		HostName:              b.hostname,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. pilot/pkg/xds/eds_test.go

    				[]*model.IstioEndpoint{
    					{
    						Address:         "10.0.0.53",
    						EndpointPort:    53,
    						ServicePortName: "tcp-dns",
    						HealthStatus:    model.UnHealthy,
    					},
    					{
    						Address:         "10.0.0.54",
    						EndpointPort:    53,
    						ServicePortName: "tcp-dns",
    						HealthStatus:    model.UnHealthy,
    					},
    				})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 20:58:47 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  8. pkg/proxy/winkernel/proxier_test.go

    			eps.AddressType = discovery.AddressTypeIPv4
    			eps.Endpoints = []discovery.Endpoint{{
    				Addresses: []string{epIpAddressRemote},
    			}}
    			eps.Ports = []discovery.EndpointPort{{
    				Name:     ptr.To(svcPortName.Port),
    				Port:     ptr.To(int32(svcPort)),
    				Protocol: ptr.To(v1.ProtocolTCP),
    			}}
    		}),
    	)
    
    	proxier.setInitialized(true)
    	proxier.syncProxyRules()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/discovery/v1beta1/generated.pb.go

    var xxx_messageInfo_EndpointHints proto.InternalMessageInfo
    
    func (m *EndpointPort) Reset()      { *m = EndpointPort{} }
    func (*EndpointPort) ProtoMessage() {}
    func (*EndpointPort) Descriptor() ([]byte, []int) {
    	return fileDescriptor_6555bad15de200e0, []int{3}
    }
    func (m *EndpointPort) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *EndpointPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 54.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/discovery/v1/generated.pb.go

    var xxx_messageInfo_EndpointHints proto.InternalMessageInfo
    
    func (m *EndpointPort) Reset()      { *m = EndpointPort{} }
    func (*EndpointPort) ProtoMessage() {}
    func (*EndpointPort) Descriptor() ([]byte, []int) {
    	return fileDescriptor_2237b452324cf77e, []int{3}
    }
    func (m *EndpointPort) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *EndpointPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 55.6K bytes
    - Viewed (0)
Back to top