Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 124 for EndpointPort (0.37 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top