Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for EndpointSubset (0.39 sec)

  1. 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)
  2. 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)
  3. 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)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go

    				ObjectMeta: metav1.ObjectMeta{
    					Name: "endpoints1",
    				},
    				Subsets: []corev1.EndpointSubset{
    					{
    						Addresses: []corev1.EndpointAddress{{IP: "127.0.0.0"}},
    					},
    				},
    			}
    		}
    	} else {
    		object = nil
    		oldObject = &corev1.Endpoints{
    			Subsets: []corev1.EndpointSubset{
    				{
    					Addresses: []corev1.EndpointAddress{{IP: "127.0.0.0"}},
    				},
    			},
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 40.4K bytes
    - Viewed (0)
  5. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    	// than necessary.
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	// maxEndpointsPerSubset references the maximum number of endpoints that
    	// should be added to an EndpointSlice for an EndpointSubset.
    	maxEndpointsPerSubset int32
    
    	// workerLoopPeriod is the time between worker runs. The workers process the
    	// queue of changes to Endpoints resources.
    	workerLoopPeriod time.Duration
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
Back to top