Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for pluginFactory (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top