Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for endpointSet (0.36 sec)

  1. cmd/endpoint-ellipses_test.go

    	testCases := []struct {
    		arg     string
    		es      endpointSet
    		success bool
    	}{
    		// Tests invalid inputs.
    		{
    			"...",
    			endpointSet{},
    			false,
    		},
    		// No range specified.
    		{
    			"{...}",
    			endpointSet{},
    			false,
    		},
    		// Invalid range.
    		{
    			"http://minio{2...3}/export/set{1...0}",
    			endpointSet{},
    			false,
    		},
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  2. pkg/proxy/endpointslicecache.go

    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)
  3. pkg/controller/endpointslicemirroring/reconciler_helpers.go

    		endpointsByKey:      map[addrTypePortMapKey]endpointsliceutil.EndpointSet{},
    		numDesiredEndpoints: 0,
    	}
    }
    
    // desiredCalc helps calculate desired endpoints and ports.
    type desiredCalc struct {
    	portsByKey          map[addrTypePortMapKey][]discovery.EndpointPort
    	endpointsByKey      map[addrTypePortMapKey]endpointsliceutil.EndpointSet
    	numDesiredEndpoints int
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. cmd/endpoint-ellipses.go

    	}
    	return totalSizes
    }
    
    // Parses all arguments and returns an endpointSet which is a collection
    // of endpoints following the ellipses pattern, this is what is used
    // by the object layer for initializing itself.
    func parseEndpointSet(setDriveCount uint64, args ...string) (ep endpointSet, err error) {
    	argPatterns := make([]ellipses.ArgPattern, len(args))
    	for i, arg := range args {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. pkg/controller/endpointslicemirroring/reconciler.go

    // and delete.
    func (r *reconciler) reconcileByPortMapping(
    	endpoints *corev1.Endpoints,
    	existingSlices []*discovery.EndpointSlice,
    	desiredSet endpointsliceutil.EndpointSet,
    	endpointPorts []discovery.EndpointPort,
    	addressType discovery.AddressType,
    ) (slicesByAction, totalsByAction) {
    	slices := slicesByAction{}
    	totals := totalsByAction{}
    
    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. pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go

    }
    
    func testEndpointsEqual(a, b []*model.IstioEndpoint) bool {
    	if len(a) != len(b) {
    		return false
    	}
    	m1 := make(map[endpointKey]int)
    	m2 := make(map[endpointKey]int)
    	for _, i := range a {
    		m1[endpointKey{i.Address, i.ServicePortName}]++
    	}
    	for _, i := range b {
    		m2[endpointKey{i.Address, i.ServicePortName}]++
    	}
    	return reflect.DeepEqual(m1, m2)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 18:50:38 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  7. pilot/pkg/xds/debug_test.go

    				}
    				if (ss.RouteAcked != "") != wantAcked {
    					errorHandler("wanted RouteAcked set %v got %v for %v", wantAcked, ss.RouteAcked, nodeID)
    				}
    				if (ss.EndpointSent != "") != wantSent {
    					errorHandler("wanted EndpointSent set %v got %v for %v", wantSent, ss.EndpointSent, nodeID)
    				}
    				if (ss.EndpointAcked != "") != wantAcked {
    					errorHandler("wanted EndpointAcked set %v got %v for %v", wantAcked, ss.EndpointAcked, nodeID)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    	return types.NamespacedName{
    		Namespace: slice.GetNamespace(),
    		Name:      serviceNameForEndpointSlice(slice.GetLabels()),
    	}
    }
    
    // endpointKey unique identifies an endpoint by IP and port name
    // This is used for deduping endpoints across slices.
    type endpointKey struct {
    	ip   string
    	port string
    }
    
    type endpointSliceCache struct {
    	mu                         sync.RWMutex
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  9. pilot/pkg/xds/debug.go

    	ListenerAcked        string         `json:"listener_acked,omitempty"`
    	RouteSent            string         `json:"route_sent,omitempty"`
    	RouteAcked           string         `json:"route_acked,omitempty"`
    	EndpointSent         string         `json:"endpoint_sent,omitempty"`
    	EndpointAcked        string         `json:"endpoint_acked,omitempty"`
    	ExtensionConfigSent  string         `json:"extensionconfig_sent,omitempty"`
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
Back to top