How to use Plugin method of install Package

...37			assert.Equal(t, actual, c.expected)38		}39	}40}41// PluginDetail test42type MetaTestPlugin struct{}43func (t *MetaTestPlugin) Version() string {44	return "1.1.1"45}46func (t *MetaTestPlugin) Desc() string {47	return "Desc"48}49func (t *MetaTestPlugin) Execute(c *kit.Context) error {50	return nil51}52func TestPluginDetailPlugin(t *testing.T) {53	plugin := MetaTestPlugin{}54	inputsSchema := []byte("{\"inputsSchema\": 1}")55	contextInputsSchema := []byte("{\"contextInputsSchema\": 2}")56	outputsSchema := []byte("{\"outputsSchema\": 3}")57	inputsSchemaJSON := map[string]interface{}{"inputsSchema": 1}58	contextInputsSchemaJSON := map[string]interface{}{"contextInputsSchema": 2}59	outputsSchemaJSON := map[string]interface{}{"outputsSchema": 3}60	detail := PluginDetail{61		plugin:                  &plugin,62		inputsSchema:            inputsSchema,63		contextInputsSchema:     contextInputsSchema,64		outputsSchema:           outputsSchema,65		inputsSchemaJSON:        inputsSchemaJSON,66		contextInputsSchemaJSON: contextInputsSchemaJSON,67		outputsSchemaJSON:       outputsSchemaJSON,68	}69	assert.Equal(t, detail.Plugin(), &plugin)70	assert.Equal(t, detail.InputsSchema(), inputsSchema)71	assert.Equal(t, detail.ContextInputsSchema(), contextInputsSchema)72	assert.Equal(t, detail.OutputsSchema(), outputsSchema)73	assert.Equal(t, detail.InputsSchemaJSON(), inputsSchemaJSON)74	assert.Equal(t, detail.ContextInputsSchemaJSON(), contextInputsSchemaJSON)75	assert.Equal(t, detail.OutputsSchemaJSON(), outputsSchemaJSON)76}77func TestReflectJSONSchema(t *testing.T) {78	// case 179	type ReflectStruct struct {80		TemplateID int    `json:"template_id"`81		TaskName   string `json:"task_name"`82	}83	var rs ReflectStruct84	reflector := jsonschema.Reflector{ExpandedStruct: true}85	schema, err := reflector.Reflect(&rs).MarshalJSON()86	assert.Nil(t, err)87	var schemaJSON map[string]interface{}88	err = json.Unmarshal(schema, &schemaJSON)89	assert.Nil(t, err)90	// case 291	var emptySchemaJSON map[string]interface{}92	err = json.Unmarshal(emptySchema, &emptySchemaJSON)93	assert.Nil(t, err)94	// case 395	type ReflectStructWithFrom struct {96		TemplateID int    `json:"template_id"`97		TaskName   string `json:"task_name"`98	}99	inputsForm := kit.Form{100		"template_id": {101			"attr1": "val1",102			"attr2": "val2",103		},104		"task_name": {105			"attr3": kit.F{106				"sub_attr3": "val3",107			},108		},109	}110	var rsf ReflectStructWithFrom111	rsfSchema, err := reflector.Reflect(&rsf).MarshalJSON()112	assert.Nil(t, err)113	var rsfSchemaJSON map[string]interface{}114	err = json.Unmarshal(schema, &rsfSchemaJSON)115	assert.Nil(t, err)116	properties := rsfSchemaJSON["properties"].(map[string]interface{})117	for prop, attrs := range inputsForm {118		for k, v := range attrs {119			property := properties[prop].(map[string]interface{})120			property[k] = v121		}122	}123	rsfSchema, err = json.Marshal(rsfSchemaJSON)124	assert.Nil(t, err)125	var cases = []struct {126		in                 interface{}127		extraAttrs         kit.Form128		expectedSchema     []byte129		expectedSchemaJSON interface{}130	}{131		{rs, nil, schema, schemaJSON},132		{rsf, inputsForm, rsfSchema, rsfSchemaJSON},133		{nil, nil, emptySchema, emptySchemaJSON},134	}135	for _, c := range cases {136		actualSchema, actualSchemaJSON, err := reflectJSONSchema(c.in, c.extraAttrs)137		assert.Nil(t, err)138		assert.Equal(t, c.expectedSchema, actualSchema)139		assert.Equal(t, c.expectedSchemaJSON, actualSchemaJSON)140	}141}142type MustInstallTestPlugin struct {143	version string144}145func (t *MustInstallTestPlugin) Version() string {146	return t.version147}148func (t *MustInstallTestPlugin) Desc() string {149	return "Desc"150}151func (t *MustInstallTestPlugin) Execute(c *kit.Context) error {152	return nil153}154type MustInstallTestPluginInput struct{}155type MustInstallTestPluginContextInput struct{}156type MustInstallTestPluginOutput struct{}157var InputsForm kit.Form = kit.Form{158	"template_id": {159		"attr1": "val1",160		"attr2": "val2",161	},162	"task_name": {163		"attr3": kit.F{164			"sub_attr3": "val3",165		},166	},167}168func TestMustInstall(t *testing.T) {169	clearHub()170	var success_cases = []struct {171		plugin        *MustInstallTestPlugin172		inputs        interface{}173		contextInputs interface{}174		outputs       interface{}175		inputsForm    kit.Form176	}{177		{&MustInstallTestPlugin{version: "1.0.0"}, nil, nil, nil, nil},178		{&MustInstallTestPlugin{version: "1.0.1"}, MustInstallTestPluginInput{}, nil, nil, nil},179		{&MustInstallTestPlugin{version: "1.0.2"}, nil, MustInstallTestPluginContextInput{}, nil, nil},180		{&MustInstallTestPlugin{version: "1.0.3"}, nil, nil, MustInstallTestPluginOutput{}, nil},181		{&MustInstallTestPlugin{version: "1.0.4"}, MustInstallTestPluginInput{}, MustInstallTestPluginContextInput{}, MustInstallTestPluginOutput{}, nil},182		{&MustInstallTestPlugin{version: "1.0.5"}, MustInstallTestPluginInput{}, MustInstallTestPluginContextInput{}, MustInstallTestPluginOutput{}, InputsForm},183	}184	for _, c := range success_cases {185		assert.NotPanics(t, func() { MustInstall(c.plugin, c.inputs, c.contextInputs, c.outputs, c.inputsForm) }, "success case %v failed", c)186	}187	var panic_cases = []struct {188		plugin        *MustInstallTestPlugin189		inputs        interface{}190		contextInputs interface{}191		outputs       interface{}192	}{193		{&MustInstallTestPlugin{version: "1.0.0"}, nil, nil, nil},194		{&MustInstallTestPlugin{version: "1.0"}, nil, nil, nil},195	}196	for _, c := range panic_cases {197		assert.Panics(t, func() { MustInstall(c.plugin, c.inputs, c.contextInputs, c.outputs, nil) }, "panic case %v failed", c)198	}199}200func TestGetPluginVersions(t *testing.T) {201	clearHub()202	MustInstall(&MustInstallTestPlugin{version: "1.0.0"}, nil, nil, nil, nil)203	MustInstall(&MustInstallTestPlugin{version: "1.0.1"}, nil, nil, nil, nil)204	MustInstall(&MustInstallTestPlugin{version: "1.0.2"}, nil, nil, nil, nil)205	MustInstall(&MustInstallTestPlugin{version: "1.0.3"}, nil, nil, nil, nil)206	versions := GetPluginVersions()207	assert.Equal(t, []string{"1.0.3", "1.0.2", "1.0.1", "1.0.0"}, versions)208}209func TestGetPluginDetail(t *testing.T) {210	clearHub()211	meta, err := GetPluginDetail("not exist version")212	assert.Nil(t, meta)213	assert.NotNil(t, err)214	MustInstall(&MustInstallTestPlugin{version: "1.0.0"}, nil, nil, nil, nil)215	meta, err = GetPluginDetail("1.0.0")216	assert.Nil(t, err)217	assert.NotNil(t, meta)218}219func TestGetPlugin(t *testing.T) {220	clearHub()221	plugin, err := GetPlugin("not exist version")222	assert.Nil(t, plugin)223	assert.NotNil(t, err)224	MustInstall(&MustInstallTestPlugin{version: "1.0.0"}, nil, nil, nil, nil)225	plugin, err = GetPlugin("1.0.0")226	assert.Nil(t, err)227	assert.NotNil(t, plugin)228	assert.Equal(t, plugin.Version(), "1.0.0")229}...

