Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for EndpointSubset (0.29 sec)

  1. staging/src/k8s.io/client-go/applyconfigurations/core/v1/endpointsubset.go

    	Ports             []EndpointPortApplyConfiguration    `json:"ports,omitempty"`
    }
    
    // EndpointSubsetApplyConfiguration constructs an declarative configuration of the EndpointSubset type for use with
    // apply.
    func EndpointSubset() *EndpointSubsetApplyConfiguration {
    	return &EndpointSubsetApplyConfiguration{}
    }
    
    // WithAddresses adds the given value to the Addresses field in the declarative configuration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 04 18:31:34 UTC 2021
    - 3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. pkg/api/v1/endpoints/util.go

    )
    
    // RepackSubsets takes a slice of EndpointSubset objects, expands it to the full
    // representation, and then repacks that into the canonical layout.  This
    // ensures that code which operates on these objects can rely on the common
    // form for things like comparison.  The result is a newly allocated slice.
    func RepackSubsets(subsets []v1.EndpointSubset) []v1.EndpointSubset {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 07 07:01:25 UTC 2018
    - 8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/registry/core/endpoint/storage/storage_test.go

    	return rest, server
    }
    
    func validNewEndpoints() *api.Endpoints {
    	return &api.Endpoints{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "foo",
    			Namespace: metav1.NamespaceDefault,
    		},
    		Subsets: []api.EndpointSubset{{
    			Addresses: []api.EndpointAddress{{IP: "1.2.3.4"}},
    			Ports:     []api.EndpointPort{{Port: 80, Protocol: "TCP"}},
    		}},
    	}
    }
    
    func TestCreate(t *testing.T) {
    	storage, server := newStorage(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 12 20:55:35 UTC 2019
    - 3.8K bytes
    - Viewed (0)
  10. pkg/controller/endpointslicemirroring/events.go

    	// InvalidIPAddress indicates that an IP address found in an Endpoints
    	// resource is invalid.
    	InvalidIPAddress = "InvalidIPAddress"
    	// TooManyAddressesToMirror indicates that some addresses were not mirrored
    	// due to an EndpointSubset containing more addresses to mirror than
    	// MaxEndpointsPerSubset allows.
    	TooManyAddressesToMirror = "TooManyAddressesToMirror"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 06 19:43:35 UTC 2020
    - 1.3K bytes
    - Viewed (0)
Back to top