Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for EndpointSubset (0.3 sec)

  1. pkg/api/v1/endpoints/util_test.go

    	testCases := []struct {
    		name   string
    		given  []v1.EndpointSubset
    		expect []v1.EndpointSubset
    	}{
    		{
    			name:   "empty everything",
    			given:  []v1.EndpointSubset{{Addresses: []v1.EndpointAddress{}, Ports: []v1.EndpointPort{}}},
    			expect: []v1.EndpointSubset{},
    		}, {
    			name:   "empty addresses",
    			given:  []v1.EndpointSubset{{Addresses: []v1.EndpointAddress{}, Ports: []v1.EndpointPort{{Port: 111}}}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 27 01:24:22 UTC 2023
    - 16.6K bytes
    - Viewed (0)
  2. pkg/controller/endpoint/endpoints_controller_test.go

    	tests := []struct {
    		name     string
    		subsets1 []v1.EndpointSubset
    		subsets2 []v1.EndpointSubset
    		expected bool
    	}{
    		{
    			name:     "Subsets removed",
    			subsets1: []v1.EndpointSubset{*es1, *es2},
    			subsets2: []v1.EndpointSubset{*es1},
    			expected: false,
    		},
    		{
    			name:     "Ready Pod IP changed",
    			subsets1: []v1.EndpointSubset{*es1, *es2},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  3. pkg/controller/endpointslicemirroring/reconciler_test.go

    	}{{
    		testName:               "Endpoints with no subsets",
    		subsets:                []corev1.EndpointSubset{},
    		existingEndpointSlices: []*discovery.EndpointSlice{},
    		expectedNumSlices:      0,
    		expectedClientActions:  0,
    		expectedMetrics:        &expectedMetrics{},
    	}, {
    		testName: "Endpoints with no addresses",
    		subsets: []corev1.EndpointSubset{{
    			Ports: []corev1.EndpointPort{{
    				Name:     "http",
    				Port:     80,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  4. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go

    		expectedNumActions int
    		expectedNumSlices  int
    	}{{
    		testName: "Endpoints with no addresses",
    		service:  &v1.Service{},
    		endpoints: &v1.Endpoints{
    			Subsets: []v1.EndpointSubset{{
    				Ports: []v1.EndpointPort{{Port: 80}},
    			}},
    		},
    		endpointSlices:     []*discovery.EndpointSlice{},
    		expectedNumActions: 0,
    		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)
  5. pkg/controller/endpointslicemirroring/reconciler.go

    	eventRecorder record.EventRecorder
    
    	// maxEndpointsPerSubset references the maximum number of endpoints that
    	// should be added to an EndpointSlice for an EndpointSubset. This allows
    	// for a simple 1:1 mapping between EndpointSubset and EndpointSlice.
    	maxEndpointsPerSubset int32
    
    	// metricsCache tracks values for total numbers of desired endpoints as well
    	// as the efficiency of EndpointSlice endpoints distribution
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/proxy/proxy_test.go

    			}
    			ports = append(ports, v1.EndpointPort{Name: p.Name, Port: p.TargetPort.IntVal})
    		}
    
    		return []*v1.Endpoints{{
    			ObjectMeta: metav1.ObjectMeta{Namespace: svc.Namespace, Name: svc.Name},
    			Subsets: []v1.EndpointSubset{{
    				Addresses: []v1.EndpointAddress{{Hostname: "dummy-host", IP: "127.0.0.1"}},
    				Ports:     ports,
    			}},
    		}}
    	}
    
    	type expectation struct {
    		url   string
    		error bool
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 07:16:27 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  7. pkg/controller/endpoint/endpoints_controller.go

    // addEndpointSubset add the endpoints addresses and ports to the EndpointSubset.
    // The addresses are added to the corresponding field, ready or not ready, depending
    // on the pod status and the Service PublishNotReadyAddresses field value.
    // The pod passed to this function must have already been filtered through ShouldPodBeInEndpoints.
    func addEndpointSubset(logger klog.Logger, subsets []v1.EndpointSubset, pod *v1.Pod, epa v1.EndpointAddress,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  8. pkg/controlplane/reconcilers/instancecount.go

    	// EndpointSlices. This may change in the future.
    	skipMirrorChanged := setSkipMirrorTrue(e)
    
    	if errors.IsNotFound(err) {
    		// Simply create non-existing endpoints for the service.
    		e.Subsets = []corev1.EndpointSubset{{
    			Addresses: []corev1.EndpointAddress{{IP: ip.String()}},
    			Ports:     endpointPorts,
    		}}
    		_, err = r.epAdapter.Create(metav1.NamespaceDefault, e)
    		return err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/cli-runtime/pkg/printers/json_test.go

    		"pod":             &v1.Pod{ObjectMeta: om("pod")},
    		"emptyPodList":    &v1.PodList{},
    		"nonEmptyPodList": &v1.PodList{Items: []v1.Pod{{}}},
    		"endpoints": &v1.Endpoints{
    			Subsets: []v1.EndpointSubset{{
    				Addresses: []v1.EndpointAddress{{IP: "127.0.0.1"}, {IP: "localhost"}},
    				Ports:     []v1.EndpointPort{{Port: 8080}},
    			}}},
    	}
    
    	// Test PrintObj() success.
    	for pName, p := range genericPrinters {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 4K bytes
    - Viewed (0)
  10. pkg/controlplane/reconcilers/endpointsadapter_test.go

    		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),
    			Protocol: corev1.ProtocolTCP,
    		}
    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