Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for labelServiceName (0.22 sec)

  1. pkg/controlplane/reconcilers/helpers_test.go

    	slice := &discoveryv1.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Namespace: metav1.NamespaceDefault,
    			Name:      name,
    			Labels: map[string]string{
    				discoveryv1.LabelServiceName: name,
    			},
    		},
    		AddressType: discoveryv1.AddressTypeIPv4,
    		Endpoints:   make([]discoveryv1.Endpoint, len(ips)),
    		Ports:       make([]discoveryv1.EndpointPort, len(ports)),
    	}
    	ready := true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 27 12:46:23 UTC 2022
    - 4K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    type endpointSliceController struct {
    	endpointCache *endpointSliceCache
    	slices        kclient.Client[*v1.EndpointSlice]
    	c             *Controller
    }
    
    var (
    	endpointSliceRequirement = labelRequirement(mcs.LabelServiceName, selection.DoesNotExist, nil)
    	endpointSliceSelector    = klabels.NewSelector().Add(*endpointSliceRequirement)
    )
    
    func newEndpointSliceController(c *Controller) *endpointSliceController {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go

    	svc1Ips := []string{"128.0.0.1"}
    	portNames := []string{"tcp-port"}
    	createEndpoints(t, controller, svcName, ns, portNames, svc1Ips, nil, map[string]string{
    		mcs.LabelServiceName: svcName,
    	})
    	fx.AssertEmpty(t, time.Millisecond*50)
    
    	// Ensure that no endpoint is create
    	endpoints := GetEndpoints(svc, controller.Endpoints)
    	assert.Equal(t, len(endpoints), 0)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 18:50:38 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  4. pkg/controller/endpointslicemirroring/reconciler_test.go

    		}
    
    		serviceNameVal, ok := epSlice.Labels[discovery.LabelServiceName]
    		if !ok {
    			t.Errorf("Expected EndpointSlice to have %s label set", discovery.LabelServiceName)
    		}
    		if serviceNameVal != endpoints.Name {
    			t.Errorf("Expected EndpointSlice to have %s label set to %s, got %s", discovery.LabelServiceName, endpoints.Name, serviceNameVal)
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  5. pkg/controlplane/reconcilers/endpointsadapter.go

    	endpointSlice := &discovery.EndpointSlice{}
    	endpointSlice.Name = endpoints.Name
    	endpointSlice.Namespace = endpoints.Namespace
    	endpointSlice.Labels = map[string]string{discovery.LabelServiceName: endpoints.Name}
    
    	// TODO: Add support for dual stack here (and in the rest of
    	// EndpointsAdapter).
    	endpointSlice.AddressType = discovery.AddressTypeIPv4
    
    	if len(endpoints.Subsets) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 27 12:46:23 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  6. pkg/proxy/nftables/proxier_test.go

    	eps := &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      fmt.Sprintf("%s-%d", name, sliceNum),
    			Namespace: namespace,
    			Labels:    map[string]string{discovery.LabelServiceName: name},
    		},
    	}
    	epsFunc(eps)
    	return eps
    }
    
    func makeNSN(namespace, name string) types.NamespacedName {
    	return types.NamespacedName{Namespace: namespace, Name: name}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  7. pkg/proxy/endpointslicecache_test.go

    	endpoint2 := discovery.Endpoint{Addresses: []string{"10.0.1.1"}}
    
    	objMeta := metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		Labels:    map[string]string{discovery.LabelServiceName: "svc1"},
    	}
    
    	testCases := map[string]struct {
    		cache         *EndpointSliceCache
    		initialSlice  *discovery.EndpointSlice
    		updatedSlice  *discovery.EndpointSlice
    		expectChanged bool
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  8. pilot/pkg/xds/cds_test.go

    		},
    	}
    	endpoint := &discoveryv1.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      service.Name,
    			Namespace: service.Namespace,
    			Labels: map[string]string{
    				discoveryv1.LabelServiceName: service.Name,
    			},
    		},
    		Endpoints: []discoveryv1.Endpoint{{
    			Addresses: []string{pod.Status.PodIP},
    			TargetRef: &v1.ObjectReference{
    				Kind:      "Pod",
    				Namespace: pod.Namespace,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 01 02:06:39 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. pkg/proxy/winkernel/proxier_test.go

    	endpointSlice := &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      fmt.Sprintf("%s-1", svcPortName.Name),
    			Namespace: svcPortName.Namespace,
    			Labels:    map[string]string{discovery.LabelServiceName: svcPortName.Name},
    		},
    		Ports: []discovery.EndpointPort{{
    			Name:     &svcPortName.Port,
    			Port:     ptr.To[int32](80),
    			Protocol: ptr.To(v1.ProtocolTCP),
    		}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  10. pkg/controlplane/reconcilers/endpointsadapter_test.go

    	epSlice := &discovery.EndpointSlice{
    		ObjectMeta:  metav1.ObjectMeta{Name: name, Namespace: namespace},
    		AddressType: discovery.AddressTypeIPv4,
    	}
    	epSlice.Labels = map[string]string{discovery.LabelServiceName: name}
    	subset := corev1.EndpointSubset{}
    
    	for i, port := range ports {
    		endpointPort := corev1.EndpointPort{
    			Name:     fmt.Sprintf("port-%d", i),
    			Port:     int32(port),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top