- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for EndpointPort (0.42 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pilot/pkg/model/push_context_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0)