Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for labelServiceName (0.26 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/endpointslicemirroring/endpointslicemirroring_controller_test.go

    			}},
    		},
    		endpointSlices: []*discovery.EndpointSlice{{
    			ObjectMeta: metav1.ObjectMeta{
    				Name: endpointsName + "-1",
    				Labels: map[string]string{
    					discovery.LabelServiceName: endpointsName,
    					discovery.LabelManagedBy:   controllerName,
    				},
    			},
    		}},
    		expectedNumActions: 1,
    		expectedNumSlices:  0,
    	}, {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 12:57:29 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  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. 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)
  8. 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)
  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