...14	testCases := []struct {15		description   string16		args          []string17		expectedError string18		installFunc   func(name string, options types.PluginInstallOptions) (io.ReadCloser, error)19	}{20		{21			description:   "insufficient number of arguments",22			args:          []string{},23			expectedError: "requires at least 1 argument",24		},25		{26			description:   "invalid alias",27			args:          []string{"foo", "--alias", "UPPERCASE_ALIAS"},28			expectedError: "invalid",29		},30		{31			description:   "invalid plugin name",32			args:          []string{"UPPERCASE_REPONAME"},33			expectedError: "invalid",34		},35		{36			description:   "installation error",37			args:          []string{"foo"},38			expectedError: "Error installing plugin",39			installFunc: func(name string, options types.PluginInstallOptions) (io.ReadCloser, error) {40				return nil, fmt.Errorf("Error installing plugin")41			},42		},43		{44			description:   "installation error due to missing image",45			args:          []string{"foo"},46			expectedError: "docker image pull",47			installFunc: func(name string, options types.PluginInstallOptions) (io.ReadCloser, error) {48				return nil, fmt.Errorf("(image) when fetching")49			},50		},51	}52	for _, tc := range testCases {53		cli := test.NewFakeCli(&fakeClient{pluginInstallFunc: tc.installFunc})54		cmd := newInstallCommand(cli)55		cmd.SetArgs(tc.args)56		cmd.SetOutput(ioutil.Discard)57		assert.ErrorContains(t, cmd.Execute(), tc.expectedError)58	}59}60func TestInstallContentTrustErrors(t *testing.T) {61	testCases := []struct {62		description   string63		args          []string64		expectedError string65		notaryFunc    test.NotaryClientFuncType66	}{67		{68			description:   "install plugin, offline notary server",69			args:          []string{"plugin:tag"},70			expectedError: "client is offline",71			notaryFunc:    notary.GetOfflineNotaryRepository,72		},73		{74			description:   "install plugin, uninitialized notary server",75			args:          []string{"plugin:tag"},76			expectedError: "remote trust data does not exist",77			notaryFunc:    notary.GetUninitializedNotaryRepository,78		},79		{80			description:   "install plugin, empty notary server",81			args:          []string{"plugin:tag"},82			expectedError: "No valid trust data for tag",83			notaryFunc:    notary.GetEmptyTargetsNotaryRepository,84		},85	}86	for _, tc := range testCases {87		cli := test.NewFakeCli(&fakeClient{88			pluginInstallFunc: func(name string, options types.PluginInstallOptions) (io.ReadCloser, error) {89				return nil, fmt.Errorf("should not try to install plugin")90			},91		}, test.EnableContentTrust)92		cli.SetNotaryClient(tc.notaryFunc)93		cmd := newInstallCommand(cli)94		cmd.SetArgs(tc.args)95		cmd.SetOutput(ioutil.Discard)96		assert.ErrorContains(t, cmd.Execute(), tc.expectedError)97	}98}99func TestInstall(t *testing.T) {100	testCases := []struct {101		description    string102		args           []string103		expectedOutput string104		installFunc    func(name string, options types.PluginInstallOptions) (io.ReadCloser, error)105	}{106		{107			description:    "install with no additional flags",108			args:           []string{"foo"},109			expectedOutput: "Installed plugin foo\n",110			installFunc: func(name string, options types.PluginInstallOptions) (io.ReadCloser, error) {111				return ioutil.NopCloser(strings.NewReader("")), nil112			},113		},114		{115			description:    "install with disable flag",116			args:           []string{"--disable", "foo"},117			expectedOutput: "Installed plugin foo\n",118			installFunc: func(name string, options types.PluginInstallOptions) (io.ReadCloser, error) {119				assert.Check(t, options.Disabled)120				return ioutil.NopCloser(strings.NewReader("")), nil121			},122		},123	}124	for _, tc := range testCases {125		cli := test.NewFakeCli(&fakeClient{pluginInstallFunc: tc.installFunc})126		cmd := newInstallCommand(cli)127		cmd.SetArgs(tc.args)128		assert.NilError(t, cmd.Execute())129		assert.Check(t, strings.Contains(cli.OutBuffer().String(), tc.expectedOutput))130	}131}...

