Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for EndpointPort (0.42 sec)

  1. 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)
  2. pkg/proxy/endpointschangetracker_test.go

    			},
    		}}
    		eps.Ports = []discovery.EndpointPort{{
    			Name:     ptr.To(""),
    			Port:     ptr.To[int32](11),
    			Protocol: ptr.To(v1.ProtocolUDP),
    		}}
    	}
    	unnamedPortLocal := func(eps *discovery.EndpointSlice) {
    		eps.Endpoints = []discovery.Endpoint{{
    			Addresses: []string{"1.1.1.1"},
    			NodeName:  ptr.To(testHostname),
    		}}
    		eps.Ports = []discovery.EndpointPort{{
    			Name:     ptr.To(""),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. pkg/controller/endpoint/endpoints_controller_test.go

    			Name:            "foo",
    			Namespace:       ns,
    			ResourceVersion: "1",
    		},
    		Subsets: []v1.EndpointSubset{{
    			Addresses: []v1.EndpointAddress{{IP: "6.7.8.9", NodeName: &emptyNodeName}},
    			Ports:     []v1.EndpointPort{{Port: 1000}},
    		}},
    	})
    	endpoints.serviceStore.Add(&v1.Service{
    		ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: ns},
    		Spec:       v1.ServiceSpec{Ports: []v1.ServicePort{{Port: 80}}},
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			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",
    			EndpointPort: 9090,
    		},
    	}
    
    	wiReviews1 := &model.WorkloadInstance{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  7. pkg/controller/endpointslice/endpointslice_controller_test.go

    	slice := sliceList.Items[0]
    	assert.Regexp(t, "^"+serviceName, slice.Name)
    	assert.Equal(t, serviceName, slice.Labels[discovery.LabelServiceName])
    	assert.EqualValues(t, []discovery.EndpointPort{}, slice.Ports)
    	assert.EqualValues(t, []discovery.Endpoint{}, slice.Endpoints)
    	assert.NotEmpty(t, slice.Annotations["endpoints.kubernetes.io/last-change-trigger-time"])
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    		sort.Strings(out)
    		return out
    	}
    
    	sort.Slice(instances, func(i, j int) bool {
    		if instances[i].Service.Hostname == instances[j].Service.Hostname {
    			if instances[i].Endpoint.EndpointPort == instances[j].Endpoint.EndpointPort {
    				if instances[i].Endpoint.Address == instances[j].Endpoint.Address {
    					if len(instances[i].Endpoint.Labels) == len(instances[j].Endpoint.Labels) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  9. pkg/proxy/nftables/proxier.go

    // endpoint. This is something like
    // "HASH-namespace/serviceName/protocol/portName__endpointIP/endpointport", e.g.,
    // "5OJB2KTY-ns1/svc1/tcp/p80__10.180.0.1/80".
    func servicePortEndpointChainNameBase(servicePortName *proxy.ServicePortName, protocol, endpoint string) string {
    	// As above in servicePortChainNameBase: Namespace, Service, Port, Protocol, and
    	// EndpointPort are all safe to copy into the chain name directly. But if
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  10. pilot/pkg/model/push_context_test.go

    					{Cluster: "Kubernets", Provider: provider.External}: {
    						&IstioEndpoint{
    							Address:         "1.1.1.1",
    							EndpointPort:    7000,
    							ServicePortName: "uds",
    						},
    						&IstioEndpoint{
    							Address:         "1.1.1.2",
    							EndpointPort:    8000,
    							ServicePortName: "uds",
    						},
    					},
    				},
    			},
    		},
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
Back to top