- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 124 for EndpointPort (0.4 sec)
-
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) -
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/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) -
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) -
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) -
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) -
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) -
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) -
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)