Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for pluginFactory (0.21 sec)

  1. 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)
  2. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go

    	return newPluginWithListers(ctx, t, nil, nil, nil)
    }
    
    func newPluginWithListers(ctx context.Context, t *testing.T, pods []*v1.Pod, nodes []*v1.Node, pvcs []*v1.PersistentVolumeClaim) framework.Plugin {
    	pluginFactory := func(ctx context.Context, plArgs runtime.Object, fh framework.Handle) (framework.Plugin, error) {
    		return New(ctx, plArgs, fh, feature.Features{})
    	}
    	snapshot := cache.NewSnapshot(pods, nodes)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 17.3K bytes
    - Viewed (0)
  3. pkg/volume/flexvolume/probe_test.go

    	return
    }
    
    // Fake Flexvolume plugin
    type fakePluginFactory struct {
    	errorDriver string // the name of the driver in error
    }
    
    var _ PluginFactory = fakePluginFactory{}
    
    func (m fakePluginFactory) NewFlexVolumePlugin(_, driverName string, _ exec.Interface) (volume.VolumePlugin, error) {
    	if driverName == m.errorDriver {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 28 11:14:00 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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