- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 124 for EndpointPort (0.37 sec)
-
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/controlplane/reconcilers/endpointsadapter.go
endpointSlice.AddressType = discovery.AddressTypeIPv4 if len(endpoints.Subsets) > 0 { subset := endpoints.Subsets[0] for i := range subset.Ports { endpointSlice.Ports = append(endpointSlice.Ports, discovery.EndpointPort{ Port: &subset.Ports[i].Port, Name: &subset.Ports[i].Name, Protocol: &subset.Ports[i].Protocol, }) } if allAddressesIPv6(append(subset.Addresses, subset.NotReadyAddresses...)) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:23 UTC 2022 - 7.8K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
Addresses: []string{pod.Status.PodIP}, TargetRef: &v1.ObjectReference{ Kind: "Pod", Namespace: pod.Namespace, Name: pod.Name, }, }}, Ports: []discoveryv1.EndpointPort{{Name: ptr.Of("http"), Port: ptr.Of(int32(80))}}, } dr := config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.DestinationRule, Name: "dr", Namespace: "test", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.StorageVersionAPI, true) reconciler.UpdateLease(tt.reconcilerConfig.serverId, tt.reconcilerConfig.publicIP, []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}) } req, err := http.NewRequest(http.MethodGet, server.URL+tt.requestPath, nil) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion.go
discoverabilityPolicy = model.DiscoverableFromSameCluster } for _, portEntry := range svc.Ports { out = append(out, &model.IstioEndpoint{ Address: svc.Attributes.ExternalName, EndpointPort: uint32(portEntry.Port), ServicePortName: portEntry.Name, Labels: svc.Attributes.Labels, DiscoverabilityPolicy: discoverabilityPolicy, }) } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
for i := 0; i < numOfEndpoints; i++ { addr := fmt.Sprintf("10.%d.0.%d", networkNum, i+1) istioEndpoints[i] = &model.IstioEndpoint{ Address: addr, EndpointPort: 2080, ServicePortName: "http-main", Network: networkID, Locality: model.Locality{ Label: "az", ClusterID: clusterID, }, Labels: svcLabels,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K 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) -
pilot/pkg/serviceregistry/memory/discovery.go
instance := &model.ServiceInstance{ Service: &model.Service{Hostname: service}, Endpoint: &model.IstioEndpoint{ Address: address, ServicePortName: servicePortName, EndpointPort: uint32(port), }, ServicePort: &model.Port{ Name: servicePortName, Port: servicePort, Protocol: protocol.HTTP, }, } sd.AddInstance(instance) return instance }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
// and delete. func (r *reconciler) reconcileByPortMapping( endpoints *corev1.Endpoints, existingSlices []*discovery.EndpointSlice, desiredSet endpointsliceutil.EndpointSet, endpointPorts []discovery.EndpointPort, addressType discovery.AddressType, ) (slicesByAction, totalsByAction) { slices := slicesByAction{} totals := totalsByAction{} // If no endpoints are desired, mark existing slices for deletion and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0)