Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewResourceManager (0.17 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go

    func TestEtagConsistent(t *testing.T) {
    	// Create 2 managers, add a bunch of services to each
    	manager1 := discoveryendpoint.NewResourceManager("apis")
    	manager2 := discoveryendpoint.NewResourceManager("apis")
    
    	apis := fuzzAPIGroups(1, 3, 11)
    	manager1.SetGroups(apis.Items)
    	manager2.SetGroups(apis.Items)
    
    	// Make sure etag of each is the same
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 02 00:29:39 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/metrics_test.go

    		args = append(args, aggregationCount)
    	}
    	return strings.NewReader(fmt.Sprintf(expected, args...))
    }
    
    func TestBasicMetrics(t *testing.T) {
    	legacyregistry.Reset()
    	manager := discoveryendpoint.NewResourceManager("apis")
    
    	apis := fuzzAPIGroups(1, 3, 10)
    	manager.SetGroups(apis.Items)
    
    	interests := []string{"aggregator_discovery_aggregation_count_total"}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 09 17:24:02 UTC 2023
    - 3K bytes
    - Viewed (0)
  3. pkg/controlplane/apiserver/config.go

    	if lastErr != nil {
    		return
    	}
    
    	if utilfeature.DefaultFeatureGate.Enabled(genericfeatures.AggregatedDiscoveryEndpoint) {
    		genericConfig.AggregatedDiscoveryGroupManager = aggregated.NewResourceManager("apis")
    	}
    
    	return
    }
    
    // BuildAuthorizer constructs the authorizer. If authorization is not set in s, it returns nil, nil, false, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler.go

    	versionPriorities map[groupVersionKey]priorityInfo
    }
    
    type priorityInfo struct {
    	GroupPriorityMinimum int
    	VersionPriority      int
    }
    
    func NewResourceManager(path string) ResourceManager {
    	scheme := runtime.NewScheme()
    	utilruntime.Must(apidiscoveryv2.AddToScheme(scheme))
    	utilruntime.Must(apidiscoveryv2beta1.AddToScheme(scheme))
    	// Register conversion for apidiscovery
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 02 00:29:39 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/config.go

    		manager := c.AggregatedDiscoveryGroupManager
    		if manager == nil {
    			manager = discoveryendpoint.NewResourceManager("apis")
    		}
    		s.AggregatedDiscoveryGroupManager = manager
    		s.AggregatedLegacyDiscoveryGroupManager = discoveryendpoint.NewResourceManager("api")
    	}
    	for {
    		if c.JSONPatchMaxCopyBytes <= 0 {
    			break
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
Back to top