...12const officialRepo = "tkeel"13var (14	configFile string15)16var PluginInstallCmd = &cobra.Command{17	Use:   "install",18	Short: "Install the plugin which you want",19	Example: `20# Install the latest version21tkeel plugin install <repo-name>/<installer-id> <plugin-id>22# Install the specified version23tkeel plugin install <repo-name>/<installer-id>@<version> <plugin-id>24`,25	Run: func(cmd *cobra.Command, args []string) {26		if len(args) != 2 {27			print.WarningStatusEvent(os.Stdout, "Please specify the installer info and plugin id")28			print.WarningStatusEvent(os.Stdout, "For example, tkeel plugin install <repo-name>/<installer-id>[@<version>] <plugin-id>")29			os.Exit(1)30		}31		var configb []byte32		var err error33		name := args[1]34		repo, plugin, version := utils.ParseInstallArg(args[0], officialRepo)35		if configFile != "" {36			configFile, err = filepath.Abs(configFile)37			if err != nil {38				print.FailureStatusEvent(os.Stdout, "unable to read config file")39				os.Exit(1)40			}41			configb, err = ioutil.ReadFile(configFile)42			if err != nil {43				print.FailureStatusEvent(os.Stdout, "unable to read config file")44				os.Exit(1)45			}46		}47		if err := kubernetes.Install(repo, plugin, version, name, configb); err != nil {48			log.Warn("install failed", err)49			print.FailureStatusEvent(os.Stdout, "Install %q failed, Because: %s", plugin, err.Error())50			os.Exit(1)51		}52		print.SuccessStatusEvent(os.Stdout, "Install %q success! It's named %q in k8s", plugin, name)53	},54}55func init() {56	PluginInstallCmd.Flags().StringVarP(&configFile, "config", "", "", "The plugin config file.")57	PluginCmd.AddCommand(PluginInstallCmd)58}...

