- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for pluginFactory (0.2 sec)
-
pkg/scheduler/framework/runtime/registry_test.go
name: "valid Merge", primaryRegistry: Registry{ "pluginFactory1": m1, }, registryToMerge: Registry{ "pluginFactory2": m2, }, expected: Registry{ "pluginFactory1": m1, "pluginFactory2": m2, }, shouldError: false, }, { name: "Merge duplicate factories", primaryRegistry: Registry{ "pluginFactory1": m1, }, registryToMerge: Registry{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 6.5K bytes - Viewed (0) -
pkg/scheduler/testing/framework/framework_helpers.go
func RegisterQueueSortPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc { return RegisterPluginAsExtensions(pluginName, pluginNewFunc, "QueueSort") } // RegisterPreFilterPlugin returns a function to register a PreFilter Plugin to a given registry. func RegisterPreFilterPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/registry.go
"k8s.io/apimachinery/pkg/util/json" "k8s.io/kubernetes/pkg/scheduler/framework" plfeature "k8s.io/kubernetes/pkg/scheduler/framework/plugins/feature" "sigs.k8s.io/yaml" ) // PluginFactory is a function that builds a plugin. type PluginFactory = func(ctx context.Context, configuration runtime.Object, f framework.Handle) (framework.Plugin, error) // PluginFactoryWithFts is a function that builds a plugin with certain feature gates.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_plugins.go
} return nil } // NewFakeFilterPlugin initializes a fakeFilterPlugin and returns it. func NewFakeFilterPlugin(failedNodeReturnCodeMap map[string]framework.Code) frameworkruntime.PluginFactory { return func(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) { return &FakeFilterPlugin{ FailedNodeReturnCodeMap: failedNodeReturnCodeMap, }, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java
import org.apache.logging.log4j.core.config.plugins.Plugin; import org.apache.logging.log4j.core.config.plugins.PluginAttribute; import org.apache.logging.log4j.core.config.plugins.PluginFactory; import org.apache.logging.log4j.core.impl.Log4jLogEvent; @Plugin(name = "ErrorToWarnRewritePolicy", category = Core.CATEGORY_NAME, elementType = "rewritePolicy", printObject = true)
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/catalog/VersionCatalogView.java
import org.gradle.api.internal.attributes.ImmutableAttributesFactory; import org.gradle.api.internal.catalog.AbstractExternalDependencyFactory.BundleFactory; import org.gradle.api.internal.catalog.AbstractExternalDependencyFactory.PluginFactory; import org.gradle.api.internal.catalog.AbstractExternalDependencyFactory.VersionFactory; import org.gradle.api.model.ObjectFactory; import org.gradle.api.provider.Provider; import org.gradle.api.provider.ProviderFactory;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Dec 17 22:25:43 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/volume/flexvolume/plugin.go
var _ volume.DeviceMountableVolumePlugin = &flexVolumeAttachablePlugin{} // PluginFactory create flex volume plugin type PluginFactory interface { NewFlexVolumePlugin(pluginDir, driverName string, runner exec.Interface) (volume.VolumePlugin, error) } type pluginFactory struct{} func (pluginFactory) NewFlexVolumePlugin(pluginDir, name string, runner exec.Interface) (volume.VolumePlugin, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/testing/testing.go
// The function also creates an empty namespace (since most tests creates pods with // empty namespace), and start informer factory. func SetupPluginWithInformers( ctx context.Context, tb testing.TB, pf frameworkruntime.PluginFactory, config runtime.Object, sharedLister framework.SharedLister, objs []runtime.Object, ) framework.Plugin { objs = append([]runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: ""}}}, objs...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/catalog/AbstractExternalDependencyFactory.java
return property; } } public static class PluginFactory { protected final ProviderFactory providers; protected final DefaultVersionCatalog config; public PluginFactory(ProviderFactory providers, DefaultVersionCatalog config) { this.providers = providers; this.config = config; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 15 16:36:23 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
testingclock "k8s.io/utils/clock/testing" "k8s.io/utils/ptr" ) func TestSchedulerCreation(t *testing.T) { invalidRegistry := map[string]frameworkruntime.PluginFactory{ defaultbinder.Name: defaultbinder.New, } validRegistry := map[string]frameworkruntime.PluginFactory{ "Foo": defaultbinder.New, } cases := []struct { name string opts []Option wantErr string wantProfiles []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0)