Merge pull request 'add modelarts' (#36) from tzwang/pcm-participant:master into master
This commit is contained in:
commit
a1f120d81e
|
|
@ -1,8 +1,9 @@
|
|||
package platform
|
||||
|
||||
const (
|
||||
OpenI Type = "openi"
|
||||
Octopus Type = "octopus"
|
||||
OpenI Type = "openi"
|
||||
Octopus Type = "octopus"
|
||||
Modelarts Type = "modelarts"
|
||||
)
|
||||
|
||||
type Platform struct {
|
||||
|
|
|
|||
3
go.work
3
go.work
|
|
@ -12,10 +12,11 @@ use (
|
|||
./platform
|
||||
hpc
|
||||
participant/octopus
|
||||
participant/modelarts
|
||||
)
|
||||
|
||||
replace gitlink.org.cn/JointCloud/pcm-participant-common v0.0.0 => ./common
|
||||
|
||||
replace gitlink.org.cn/JointCloud/pcm-participant-ai v0.0.0 => ./ai
|
||||
|
||||
replace gitlink.org.cn/JointCloud/pcm-participant-openi v0.0.0 => ./participant/openI
|
||||
replace gitlink.org.cn/JointCloud/pcm-participant-openi v0.0.0 => ./participant/openI
|
||||
28
go.work.sum
28
go.work.sum
|
|
@ -1,5 +1,7 @@
|
|||
dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
|
||||
dario.cat/mergo v1.0.0/go.mod h1:uNxQE+84aUszobStD9th8a29P2fMDhsBdgRYvZOxGmk=
|
||||
github.com/JCCE-nudt/apigw-go-sdk v0.0.0-20230525025609-34159d6f2818 h1:QLulhUyxPDs9FFieVZwmKAnUBLeRDhsVNehotAAL/FE=
|
||||
github.com/JCCE-nudt/apigw-go-sdk v0.0.0-20230525025609-34159d6f2818/go.mod h1:j+am5/1URgsvyhOAyURFR9vH3malaW7Tq6d33OyPsnM=
|
||||
github.com/Microsoft/go-winio v0.5.2/go.mod h1:WpS1mjBmmwHBEWmogvA2mj8546UReBk4v8QkMxJ6pZY=
|
||||
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
|
||||
github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
|
||||
|
|
@ -11,14 +13,10 @@ github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 h1:0CwZNZbxp69SHPd
|
|||
github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5/go.mod h1:wHh0iHkYZB8zMSxRWpUBQtwG5a7fFgvEO+odwuTv2gs=
|
||||
github.com/bwesterb/go-ristretto v1.2.3 h1:1w53tCkGhCQ5djbat3+MH0BAQ5Kfgbt56UZQ/JMzngw=
|
||||
github.com/bwesterb/go-ristretto v1.2.3/go.mod h1:fUIoIZaG73pV5biE2Blr2xEzDoMj7NFEuV9ekS419A0=
|
||||
github.com/bytedance/sonic v1.13.2/go.mod h1:o68xyaF9u2gvVBuGHPlUVCy+ZfmNNO5ETf1+KgkJhz4=
|
||||
github.com/bytedance/sonic/loader v0.2.4/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI=
|
||||
github.com/cloudflare/circl v1.3.7 h1:qlCDlTPz2n9fu58M0Nh1J/JzcFpfgkFHHX3O35r5vcU=
|
||||
github.com/cloudflare/circl v1.3.7/go.mod h1:sRTcRWXGLrKw6yIGJ+l7amYJFfAXbZG0kBSc8r4zxgA=
|
||||
github.com/cloudwego/base64x v0.1.5/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
|
||||
github.com/cpuguy83/go-md2man/v2 v2.0.6 h1:XJtiaUW6dEEqVuZiMTn1ldk455QWwEIsMIJlo5vtkx0=
|
||||
github.com/creack/pty v1.1.9 h1:uDmaGzcdjhF4i/plgjmEsriH11Y0o7RKapEf/LDaM3w=
|
||||
github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
|
||||
github.com/cyphar/filepath-securejoin v0.3.6 h1:4d9N5ykBnSp5Xn2JkhocYDkOpURL/18CYMpo6xB9uWM=
|
||||
github.com/cyphar/filepath-securejoin v0.3.6/go.mod h1:Sdj7gXlvMcPZsbhwhQ33GguGLDGQL7h7bg04C/+u9jI=
|
||||
github.com/elazarl/goproxy v1.4.0 h1:4GyuSbFa+s26+3rmYNSuUVsx+HgPrV1bk1jXI0l9wjM=
|
||||
|
|
@ -27,8 +25,6 @@ github.com/emirpasic/gods v1.18.1 h1:FXtiHYKDGKCW2KzwZKx0iC0PQmdlorYgdFG9jPXJ1Bc
|
|||
github.com/emirpasic/gods v1.18.1/go.mod h1:8tpGGwCnJ5H4r6BWwaV6OrWmMoPhUl5jm/FMNAnJvWQ=
|
||||
github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4=
|
||||
github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
|
||||
github.com/gabriel-vasile/mimetype v1.4.8/go.mod h1:ByKUIKGjh1ODkGM1asKUbQZOLGrPjydw3hYPU2YU9t8=
|
||||
github.com/gin-contrib/sse v1.0.0/go.mod h1:zNuFdwarAygJBht0NTKiSi3jRf6RbqeILZ9Sp6Slhe0=
|
||||
github.com/gliderlabs/ssh v0.3.8 h1:a4YXD1V7xMF9g5nTkdfnja3Sxy1PVDCj1Zg4Wb8vY6c=
|
||||
github.com/gliderlabs/ssh v0.3.8/go.mod h1:xYoytBv1sV0aL3CavoDuJIQNURXkkfPA/wxQ1pL1fAU=
|
||||
github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 h1:+zs/tPmkDkHx3U66DAb0lQFJrpS6731Oaa12ikc+DiI=
|
||||
|
|
@ -39,14 +35,11 @@ github.com/go-git/go-git-fixtures/v4 v4.3.2-0.20231010084843-55a94097c399 h1:eMj
|
|||
github.com/go-git/go-git-fixtures/v4 v4.3.2-0.20231010084843-55a94097c399/go.mod h1:1OCfN199q1Jm3HZlxleg+Dw/mwps2Wbk9frAWm+4FII=
|
||||
github.com/go-git/go-git/v5 v5.13.2 h1:7O7xvsK7K+rZPKW6AQR1YyNhfywkv7B8/FsP3ki6Zv0=
|
||||
github.com/go-git/go-git/v5 v5.13.2/go.mod h1:hWdW5P4YZRjmpGHwRH2v3zkWcNl6HeXaXQEMGb3NJ9A=
|
||||
github.com/go-playground/validator/v10 v10.25.0/go.mod h1:GGzBIJMuE98Ic/kJsBXbz1x/7cByt++cQ+YOuDM5wus=
|
||||
github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
|
||||
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE=
|
||||
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
|
||||
github.com/golang/protobuf v1.5.0 h1:LUVKkCeviFUMKqHa4tXIIij/lbhnMbP7Fn5wKdKkRh4=
|
||||
github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ=
|
||||
github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
|
||||
github.com/google/gofuzz v1.0.0 h1:A8PeW59pxE9IoFRqBp37U+mSNaQoZ46F1f0f863XSXw=
|
||||
github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||
github.com/hashicorp/errwrap v1.0.0 h1:hLrqtEDnRye3+sgx6z4qVLNuviH3MR5aQ0ykNJa/UYA=
|
||||
|
|
@ -59,29 +52,20 @@ github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 h1:BQSFePA1RWJOl
|
|||
github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99/go.mod h1:1lJo3i6rXxKeerYnT8Nvf0QmHCRC1n8sfWVwXF2Frvo=
|
||||
github.com/kevinburke/ssh_config v1.2.0 h1:x584FjTGwHzMwvHx18PXxbBVzfnxogHaAReU4gf13a4=
|
||||
github.com/kevinburke/ssh_config v1.2.0/go.mod h1:CT57kijsi8u/K/BOFA39wgDQJ9CxiF4nAY/ojJ6r6mM=
|
||||
github.com/klauspost/cpuid/v2 v2.2.10/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
|
||||
github.com/knz/go-libedit v1.10.1 h1:0pHpWtx9vcvC0xGZqEQlQdfSQs7WRlAjuPvk3fOZDCo=
|
||||
github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
|
||||
github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
|
||||
github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
|
||||
github.com/kr/pty v1.1.1 h1:VkoXIwSboBpnk99O/KFauAEILuNHv5DVFKZMBN/gUgw=
|
||||
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
|
||||
github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
|
||||
github.com/neelance/astrewrite v0.0.0-20160511093645-99348263ae86 h1:D6paGObi5Wud7xg83MaEFyjxQB1W5bz5d0IFppr+ymk=
|
||||
github.com/neelance/astrewrite v0.0.0-20160511093645-99348263ae86/go.mod h1:kHJEU3ofeGjhHklVoIGuVj85JJwZ6kWPaJwCIxgnFmo=
|
||||
github.com/neelance/sourcemap v0.0.0-20200213170602-2833bce08e4c h1:bY6ktFuJkt+ZXkX0RChQch2FtHpWQLVS8Qo1YasiIVk=
|
||||
github.com/neelance/sourcemap v0.0.0-20200213170602-2833bce08e4c/go.mod h1:Qr6/a/Q4r9LP1IltGz7tA7iOK1WonHEYhu1HRBA7ZiM=
|
||||
github.com/onsi/gomega v1.34.1 h1:EUMJIKUjM8sKjYbtxQI9A4z2o+rruxnzNvpknOXie6k=
|
||||
github.com/onsi/gomega v1.34.1/go.mod h1:kU1QgUvBDLXBJq618Xvm2LUX6rSAfRaFRTcdOeDLwwY=
|
||||
github.com/pelletier/go-toml/v2 v2.2.3/go.mod h1:MfCQTFTvCcUyyvvwm1+G6H/jORL20Xlb6rzQu9GuUkc=
|
||||
github.com/pjbgf/sha1cd v0.3.2 h1:a9wb0bp1oC2TGwStyn0Umc/IGKQnEgF0vVaZ8QF8eo4=
|
||||
github.com/pjbgf/sha1cd v0.3.2/go.mod h1:zQWigSxVmsHEZow5qaLtPYxpcKMMQpa09ixqBxuCS6A=
|
||||
github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e h1:aoZm08cpOy4WuID//EZDgcC4zIxODThtZNPirFr42+A=
|
||||
github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA=
|
||||
github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
|
||||
github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
|
||||
github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
|
||||
github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4=
|
||||
github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=
|
||||
github.com/segmentio/fasthash v1.0.3 h1:EI9+KE1EwvMLBWwjpRDc+fEM+prwxDYbslddQGtrmhM=
|
||||
github.com/segmentio/fasthash v1.0.3/go.mod h1:waKX8l2N8yckOgmSsXJi7x1ZfdKZ4x7KRMzBtS3oedY=
|
||||
|
|
@ -104,18 +88,15 @@ github.com/stretchr/objx v0.1.0 h1:4G4v2dO3VZwixGIRoQ5Lfboy6nUhCyYzaqnIAPPhYs4=
|
|||
github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
|
||||
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
|
||||
github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
|
||||
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
|
||||
github.com/xanzy/ssh-agent v0.3.3 h1:+/15pJfg/RsTxqYcX6fHqOXZwwMP+2VyYWJeWM2qQFM=
|
||||
github.com/xanzy/ssh-agent v0.3.3/go.mod h1:6dzNDKs0J9rVPHPhaGCukekBHKqfl+L3KghI1Bc68Uw=
|
||||
github.com/yuin/goldmark v1.4.13 h1:fVcFKWvrslecOb/tg+Cc05dkeYx540o0FuFt3nUVDoE=
|
||||
golang.org/x/arch v0.15.0/go.mod h1:JmwW7aLIoRUKgaTzhkiEFxvcEiQGyOg9BMonBJUS7EE=
|
||||
golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97 h1:/UOmuWzQfxxo9UtlXMwuQU8CMgg1eZXqTRwkSQJWKOI=
|
||||
golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
|
||||
golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
|
||||
golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU=
|
||||
golang.org/x/crypto v0.31.0/go.mod h1:kDsLvtWBEx7MV9tJOj9bnXsPbxwJQ6csT/x4KIN4Ssk=
|
||||
golang.org/x/crypto v0.32.0/go.mod h1:ZnnJkOaASj8g0AjIduWNlq2NRxL0PlBrbKVyZ6V/Ugc=
|
||||
golang.org/x/crypto v0.36.0/go.mod h1:Y4J0ReaxCR1IMaabaSMugxJES1EpwhBHhv2bDHklZvc=
|
||||
golang.org/x/exp v0.0.0-20220218215828-6cf2b201936e h1:iWVPgObh6F4UDtjBLK51zsy5UHTPLQwCmsNjCsbKhQ0=
|
||||
golang.org/x/exp v0.0.0-20220218215828-6cf2b201936e/go.mod h1:lgLbSvA5ygNOMpwM/9anMpWVlVJ7Z+cHWq/eFuinpGE=
|
||||
golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56 h1:2dVuKD2vS7b0QIHQbpyTISPd0LeHDbnYEryqj5Q1ug8=
|
||||
|
|
@ -129,7 +110,6 @@ golang.org/x/net v0.8.0/go.mod h1:QVkue5JL9kW//ek3r6jTKnTFis1tRmNAW2P1shuFdJc=
|
|||
golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
|
||||
golang.org/x/net v0.33.0/go.mod h1:HXLR5J+9DxmrqMwG9qjGCxZ+zKXxBru04zlTvWlWuN4=
|
||||
golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
|
||||
golang.org/x/net v0.37.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
|
||||
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c h1:5KslGYwFpkhGh+Q16bwMP3cOontH8FOep7tGV86Y7SQ=
|
||||
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.1.0 h1:wsuoTGHzEhffawBOhz5CYhcrV4IdKZbEyZjBMuTp12o=
|
||||
|
|
@ -144,25 +124,21 @@ golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
|||
golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
||||
golang.org/x/sys v0.29.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
||||
golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
||||
golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
|
||||
golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2 h1:IRJeR9r1pYWsHKTRe/IInb7lYvbBVIqOgsX/u0mbOWY=
|
||||
golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2/go.mod h1:TeRTkGYfJXctD9OcfyVLyj2J3IxLnKwHJR8f4D8a3YE=
|
||||
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1 h1:v+OssWQX+hTHEmOBgwxdZxK4zHq3yOs8F9J7mk0PY8E=
|
||||
golang.org/x/term v0.20.0 h1:VnkxpohqXaOBYJtBmEppKUG6mXpi+4O6purfc2+sMhw=
|
||||
golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY=
|
||||
golang.org/x/term v0.27.0/go.mod h1:iMsnZpn0cago0GOrHO2+Y7u7JPn5AylBrcoWkElMTSM=
|
||||
golang.org/x/term v0.30.0/go.mod h1:NYYFdzHoI5wRh/h5tDMdMqCqPJZEuNqVR5xJLd/n67g=
|
||||
golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
|
||||
golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
|
||||
golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ=
|
||||
golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4=
|
||||
golang.org/x/tools v0.7.0 h1:W4OVu8VVOaIO0yzWMNdepAulS7YfoS3Zabrm8DOXXU4=
|
||||
golang.org/x/tools v0.7.0/go.mod h1:4pg6aUX35JBAogB10C9AtvVL+qowtN4pT3CGSQex14s=
|
||||
golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d h1:vU5i/LfpvrRCpgM/VPfJLg5KjxD3E+hfT1SH+d9zLwg=
|
||||
golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
|
||||
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
|
||||
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
|
||||
google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
|
||||
gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/warnings.v0 v0.1.2 h1:wFXVbFY8DY5/xOe1ECiWdKCzZlxgshcYVNkBHstARME=
|
||||
gopkg.in/warnings.v0 v0.1.2/go.mod h1:jksf8JmL6Qr/oQM2OXTHunEvvTAsrWBLb6OOjuVWRNI=
|
||||
|
|
|
|||
|
|
@ -0,0 +1,72 @@
|
|||
package common
|
||||
|
||||
import "C"
|
||||
import (
|
||||
"crypto/tls"
|
||||
"fmt"
|
||||
"github.com/JCCE-nudt/apigw-go-sdk/core"
|
||||
"io"
|
||||
"net/http"
|
||||
)
|
||||
|
||||
var FileName string
|
||||
|
||||
// SignClient AK/SK签名认证
|
||||
func SignClient(r *http.Request, Platform string) (*http.Client, error) {
|
||||
var (
|
||||
projectId = "d18190e28e3f45a281ef0b0696ec9d52"
|
||||
ak = "UNEHPHO4Z7YSNPKRXFE4"
|
||||
sk = "JWXCE9qcYbc7RjpSRIWt4WgG3ZKF6Q4lPzkJReX9"
|
||||
)
|
||||
|
||||
r.Header.Add("content-type", "application/json;charset=UTF-8")
|
||||
r.Header.Add("X-Project-Id", projectId)
|
||||
r.Header.Add("x-stage", "RELEASE")
|
||||
|
||||
s := core.Signer{
|
||||
Key: ak,
|
||||
Secret: sk,
|
||||
}
|
||||
err := s.Sign(r)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
//设置client信任所有证书
|
||||
tr := &http.Transport{
|
||||
TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
|
||||
}
|
||||
client := &http.Client{
|
||||
Transport: tr,
|
||||
}
|
||||
return client, nil
|
||||
}
|
||||
|
||||
func SendRequestHttp(method, url string, in io.Reader, Platform string) ([]byte, error) {
|
||||
r, err := http.NewRequest(method, url, in)
|
||||
if err != nil {
|
||||
fmt.Println("Error creating new request:", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
signedR, err := SignClient(r, Platform)
|
||||
if err != nil {
|
||||
fmt.Println("Error signing request:", err)
|
||||
return nil, err
|
||||
}
|
||||
|
||||
res, err := signedR.Do(r)
|
||||
if err != nil {
|
||||
fmt.Println("Error sending request:", err)
|
||||
return nil, err
|
||||
}
|
||||
defer res.Body.Close()
|
||||
|
||||
body, err := io.ReadAll(res.Body)
|
||||
if err != nil {
|
||||
fmt.Println("Error reading response body:", err)
|
||||
return nil, err
|
||||
}
|
||||
fmt.Println(string(body))
|
||||
return body, nil
|
||||
}
|
||||
|
|
@ -0,0 +1,7 @@
|
|||
package common
|
||||
|
||||
const (
|
||||
// algorithm
|
||||
Algorithm = "/v2/{project_id}/algorithms"
|
||||
AlgorithmDetail = "/v2/{project_id}/algorithms/{algorithm_id}"
|
||||
)
|
||||
|
|
@ -0,0 +1,17 @@
|
|||
package common
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func Test123(t *testing.T) {
|
||||
a := "https://modelarts.cn-south-222.ai.pcl.cn/v2/d18190e28e3f45a281ef0b0696ec9d52/algorithms"
|
||||
body, err := SendRequestHttp(http.MethodGet, a, nil, "")
|
||||
if err != nil {
|
||||
fmt.Println(err.Error())
|
||||
return
|
||||
}
|
||||
fmt.Println(string(body))
|
||||
}
|
||||
|
|
@ -0,0 +1,18 @@
|
|||
package config
|
||||
|
||||
type ModelArtsConf struct {
|
||||
CloudBrain2 Conf `json:"CloudBrain2"`
|
||||
JobLogsPath string `json:"JobLogsPath"`
|
||||
Platform string `json:"Platform"`
|
||||
}
|
||||
|
||||
type Conf struct {
|
||||
AK string `json:"AK"`
|
||||
SK string `json:"SK"`
|
||||
Endpoint string `json:"Endpoint"`
|
||||
ProjectId string `json:"ProjectId"`
|
||||
DomainId string `json:"DomainId"`
|
||||
SwrEndpoint string `json:"SwrEndpoint"`
|
||||
SwrApiEndpoint string `json:"SwrApiEndpoint"`
|
||||
Platform string `json:"Platform"`
|
||||
}
|
||||
|
|
@ -0,0 +1,7 @@
|
|||
module gitlink.org.cn/JointCloud/pcm-participant-modelarts
|
||||
|
||||
go 1.22.0
|
||||
|
||||
require (
|
||||
github.com/JCCE-nudt/apigw-go-sdk v0.0.0-20230525025609-34159d6f2818
|
||||
)
|
||||
|
|
@ -0,0 +1,235 @@
|
|||
package modelarts
|
||||
|
||||
import (
|
||||
"context"
|
||||
"errors"
|
||||
jcs "gitlink.org.cn/JointCloud/jcs/storagekit"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-ai/algorithm"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-ai/dataset"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-ai/image"
|
||||
aiModel "gitlink.org.cn/JointCloud/pcm-participant-ai/model"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-ai/platform"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-ai/resource"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-ai/task"
|
||||
"gitlink.org.cn/JointCloud/pcm-participant-client/config"
|
||||
)
|
||||
|
||||
type Modelarts struct {
|
||||
opt *Option
|
||||
Res *Resource
|
||||
Img *Image
|
||||
Ds *Dataset
|
||||
Alg *Algorithm
|
||||
Mdl *Model
|
||||
Task *Task
|
||||
}
|
||||
|
||||
type Option struct {
|
||||
platform *platform.Platform
|
||||
JcsClient *jcs.Jcs
|
||||
}
|
||||
|
||||
type Resource struct {
|
||||
opt *Option
|
||||
ft *resource.Features
|
||||
}
|
||||
|
||||
type Image struct {
|
||||
opt *Option
|
||||
ft *image.Features
|
||||
}
|
||||
|
||||
type Dataset struct {
|
||||
opt *Option
|
||||
ft *dataset.Features
|
||||
}
|
||||
|
||||
type Algorithm struct {
|
||||
opt *Option
|
||||
ft *algorithm.Features
|
||||
}
|
||||
|
||||
type Model struct {
|
||||
opt *Option
|
||||
ft *aiModel.Features
|
||||
}
|
||||
|
||||
type Task struct {
|
||||
opt *Option
|
||||
}
|
||||
|
||||
func New(conf *config.Jcs, username, pwd, token, clusterName string, id platform.Id) (*Modelarts, error) {
|
||||
jcsClient := jcs.NewJcs(conf.ApiKey, conf.Url, -1)
|
||||
|
||||
opt := &Option{
|
||||
platform: &platform.Platform{
|
||||
Name: clusterName,
|
||||
Type: platform.Modelarts,
|
||||
Id: id,
|
||||
},
|
||||
JcsClient: jcsClient,
|
||||
}
|
||||
|
||||
res := &Resource{
|
||||
opt: opt,
|
||||
}
|
||||
res.ft = (&resource.Features{}).Fill(context.Background(), res)
|
||||
|
||||
img := &Image{
|
||||
opt: opt,
|
||||
}
|
||||
img.ft = (&image.Features{
|
||||
HasRecommendation: true,
|
||||
}).Fill(context.Background(), img)
|
||||
|
||||
ds := &Dataset{
|
||||
opt: opt,
|
||||
}
|
||||
|
||||
alg := &Algorithm{
|
||||
opt: opt,
|
||||
}
|
||||
alg.ft = (&algorithm.Features{}).Fill(context.Background(), alg)
|
||||
|
||||
mdl := &Model{
|
||||
opt: opt,
|
||||
}
|
||||
mdl.ft = (&aiModel.Features{}).Fill(context.Background(), mdl)
|
||||
|
||||
tsk := &Task{
|
||||
opt: opt,
|
||||
}
|
||||
|
||||
return &Modelarts{
|
||||
Res: res,
|
||||
Ds: ds,
|
||||
opt: opt,
|
||||
Alg: alg,
|
||||
Img: img,
|
||||
Mdl: mdl,
|
||||
Task: tsk,
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (r *Resource) All(ctx context.Context) (resource.Specs, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (r *Resource) Train(ctx context.Context) (resource.Specs, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (r *Resource) Infer(ctx context.Context) (resource.Specs, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (r *Resource) Features() *resource.Features {
|
||||
return r.ft
|
||||
}
|
||||
|
||||
func (i *Image) All(ctx context.Context) (image.Images, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (i *Image) Train(ctx context.Context) (image.Images, error) {
|
||||
return nil, errors.New("implement me")
|
||||
|
||||
}
|
||||
|
||||
func (i *Image) Infer(ctx context.Context) (image.Images, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (i *Image) Features() *image.Features {
|
||||
return i.ft
|
||||
}
|
||||
|
||||
func (d *Dataset) All(ctx context.Context) (dataset.Datasets, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (d *Dataset) Train(ctx context.Context) (dataset.Datasets, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (d *Dataset) Infer(ctx context.Context) (dataset.Datasets, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (d *Dataset) Create(ctx context.Context, param *dataset.CreateParam) (*dataset.CreateResp, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (d *Dataset) Features() *dataset.Features {
|
||||
return d.ft
|
||||
}
|
||||
|
||||
func (a *Algorithm) All(ctx context.Context) (algorithm.Algorithms, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (a *Algorithm) Train(ctx context.Context) (algorithm.Algorithms, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (a *Algorithm) Infer(ctx context.Context) (algorithm.Algorithms, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (a *Algorithm) Create(ctx context.Context, param *algorithm.CreateParam) (*algorithm.CreateResp, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (a *Algorithm) Features() *algorithm.Features {
|
||||
return a.ft
|
||||
}
|
||||
|
||||
func (m *Model) All(ctx context.Context) (aiModel.Models, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (m *Model) Train(ctx context.Context) (aiModel.Models, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (m *Model) Infer(ctx context.Context) (aiModel.Models, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (m *Model) Create(ctx context.Context, param *aiModel.CreateParam) (*aiModel.CreateResp, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (m *Model) Features() *aiModel.Features {
|
||||
return m.ft
|
||||
}
|
||||
|
||||
func (t *Task) CreateInference(ctx context.Context, params *task.InferParams) (interface{}, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (t *Task) GetInference(ctx context.Context, taskId string) (interface{}, error) {
|
||||
return nil, errors.New("implement me")
|
||||
|
||||
}
|
||||
|
||||
func (t *Task) Stop(ctx context.Context, id string) error {
|
||||
return errors.New("implement me")
|
||||
}
|
||||
|
||||
func (t *Task) CreateTraining(ctx context.Context, params *task.TrainParams) (interface{}, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (t *Task) GetTraining(ctx context.Context, taskId string) (interface{}, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (t *Task) Log(ctx context.Context, taskId string) (interface{}, error) {
|
||||
return nil, errors.New("implement me")
|
||||
}
|
||||
|
||||
func (t *Task) SyncResult(ctx context.Context, param *task.ResultSyncParam) error {
|
||||
return errors.New("implement me")
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue