import (
   ultipa "ultipa-go-sdk/rpc"
   "ultipa-go-sdk/sdk/printers"
   "ultipa-go-sdk/sdk/configuration"
   "ultipa-go-sdk/sdk"
)

安装算法

func InstallAlgo() {
   config := configuration.NewUltipaConfig(&configuration.UltipaConfig{
      Hosts:        []string{"host:port"},
      Username:     "root",
      Password:     "root",
      DefaultGraph: "default",
   })
   client, err := sdk.NewUltipa(config)
   resp, err := client.InstallAlgo("path/xxx.so", "path/xxx.yml", nil)
   if resp.Status.ErrorCode != ultipa.ErrorCode_SUCCESS {
      printers.PrintError(resp.Status.Msg)
   }
   if err != nil {
      printers.PrintErrAndExist(err.Error())
   }
}

卸载算法

func UninstallAlgo() {
   config := configuration.NewUltipaConfig(&configuration.UltipaConfig{
      Hosts:        []string{"host:port"},
      Username:     "root",
      Password:     "root",
      DefaultGraph: "default",
   })
   client, err := sdk.NewUltipa(config)
   resp, err := client.UninstallAlgo("AlgoName", nil)
   if resp.Status.ErrorCode != ultipa.ErrorCode_SUCCESS {
      printers.PrintError(resp.Status.Msg)
   }
   if err != nil {
      printers.PrintErrAndExist(err.Error())
   }
}