bash

func BuildPluginUpgradeSqlFile(initSqlFile, upgradeSqlFile, currentVersion string) (outputFile string, err error)

func CopyTmpFile(sourceFilePath string) (filePath, fileDir string, err error)

func CreatePluginDatabase(ctx context.Context, username string, mysqlResource *models.PluginPackageRuntimeResourcesMysql, mysqlServer *models.ResourceServer) (password string, err error)

func DecompressFile(filePath, targetDir string) (localDir string, err error)

func DownloadPackageFile(bucket, key string) (tmpPath string, err error)

func ExecPluginUpgradeSql(ctx context.Context, mysqlInstance *models.PluginMysqlInstances, mysqlServer *models.ResourceServer, sqlFilePath string) (err error)

func GetDirIndexPath(targetDir string) (subPath string, matchFlag bool, err error)

func GetHostSerialNum(hostIp string)

func GetRemoteHostAvailablePort(resourceServer *models.ResourceServer) (port int, err error)

func InitPluginDockerHostSSH()

func ListContains(inputList []string, target string) bool

func ListDirAllFiles(targetDir string) (resultPaths []string, err error)

func ListDirFiles(dirPath string) (result []string, err error)

func MakeBucket(bucket string) (err error)

func RemoteSCP(targetIp, user, pwd, port, localFile, targetPath string) (err error)

func RemoteSSHCommand(targetIp, user, pwd, port, command string) (err error)

func RemoteSSHCommandWithOutput(targetIp, user, pwd, port, command string) (stdout []byte, err error)

func RemoveTmpFile(tmpFile string)

func SaveTmpFile(fileName string, fileContent []byte) (filePath, fileDir string, err error)

func UploadPluginPackage(address, accessKey, secretKey, bucket string, fileMap map[string]string) (err error)