Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for endpointSet (0.19 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. 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)
  4. 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)
  5. 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)
  6. 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