1import com.vmware.vim25.mo.*;2import com.vmware.vim25.*;3import java.net.URL;4import java.rmi.RemoteException;5import java.util.ArrayList;6import java.util.List;7{8  public static void main(String[] args) throws Exception9  {

1Install install = new Install();2install.Plugin("C:\\Users\\user\\Desktop\\1.txt");3Install install = new Install();4install.Plugin("C:\\Users\\user\\Desktop\\2.txt");5Install install = new Install();6install.Plugin("C:\\Users\\user\\Desktop\\3.txt");7Install install = new Install();8install.Plugin("C:\\Users\\user\\Desktop\\4.txt");9Install install = new Install();10install.Plugin("C:\\Users\\user\\Desktop\\5.txt");11Install install = new Install();12install.Plugin("C:\\Users\\user\\Desktop\\6.txt");13Install install = new Install();14install.Plugin("C:\\Users\\user\\Desktop\\7.txt");15Install install = new Install();16install.Plugin("C:\\Users\\user\\Desktop\\8.txt");17Install install = new Install();18install.Plugin("C:\\Users\\user\\Desktop\\9.txt");19Install install = new Install();20install.Plugin("C:\\Users\\user\\Desktop\\10.txt");21Install install = new Install();22install.Plugin("C:\\Users\\user\\Desktop\\11.txt");23Install install = new Install();24install.Plugin("C:\\Users\\user\\Desktop\\12.txt");25Install install = new Install();26install.Plugin("C:\\Users\\user\\Desktop\\13.txt");27Install install = new Install();28install.Plugin("C:\\Users\\user\\Desktop\\

1import (2func main() {3	p, err := plugin.Open("plugin.so")4	if err != nil {5		panic(err)6	}7	symInstall, err := p.Lookup("Install")8	if err != nil {9		panic(err)10	}11	install, ok := symInstall.(*func())12	if !ok {13		panic("unexpected type from module symbol")14	}15	(*install)()16}