Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for pluginFactory (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/kube-scheduler/app/server.go

    // hence there are no references to it from the kubernetes scheduler code base.
    func WithPlugin(name string, factory runtime.PluginFactory) Option {
    	return func(registry runtime.Registry) error {
    		return registry.Register(name, factory)
    	}
    }
    
    // Setup creates a completed config and a scheduler based on the command args and options
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  6. pkg/scheduler/testing/framework/fake_extender.go

    	}
    	return &result, nil
    }
    
    type node2PrioritizerPlugin struct{}
    
    // NewNode2PrioritizerPlugin returns a factory function to build node2PrioritizerPlugin.
    func NewNode2PrioritizerPlugin() frameworkruntime.PluginFactory {
    	return func(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
    		return &node2PrioritizerPlugin{}, nil
    	}
    }
    
    // Name returns name of the plugin.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. pkg/scheduler/schedule_one_test.go

    	return f.isPrioritizer
    }
    
    func (f *fakeExtender) IsFilter() bool {
    	return f.isFilter
    }
    
    type falseMapPlugin struct{}
    
    func newFalseMapPlugin() frameworkruntime.PluginFactory {
    	return func(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
    		return &falseMapPlugin{}, nil
    	}
    }
    
    func (pl *falseMapPlugin) Name() string {
    	return "FalseMap"
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  8. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/catalog/LibrariesSourceGenerator.java

            List<String> aliases = classNode.aliases
                .stream()
                .sorted()
                .collect(toList());
            writeLn("public static class " + pluginClassName + " extends PluginFactory " + interfaces + "{");
            indent(() -> {
                writeSubAccessorFieldsOf(classNode, AccessorKind.plugin);
                writeLn();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Mar 06 13:35:05 UTC 2024
    - 36K bytes
    - Viewed (0)
Back to top