Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for EndpointSubset (0.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. pkg/apis/core/v1/zz_generated.conversion.go

    	}
    	if err := s.AddGeneratedConversionFunc((*v1.EndpointSubset)(nil), (*core.EndpointSubset)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_EndpointSubset_To_core_EndpointSubset(a.(*v1.EndpointSubset), b.(*core.EndpointSubset), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*core.EndpointSubset)(nil), (*v1.EndpointSubset)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 472.1K bytes
    - Viewed (0)
  7. 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)
  8. pkg/apis/core/zz_generated.deepcopy.go

    		}
    	}
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSubset.
    func (in *EndpointSubset) DeepCopy() *EndpointSubset {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointSubset)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 181.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/core/v1/zz_generated.deepcopy.go

    		}
    	}
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSubset.
    func (in *EndpointSubset) DeepCopy() *EndpointSubset {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointSubset)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 181.9K bytes
    - Viewed (0)
  10. pkg/apis/core/validation/validation_test.go

    				Subsets: []core.EndpointSubset{{
    					Addresses: []core.EndpointAddress{{IP: "10.10.1.1"}},
    					Ports:     []core.EndpointPort{{Port: 8675, Protocol: "TCP"}},
    				}},
    			},
    		},
    		"valid appProtocol": {
    			endpoints: core.Endpoints{
    				ObjectMeta: metav1.ObjectMeta{Name: "mysvc", Namespace: "namespace"},
    				Subsets: []core.EndpointSubset{{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
Back to top