How to use startPluginsForExecution method of plugin Package

...197		}198	}199	return false200}201func startPluginsForExecution(manifest *manifest.Manifest) (Handler, []string) {202	var warnings []string203	handler := &GaugePlugins{}204	envProperties := make(map[string]string)205	for _, pluginID := range manifest.Plugins {206		pd, err := GetPluginDescriptor(pluginID, "")207		if err != nil {208			warnings = append(warnings, fmt.Sprintf("Unable to start plugin %s. %s. To install, run `gauge install %s`.", pluginID, err.Error(), pluginID))209			continue210		}211		compatibilityErr := version.CheckCompatibility(version.CurrentGaugeVersion, &pd.GaugeVersionSupport)212		if compatibilityErr != nil {213			warnings = append(warnings, fmt.Sprintf("Compatible %s plugin version to current Gauge version %s not found", pd.Name, version.CurrentGaugeVersion))214			continue215		}216		if pd.hasScope(executionScope) {217			gaugeConnectionHandler, err := conn.NewGaugeConnectionHandler(0, &keepAliveHandler{ph: handler})218			if err != nil {219				warnings = append(warnings, err.Error())220				continue221			}222			envProperties[pluginConnectionPortEnv] = strconv.Itoa(gaugeConnectionHandler.ConnectionPortNumber())223			prop, err := common.GetGaugeConfiguration()224			if err != nil {225				warnings = append(warnings, fmt.Sprintf("Unable to read Gauge configuration. %s", err.Error()))226				continue227			}228			envProperties["plugin_kill_timeout"] = prop["plugin_kill_timeout"]229			err = SetEnvForPlugin(executionScope, pd, manifest, envProperties)230			if err != nil {231				warnings = append(warnings, fmt.Sprintf("Error setting environment for plugin %s %s. %s", pd.Name, pd.Version, err.Error()))232				continue233			}234			plugin, err := StartPlugin(pd, executionScope)235			if err != nil {236				warnings = append(warnings, fmt.Sprintf("Error starting plugin %s %s. %s", pd.Name, pd.Version, err.Error()))237				continue238			}239			pluginConnection, err := gaugeConnectionHandler.AcceptConnection(config.PluginConnectionTimeout(), make(chan error))240			if err != nil {241				warnings = append(warnings, fmt.Sprintf("Error starting plugin %s %s. Failed to connect to plugin. %s", pd.Name, pd.Version, err.Error()))242				plugin.pluginCmd.Process.Kill()243				continue244			}245			plugin.connection = pluginConnection246			handler.addPlugin(pluginID, plugin)247		}248	}249	return handler, warnings250}251func GenerateDoc(pluginName string, specDirs []string, port int) {252	pd, err := GetPluginDescriptor(pluginName, "")253	if err != nil {254		logger.Fatalf(true, "Error starting plugin %s. Failed to get plugin.json. %s. To install, run `gauge install %s`.", pluginName, err.Error(), pluginName)255	}256	if err := version.CheckCompatibility(version.CurrentGaugeVersion, &pd.GaugeVersionSupport); err != nil {257		logger.Fatalf(true, "Compatible %s plugin version to current Gauge version %s not found", pd.Name, version.CurrentGaugeVersion)258	}259	if !pd.hasScope(docScope) {260		logger.Fatalf(true, "Invalid plugin name: %s, this plugin cannot generate documentation.", pd.Name)261	}262	var sources []string263	for _, src := range specDirs {264		path, _ := filepath.Abs(src)265		sources = append(sources, path)266	}267	os.Setenv("GAUGE_SPEC_DIRS", strings.Join(sources, "||"))268	os.Setenv("GAUGE_PROJECT_ROOT", config.ProjectRoot)269	os.Setenv(common.APIPortEnvVariableName, strconv.Itoa(port))270	p, err := StartPlugin(pd, docScope)271	if err != nil {272		logger.Fatalf(true, "Error starting plugin %s %s. %s", pd.Name, pd.Version, err.Error())273	}274	for isProcessRunning(p) {275	}276}277func (p *plugin) sendMessage(message *gauge_messages.Message) error {278	messageID := common.GetUniqueID()279	message.MessageId = messageID280	messageBytes, err := proto.Marshal(message)281	if err != nil {282		return err283	}284	err = conn.Write(p.connection, messageBytes)285	if err != nil {286		return fmt.Errorf("[Warning] Failed to send message to plugin: %s  %s", p.descriptor.ID, err.Error())287	}288	return nil289}290func StartPlugins(manifest *manifest.Manifest) Handler {291	pluginHandler, warnings := startPluginsForExecution(manifest)292	logger.HandleWarningMessages(true, warnings)293	return pluginHandler294}295func PluginsWithoutScope() (infos []pluginInfo.PluginInfo) {296	if plugins, err := pluginInfo.GetAllInstalledPluginsWithVersion(); err == nil {297		for _, p := range plugins {298			pd, err := GetPluginDescriptor(p.Name, p.Version.String())299			if err == nil && !pd.hasAnyScope() {300				infos = append(infos, p)301			}302		}303	}304	return305}...

1import (2func main() {3	conn, err := rpc.Dial("/home/ethereum/.ethereum/geth.ipc")4	if err != nil {5		log.Fatalf("Failed to connect to the Ethereum client: %v", err)6	}7	client := ethclient.NewClient(conn)8	blockNumber, err := client.BlockNumber()9	if err != nil {10		log.Fatalf("Failed to retrieve block number: %v", err)11	}12	fmt.Println("Block Number", blockNumber)13	blockNumber, err = client.BlockNumber()14	if err != nil {15		log.Fatalf("Failed to retrieve block number: %v", err)16	}17	fmt.Println("Block Number", blockNumber)18	blockNumber, err = client.BlockNumber()19	if err != nil {20		log.Fatalf("Failed to retrieve block number: %v", err)21	}22	fmt.Println("Block Number", blockNumber)23	blockNumber, err = client.BlockNumber()24	if err != nil {25		log.Fatalf("Failed to retrieve block number: %v", err)26	}27	fmt.Println("Block Number", blockNumber)28	blockNumber, err = client.BlockNumber()29	if err != nil {30		log.Fatalf("Failed to retrieve block number: %v", err)31	}32	fmt.Println("Block Number", blockNumber)33	blockNumber, err = client.BlockNumber()