- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for EndpointPort (0.19 sec)
-
pkg/controlplane/reconcilers/instancecount_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
ip: "1.2.3.4", endpointPorts: []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}, initialState: []runtime.Object{ makeEndpoints("foo", []string{"1.2.3.4"}, []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}), }, expectCreate: []runtime.Object{ makeEndpointSlice("foo", []string{"1.2.3.4"}, []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
pkg/api/v1/endpoints/util_test.go
}, { Addresses: []v1.EndpointAddress{{IP: "5.6.7.8", TargetRef: podRef("uid-1")}}, Ports: []v1.EndpointPort{{Port: 111}}, }, { Addresses: []v1.EndpointAddress{{IP: "1.2.3.4", TargetRef: podRef("uid-1")}}, Ports: []v1.EndpointPort{{Port: 111}}, }, { Addresses: []v1.EndpointAddress{{IP: "1.2.3.4"}}, Ports: []v1.EndpointPort{{Port: 111}}, }},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 27 01:24:22 UTC 2023 - 16.6K bytes - Viewed (0) -
pkg/apis/discovery/validation/validation_test.go
} // Test helpers func protocolPtr(protocol api.Protocol) *api.Protocol { return &protocol } func generatePorts(n int) []discovery.EndpointPort { ports := []discovery.EndpointPort{} for i := 0; i < n; i++ { ports = append(ports, discovery.EndpointPort{ Name: utilpointer.String(fmt.Sprintf("http-%d", i)), Protocol: protocolPtr(api.ProtocolTCP), }) } return ports }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 10:48:05 UTC 2023 - 23.9K bytes - Viewed (0) -
pkg/apis/discovery/v1/zz_generated.conversion.go
} if err := s.AddGeneratedConversionFunc((*v1.EndpointPort)(nil), (*discovery.EndpointPort)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1_EndpointPort_To_discovery_EndpointPort(a.(*v1.EndpointPort), b.(*discovery.EndpointPort), scope) }); err != nil { return err } if err := s.AddGeneratedConversionFunc((*discovery.EndpointPort)(nil), (*v1.EndpointPort)(nil), func(a, b interface{}, scope conversion.Scope) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 14.4K bytes - Viewed (0) -
pkg/apis/discovery/v1beta1/zz_generated.conversion.go
} if err := s.AddGeneratedConversionFunc((*v1beta1.EndpointPort)(nil), (*discovery.EndpointPort)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1beta1_EndpointPort_To_discovery_EndpointPort(a.(*v1beta1.EndpointPort), b.(*discovery.EndpointPort), scope) }); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 15.3K bytes - Viewed (0) -
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) -
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) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
expectedNumActions int expectedNumSlices int }{{ testName: "Endpoints with no addresses", service: &v1.Service{}, endpoints: &v1.Endpoints{ Subsets: []v1.EndpointSubset{{ Ports: []v1.EndpointPort{{Port: 80}}, }}, }, endpointSlices: []*discovery.EndpointSlice{}, expectedNumActions: 0, expectedNumSlices: 0, }, { testName: "Endpoints with skip label true",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K bytes - Viewed (0) -
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)