Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 476 for registry_ (0.13 sec)

  1. pkg/scheduler/framework/runtime/registry.go

    	}
    }
    
    // Registry is a collection of all available plugins. The framework uses a
    // registry to enable and initialize configured plugins.
    // All plugins must be in the registry before initializing the framework.
    type Registry map[string]PluginFactory
    
    // Register adds a new plugin to the registry. If a plugin with the same name
    // exists, it returns an error.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/registry.go

    	"k8s.io/kubernetes/pkg/scheduler/framework/runtime"
    )
    
    // NewInTreeRegistry builds the registry with all the in-tree plugins.
    // A scheduler that runs out of tree plugins can register additional plugins
    // through the WithFrameworkOutOfTreeRegistry option.
    func NewInTreeRegistry() runtime.Registry {
    	fts := plfeature.Features{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/registry_test.go

    func isRegistryEqual(registryX, registryY Registry) bool {
    	for name, pluginFactory := range registryY {
    		if val, ok := registryX[name]; ok {
    			p1, _ := pluginFactory(nil, nil, nil)
    			p2, _ := val(nil, nil, nil)
    			if p1.Name() != p2.Name() {
    				// pluginFactory functions are not the same.
    				return false
    			}
    		} else {
    			// registryY contains an entry that is not present in registryX
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  4. pkg/registry/core/service/portallocator/controller/repair_test.go

    	clearMetrics()
    	fakeClient := fake.NewSimpleClientset()
    	registry := &mockRangeRegistry{
    		item: &api.RangeAllocation{Range: "100-200"},
    	}
    	pr, _ := net.ParsePortRange(registry.item.Range)
    	r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry)
    
    	if err := r.runOnce(); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  5. pkg/registry/resource/rest/storage_resource.go

    	resourceclaimparametersstore "k8s.io/kubernetes/pkg/registry/resource/resourceclaimparameters/storage"
    	resourceclaimtemplatestore "k8s.io/kubernetes/pkg/registry/resource/resourceclaimtemplate/storage"
    	resourceclassstore "k8s.io/kubernetes/pkg/registry/resource/resourceclass/storage"
    	resourceclassparametersstore "k8s.io/kubernetes/pkg/registry/resource/resourceclassparameters/storage"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/options/api_enablement.go

    	if err != nil {
    		return append(errors, err)
    	}
    
    	for _, registry := range registries {
    		// filter out known groups
    		groups = unknownGroups(groups, registry)
    	}
    	if len(groups) != 0 {
    		errors = append(errors, fmt.Errorf("unknown api groups %s", strings.Join(groups, ",")))
    	}
    
    	return errors
    }
    
    // ApplyTo override MergedResourceConfig with defaults and registry
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 09:22:37 UTC 2023
    - 4K bytes
    - Viewed (0)
  7. pkg/registry/core/rest/storage_core_generic.go

    	namespacestore "k8s.io/kubernetes/pkg/registry/core/namespace/storage"
    	resourcequotastore "k8s.io/kubernetes/pkg/registry/core/resourcequota/storage"
    	secretstore "k8s.io/kubernetes/pkg/registry/core/secret/storage"
    	serviceaccountstore "k8s.io/kubernetes/pkg/registry/core/serviceaccount/storage"
    	"k8s.io/kubernetes/pkg/serviceaccount"
    )
    
    // GenericConfig provides information needed to build RESTStorage
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 6K bytes
    - Viewed (0)
  8. pkg/controlplane/instance.go

    	certificatesrest "k8s.io/kubernetes/pkg/registry/certificates/rest"
    	coordinationrest "k8s.io/kubernetes/pkg/registry/coordination/rest"
    	corerest "k8s.io/kubernetes/pkg/registry/core/rest"
    	discoveryrest "k8s.io/kubernetes/pkg/registry/discovery/rest"
    	eventsrest "k8s.io/kubernetes/pkg/registry/events/rest"
    	flowcontrolrest "k8s.io/kubernetes/pkg/registry/flowcontrol/rest"
    	networkingrest "k8s.io/kubernetes/pkg/registry/networking/rest"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  9. pkg/registry/resource/resourceslice/storage/storage.go

    import (
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apiserver/pkg/registry/generic"
    	genericregistry "k8s.io/apiserver/pkg/registry/generic/registry"
    	"k8s.io/kubernetes/pkg/apis/resource"
    	"k8s.io/kubernetes/pkg/printers"
    	printersinternal "k8s.io/kubernetes/pkg/printers/internalversion"
    	printerstorage "k8s.io/kubernetes/pkg/printers/storage"
    	"k8s.io/kubernetes/pkg/registry/resource/resourceslice"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  10. pkg/scheduler/testing/framework/framework_helpers.go

    	registry := runtime.Registry{}
    	profile := &schedulerapi.KubeSchedulerProfile{
    		SchedulerName: profileName,
    		Plugins:       &schedulerapi.Plugins{},
    	}
    	for _, f := range fns {
    		f(&registry, profile)
    	}
    	return runtime.NewFramework(ctx, registry, profile, opts...)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.3K bytes
    - Viewed (0)
Back to top