|
|
|
@ -10,12 +10,12 @@ import ( |
|
|
|
|
|
|
|
func TestMiniDefaultPluginJobTypes(t *testing.T) { |
|
|
|
dialOption := grpc.WithTransportCredentials(insecure.NewCredentials()) |
|
|
|
// defaultMiniPluginJobTypes is an explicit list: "vacuum,volume_balance,erasure_coding,admin_script"
|
|
|
|
// defaultMiniPluginJobTypes is "all", which includes every registered handler
|
|
|
|
handlers, err := buildPluginWorkerHandlers(defaultMiniPluginJobTypes, dialOption, int(pluginworker.DefaultMaxExecutionConcurrency), "") |
|
|
|
if err != nil { |
|
|
|
t.Fatalf("buildPluginWorkerHandlers(mini default) err = %v", err) |
|
|
|
} |
|
|
|
if len(handlers) != 4 { |
|
|
|
t.Fatalf("expected mini default job types to include 4 handlers, got %d", len(handlers)) |
|
|
|
if len(handlers) != 6 { |
|
|
|
t.Fatalf("expected mini default job types to include 6 handlers, got %d", len(handlers)) |
|
|
|
} |
|
|
|
} |