Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for labelServiceName (0.47 sec)

  1. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    	// controller will never change LabelServiceName, users might. This check
    	// ensures that we handle changes to this label.
    	svcName := endpointSlice.Labels[discovery.LabelServiceName]
    	prevSvcName := prevEndpointSlice.Labels[discovery.LabelServiceName]
    	if svcName != prevSvcName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  2. pkg/controller/endpointslice/endpointslice_controller.go

    	// controller will never change LabelServiceName, users might. This check
    	// ensures that we handle changes to this label.
    	svcName := endpointSlice.Labels[discovery.LabelServiceName]
    	prevSvcName := prevEndpointSlice.Labels[discovery.LabelServiceName]
    	if svcName != prevSvcName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/number_generated_rules_test.go

    					t.Fatalf("expected Service Type %s, got %s", test.svcType, svcs[i].Spec.Type)
    				}
    				if eps[i].ObjectMeta.Labels[discovery.LabelServiceName] != svcs[i].Name {
    					t.Fatalf("endpoint slice reference %s instead of Service %s", eps[i].ObjectMeta.Labels[discovery.LabelServiceName], svcs[i].Name)
    				}
    				if len(eps[i].Endpoints) != test.epPerService {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. pkg/controller/endpointslice/endpointslice_controller_test.go

    			Labels: map[string]string{
    				discovery.LabelServiceName: serviceName,
    				discovery.LabelManagedBy:   controllerName,
    			},
    		},
    		AddressType: discovery.AddressTypeIPv4,
    	}, {
    		ObjectMeta: metav1.ObjectMeta{
    			Name:            "matching-2",
    			Namespace:       ns,
    			OwnerReferences: []metav1.OwnerReference{*ownerRef},
    			Labels: map[string]string{
    				discovery.LabelServiceName: serviceName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  5. pkg/proxy/endpointslicecache.go

    	var err error
    	serviceName, ok := endpointSlice.Labels[discovery.LabelServiceName]
    	if !ok || serviceName == "" {
    		err = fmt.Errorf("no %s label set on endpoint slice: %s", discovery.LabelServiceName, endpointSlice.Name)
    	} else if endpointSlice.Namespace == "" || endpointSlice.Name == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 11.7K bytes
    - Viewed (1)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top