Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 407 for endpoints1 (0.17 sec)

  1. pkg/controlplane/reconcilers/endpointsadapter_test.go

    			expectedResult: endpoints2,
    			expectUpdate:   []runtime.Object{endpoints2, epSlice2},
    			initialState:   []runtime.Object{endpoints2, epSlice1},
    			namespaceParam: "testing",
    			endpointsParam: endpoints2,
    		},
    		"endpointslice-correct-endpoints-wrong": {
    			expectedError:  nil,
    			expectedResult: endpoints2,
    			expectUpdate:   []runtime.Object{endpoints2},
    			initialState:   []runtime.Object{endpoints1, epSlice2},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. pkg/proxy/config/config_test.go

    		Endpoints: []discoveryv1.Endpoint{{
    			Addresses: []string{"7.7.7.7"},
    		}},
    		Ports: []discoveryv1.EndpointPort{{Port: ptr.To[int32](80)}},
    	}
    	fakeWatch.Modify(endpoints1v2)
    	endpoints = []*discoveryv1.EndpointSlice{endpoints2, endpoints1v2, endpoints3}
    	handler.ValidateEndpointSlices(t, endpoints)
    	handler2.ValidateEndpointSlices(t, endpoints)
    
    	// Remove "bar" endpoints
    	fakeWatch.Delete(endpoints2)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go

    	if !isDelete {
    		if object == nil {
    			object = &corev1.Endpoints{
    				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{
    				{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 40.4K bytes
    - Viewed (0)
  4. pilot/pkg/xds/eds_test.go

    	verifyLocalityPriorities(asdc2Locality, endpoints2["outbound|80||locality.cluster.local"].GetEndpoints(), t)
    
    	// No outlier detection specified for this cluster, so we shouldn't apply priority.
    	verifyNoLocalityPriorities(endpoints1["outbound|80||locality-no-outlier-detection.cluster.local"].GetEndpoints(), t)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 20:58:47 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  5. cmd/endpoint-ellipses.go

    }
    
    // Returns all the expanded endpoints, each argument is expanded separately.
    func (s *endpointSet) getEndpoints() (endpoints []string) {
    	if len(s.endpoints) != 0 {
    		return s.endpoints
    	}
    	for _, argPattern := range s.argPatterns {
    		for _, lbls := range argPattern.Expand() {
    			endpoints = append(endpoints, strings.Join(lbls, ""))
    		}
    	}
    	s.endpoints = endpoints
    	return endpoints
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. cmd/endpoint.go

    	return allSet.ToSlice(), local
    }
    
    // Endpoints - list of same type of endpoint.
    type Endpoints []Endpoint
    
    // HTTPS - returns true if secure for URLEndpointType.
    func (endpoints Endpoints) HTTPS() bool {
    	return endpoints[0].HTTPS()
    }
    
    // GetString - returns endpoint string of i-th endpoint (0-based),
    // and empty string for invalid indexes.
    func (endpoints Endpoints) GetString(i int) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  7. cmd/endpoint-ellipses_test.go

    			"http://minio{2...3}/export/set{1...0}",
    			endpointSet{},
    			false,
    		},
    		// Range cannot be smaller than 4 minimum.
    		{
    			"/export{1..2}",
    			endpointSet{},
    			false,
    		},
    		// Unsupported characters.
    		{
    			"/export/test{1...2O}",
    			endpointSet{},
    			false,
    		},
    		// Tests valid inputs.
    		{
    			"{1...27}",
    			endpointSet{
    				[]ellipses.ArgPattern{
    					[]ellipses.Pattern{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  8. pkg/proxy/endpointslicecache.go

    // addEndpoints adds an Endpoint for each unique endpoint.
    func (cache *EndpointSliceCache) addEndpoints(svcPortName *ServicePortName, portNum int, endpointSet map[string]Endpoint, endpoints []discovery.Endpoint) map[string]Endpoint {
    	if endpointSet == nil {
    		endpointSet = map[string]Endpoint{}
    	}
    
    	// iterate through endpoints to add them to endpointSet.
    	for _, endpoint := range endpoints {
    		if len(endpoint.Addresses) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. pkg/proxy/endpointslicecache_test.go

    				Endpoints:  []discovery.Endpoint{endpoint1, endpoint2},
    			},
    			expectChanged: false,
    		},
    		"identical with endpoints out of order": {
    			cache: NewEndpointSliceCache("", v1.IPv4Protocol, nil, nil),
    			initialSlice: &discovery.EndpointSlice{
    				ObjectMeta: objMeta,
    				Ports:      []discovery.EndpointPort{port443},
    				Endpoints:  []discovery.Endpoint{endpoint1, endpoint2},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  10. pkg/controller/endpointslicemirroring/reconciler.go

    	endpointsNN := types.NamespacedName{Name: endpoints.Name, Namespace: endpoints.Namespace}
    	r.metricsCache.UpdateEndpointPortCache(endpointsNN, epMetrics)
    
    	return r.finalize(endpoints, slices)
    }
    
    // reconcileByPortMapping compares the endpoints found in existing slices with
    // the list of desired endpoints and returns lists of slices to create, update,
    // and delete.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
Back to top