updated goctl version
This commit is contained in:
parent
4ba9f09bc0
commit
83ab2b8ee1
21
go.mod
21
go.mod
|
|
@ -8,8 +8,8 @@ require (
|
|||
github.com/zeromicro/go-zero v1.6.0
|
||||
gitlink.org.cn/JointCloud/pcm-coordinator v0.0.0-20240301032931-d8d63c116dda
|
||||
gitlink.org.cn/jcce-pcm/utils v0.0.1
|
||||
google.golang.org/grpc v1.60.0
|
||||
google.golang.org/protobuf v1.31.0
|
||||
google.golang.org/grpc v1.64.0
|
||||
google.golang.org/protobuf v1.33.0
|
||||
)
|
||||
|
||||
require (
|
||||
|
|
@ -30,11 +30,11 @@ require (
|
|||
github.com/go-redis/redis/v8 v8.11.5 // indirect
|
||||
github.com/gogo/protobuf v1.3.2 // indirect
|
||||
github.com/golang/mock v1.6.0 // indirect
|
||||
github.com/golang/protobuf v1.5.3 // indirect
|
||||
github.com/golang/protobuf v1.5.4 // indirect
|
||||
github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49 // indirect
|
||||
github.com/google/go-cmp v0.6.0 // indirect
|
||||
github.com/google/gofuzz v1.2.0 // indirect
|
||||
github.com/google/uuid v1.5.0 // indirect
|
||||
github.com/google/uuid v1.6.0 // indirect
|
||||
github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.1 // indirect
|
||||
github.com/jinzhu/copier v0.4.0 // indirect
|
||||
github.com/josharian/intern v1.0.0 // indirect
|
||||
|
|
@ -72,16 +72,15 @@ require (
|
|||
go.uber.org/automaxprocs v1.5.3 // indirect
|
||||
go.uber.org/multierr v1.11.0 // indirect
|
||||
go.uber.org/zap v1.26.0 // indirect
|
||||
golang.org/x/net v0.19.0 // indirect
|
||||
golang.org/x/oauth2 v0.15.0 // indirect
|
||||
golang.org/x/sys v0.15.0 // indirect
|
||||
golang.org/x/term v0.15.0 // indirect
|
||||
golang.org/x/net v0.22.0 // indirect
|
||||
golang.org/x/oauth2 v0.18.0 // indirect
|
||||
golang.org/x/sys v0.18.0 // indirect
|
||||
golang.org/x/term v0.18.0 // indirect
|
||||
golang.org/x/text v0.14.0 // indirect
|
||||
golang.org/x/time v0.5.0 // indirect
|
||||
google.golang.org/appengine v1.6.8 // indirect
|
||||
google.golang.org/genproto v0.0.0-20231212172506-995d672761c0 // indirect
|
||||
google.golang.org/genproto/googleapis/api v0.0.0-20231212172506-995d672761c0 // indirect
|
||||
google.golang.org/genproto/googleapis/rpc v0.0.0-20231212172506-995d672761c0 // indirect
|
||||
google.golang.org/genproto/googleapis/api v0.0.0-20240318140521-94a12d6c2237 // indirect
|
||||
google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237 // indirect
|
||||
gopkg.in/inf.v0 v0.9.1 // indirect
|
||||
gopkg.in/yaml.v2 v2.4.0 // indirect
|
||||
gopkg.in/yaml.v3 v3.0.1 // indirect
|
||||
|
|
|
|||
42
go.sum
42
go.sum
|
|
@ -53,8 +53,8 @@ github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc=
|
|||
github.com/golang/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs=
|
||||
github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
|
||||
github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
|
||||
github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg=
|
||||
github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
|
||||
github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
|
||||
github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
|
||||
github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49 h1:0VpGH+cDhbDtdcweoyCVsF3fhN8kejK6rFe/2FFX2nU=
|
||||
github.com/google/gnostic-models v0.6.9-0.20230804172637-c7be7c783f49/go.mod h1:BkkQ4L1KS1xMt2aWSPStnn55ChGC0DPOn2FQYj+f25M=
|
||||
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||
|
|
@ -66,8 +66,8 @@ github.com/google/gofuzz v1.2.0 h1:xRy4A+RhZaiKjJ1bPfwQ8sedCA+YS2YcCHW6ec7JMi0=
|
|||
github.com/google/gofuzz v1.2.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
|
||||
github.com/google/pprof v0.0.0-20211214055906-6f57359322fd h1:1FjCyPC+syAzJ5/2S8fqdZK1R22vvA0J7JZKcuOIQ7Y=
|
||||
github.com/google/pprof v0.0.0-20211214055906-6f57359322fd/go.mod h1:KgnwoLYCZ8IQu3XUZ8Nc/bM9CCZFOyjUNOSygVozoDg=
|
||||
github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU=
|
||||
github.com/google/uuid v1.5.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
|
||||
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||
github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.1 h1:6UKoz5ujsI55KNpsJH3UwCq3T8kKbZwNZBNPuTTje8U=
|
||||
github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.1/go.mod h1:YvJ2f6MplWDhfxiUC3KpyTy76kYUZA4W3pTv/wdKQ9Y=
|
||||
github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542 h1:2VTzZjLZBgl62/EtslCrtky5vbi9dd7HrQPQIx6wqiw=
|
||||
|
|
@ -215,10 +215,10 @@ golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug
|
|||
golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
|
||||
golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
|
||||
golang.org/x/net v0.17.0/go.mod h1:NxSsAGuq816PNPmqtQdLE42eU2Fs7NoRIZrHJAlaCOE=
|
||||
golang.org/x/net v0.19.0 h1:zTwKpTd2XuCqf8huc7Fo2iSy+4RHPd10s4KzeTnVr1c=
|
||||
golang.org/x/net v0.19.0/go.mod h1:CfAk/cbD4CthTvqiEl8NpboMuiuOYsAr/7NOjZJtv1U=
|
||||
golang.org/x/oauth2 v0.15.0 h1:s8pnnxNVzjWyrvYdFUQq5llS1PX2zhPXmccZv99h7uQ=
|
||||
golang.org/x/oauth2 v0.15.0/go.mod h1:q48ptWNTY5XWf+JNten23lcvHpLJ0ZSxF5ttTHKVCAM=
|
||||
golang.org/x/net v0.22.0 h1:9sGLhx7iRIHEiX0oAJ3MRZMUCElJgy7Br1nO+AMN3Tc=
|
||||
golang.org/x/net v0.22.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
|
||||
golang.org/x/oauth2 v0.18.0 h1:09qnuIAgzdx1XplqJvW6CQqMCtGZykZWcXzPMPUusvI=
|
||||
golang.org/x/oauth2 v0.18.0/go.mod h1:Wf7knwG0MPoWIMMBgFlEaSUDaKskp0dCfrlJRJXbBi8=
|
||||
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||
|
|
@ -239,15 +239,15 @@ golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
|||
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||
golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc=
|
||||
golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
||||
golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
|
||||
golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
||||
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
|
||||
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
|
||||
golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
|
||||
golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
|
||||
golang.org/x/term v0.13.0/go.mod h1:LTmsnFJwVN6bCy1rVCoS+qHT1HhALEFxKncY3WNNh4U=
|
||||
golang.org/x/term v0.15.0 h1:y/Oo/a/q3IXu26lQgl04j/gjuBDOBlx7X6Om1j2CPW4=
|
||||
golang.org/x/term v0.15.0/go.mod h1:BDl952bC7+uMoWR75FIrCDx79TPU9oHkTZ9yRbYOrX0=
|
||||
golang.org/x/term v0.18.0 h1:FcHjZXDMxI8mM3nwhX9HlKop4C0YQvCVCdwYl2wOtE8=
|
||||
golang.org/x/term v0.18.0/go.mod h1:ILwASektA3OnRv7amZ1xhE/KTR+u50pbXfZ03+6Nx58=
|
||||
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
|
||||
golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
|
||||
|
|
@ -275,18 +275,16 @@ golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8T
|
|||
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
|
||||
google.golang.org/appengine v1.6.8 h1:IhEN5q69dyKagZPYMSdIjS2HqprW324FRQZJcGqPAsM=
|
||||
google.golang.org/appengine v1.6.8/go.mod h1:1jJ3jBArFh5pcgW8gCtRJnepW8FzD1V44FJffLiz/Ds=
|
||||
google.golang.org/genproto v0.0.0-20231212172506-995d672761c0 h1:YJ5pD9rF8o9Qtta0Cmy9rdBwkSjrTCT6XTiUQVOtIos=
|
||||
google.golang.org/genproto v0.0.0-20231212172506-995d672761c0/go.mod h1:l/k7rMz0vFTBPy+tFSGvXEd3z+BcoG1k7EHbqm+YBsY=
|
||||
google.golang.org/genproto/googleapis/api v0.0.0-20231212172506-995d672761c0 h1:s1w3X6gQxwrLEpxnLd/qXTVLgQE2yXwaOaoa6IlY/+o=
|
||||
google.golang.org/genproto/googleapis/api v0.0.0-20231212172506-995d672761c0/go.mod h1:CAny0tYF+0/9rmDB9fahA9YLzX3+AEVl1qXbv5hhj6c=
|
||||
google.golang.org/genproto/googleapis/rpc v0.0.0-20231212172506-995d672761c0 h1:/jFB8jK5R3Sq3i/lmeZO0cATSzFfZaJq1J2Euan3XKU=
|
||||
google.golang.org/genproto/googleapis/rpc v0.0.0-20231212172506-995d672761c0/go.mod h1:FUoWkonphQm3RhTS+kOEhF8h0iDpm4tdXolVCeZ9KKA=
|
||||
google.golang.org/grpc v1.60.0 h1:6FQAR0kM31P6MRdeluor2w2gPaS4SVNrD/DNTxrQ15k=
|
||||
google.golang.org/grpc v1.60.0/go.mod h1:OlCHIeLYqSSsLi6i49B5QGdzaMZK9+M7LXN2FKz4eGM=
|
||||
google.golang.org/genproto/googleapis/api v0.0.0-20240318140521-94a12d6c2237 h1:RFiFrvy37/mpSpdySBDrUdipW/dHwsRwh3J3+A9VgT4=
|
||||
google.golang.org/genproto/googleapis/api v0.0.0-20240318140521-94a12d6c2237/go.mod h1:Z5Iiy3jtmioajWHDGFk7CeugTyHtPvMHA4UTmUkyalE=
|
||||
google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237 h1:NnYq6UN9ReLM9/Y01KWNOWyI5xQ9kbIms5GGJVwS/Yc=
|
||||
google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237/go.mod h1:WtryC6hu0hhx87FDGxWCDptyssuo68sk10vYjF+T9fY=
|
||||
google.golang.org/grpc v1.64.0 h1:KH3VH9y/MgNQg1dE7b3XfVK0GsPSIzJwdF617gUSbvY=
|
||||
google.golang.org/grpc v1.64.0/go.mod h1:oxjF8E3FBnjp+/gVFYdWacaLDx9na1aqy9oovLpxQYg=
|
||||
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
|
||||
google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
|
||||
google.golang.org/protobuf v1.31.0 h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8=
|
||||
google.golang.org/protobuf v1.31.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
|
||||
google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI=
|
||||
google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
|
||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
// Code generated by goctl. DO NOT EDIT.
|
||||
// goctl 1.7.2
|
||||
// Source: octopus.proto
|
||||
|
||||
package server
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load Diff
|
|
@ -1,6 +1,6 @@
|
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.3.0
|
||||
// - protoc-gen-go-grpc v1.5.1
|
||||
// - protoc v3.19.4
|
||||
// source: octopus.proto
|
||||
|
||||
|
|
@ -15,8 +15,8 @@ import (
|
|||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7
|
||||
// Requires gRPC-Go v1.64.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion9
|
||||
|
||||
const (
|
||||
Octopus_GetComputingPower_FullMethodName = "/octopus.Octopus/GetComputingPower"
|
||||
|
|
@ -86,7 +86,7 @@ const (
|
|||
type OctopusClient interface {
|
||||
GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error)
|
||||
GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error)
|
||||
GetInferResult(ctx context.Context, opts ...grpc.CallOption) (Octopus_GetInferResultClient, error)
|
||||
GetInferResult(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[InferResultReq, InferResultResp], error)
|
||||
// Algorithm
|
||||
GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error)
|
||||
GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error)
|
||||
|
|
@ -163,8 +163,9 @@ func NewOctopusClient(cc grpc.ClientConnInterface) OctopusClient {
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CpResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetComputingPower_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetComputingPower_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -172,51 +173,32 @@ func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq,
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GiResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetGeneralInfo_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetGeneralInfo_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *octopusClient) GetInferResult(ctx context.Context, opts ...grpc.CallOption) (Octopus_GetInferResultClient, error) {
|
||||
stream, err := c.cc.NewStream(ctx, &Octopus_ServiceDesc.Streams[0], Octopus_GetInferResult_FullMethodName, opts...)
|
||||
func (c *octopusClient) GetInferResult(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[InferResultReq, InferResultResp], error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
stream, err := c.cc.NewStream(ctx, &Octopus_ServiceDesc.Streams[0], Octopus_GetInferResult_FullMethodName, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
x := &octopusGetInferResultClient{stream}
|
||||
x := &grpc.GenericClientStream[InferResultReq, InferResultResp]{ClientStream: stream}
|
||||
return x, nil
|
||||
}
|
||||
|
||||
type Octopus_GetInferResultClient interface {
|
||||
Send(*InferResultReq) error
|
||||
CloseAndRecv() (*InferResultResp, error)
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
type octopusGetInferResultClient struct {
|
||||
grpc.ClientStream
|
||||
}
|
||||
|
||||
func (x *octopusGetInferResultClient) Send(m *InferResultReq) error {
|
||||
return x.ClientStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func (x *octopusGetInferResultClient) CloseAndRecv() (*InferResultResp, error) {
|
||||
if err := x.ClientStream.CloseSend(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
m := new(InferResultResp)
|
||||
if err := x.ClientStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
||||
type Octopus_GetInferResultClient = grpc.ClientStreamingClient[InferResultReq, InferResultResp]
|
||||
|
||||
func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetMyAlgorithmListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetMyAlgorithmList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetMyAlgorithmList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -224,8 +206,9 @@ func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorit
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetAlgorithmListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -233,8 +216,9 @@ func (c *octopusClient) GetAlgorithmList(ctx context.Context, in *GetAlgorithmLi
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetAlgorithmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -242,8 +226,9 @@ func (c *octopusClient) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, o
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetAlgorithmApplyListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmApplyList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmApplyList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -251,8 +236,9 @@ func (c *octopusClient) GetAlgorithmApplyList(ctx context.Context, in *GetAlgori
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetAlgorithmFrameworkListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmFrameworkList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmFrameworkList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -260,8 +246,9 @@ func (c *octopusClient) GetAlgorithmFrameworkList(ctx context.Context, in *GetAl
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteMyAlgorithmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteMyAlgorithm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteMyAlgorithm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -269,8 +256,9 @@ func (c *octopusClient) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgor
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateMyAlgorithmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateMyAlgorithm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateMyAlgorithm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -278,8 +266,9 @@ func (c *octopusClient) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgor
|
|||
}
|
||||
|
||||
func (c *octopusClient) DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DownloadAlgorithmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadAlgorithm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadAlgorithm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -287,8 +276,9 @@ func (c *octopusClient) DownloadAlgorithm(ctx context.Context, in *DownloadAlgor
|
|||
}
|
||||
|
||||
func (c *octopusClient) DownloadCompress(ctx context.Context, in *DownloadCompressReq, opts ...grpc.CallOption) (*DownloadCompressResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DownloadCompressResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadCompress_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadCompress_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -296,8 +286,9 @@ func (c *octopusClient) DownloadCompress(ctx context.Context, in *DownloadCompre
|
|||
}
|
||||
|
||||
func (c *octopusClient) DownloadAlgorithmUrl(ctx context.Context, in *AlgorithmUrlReq, opts ...grpc.CallOption) (*AlgorithmUrlResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(AlgorithmUrlResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadAlgorithmUrl_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadAlgorithmUrl_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -305,8 +296,9 @@ func (c *octopusClient) DownloadAlgorithmUrl(ctx context.Context, in *AlgorithmU
|
|||
}
|
||||
|
||||
func (c *octopusClient) UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(UploadAlgorithmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadAlgorithm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadAlgorithm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -314,8 +306,9 @@ func (c *octopusClient) UploadAlgorithm(ctx context.Context, in *UploadAlgorithm
|
|||
}
|
||||
|
||||
func (c *octopusClient) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(UploadAlgorithmConfirmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadAlgorithmConfirm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadAlgorithmConfirm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -323,8 +316,9 @@ func (c *octopusClient) UploadAlgorithmConfirm(ctx context.Context, in *UploadAl
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetMyDatasetListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetMyDatasetList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetMyDatasetList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -332,8 +326,9 @@ func (c *octopusClient) GetMyDatasetList(ctx context.Context, in *GetMyDatasetLi
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetDatasetVersionList(ctx context.Context, in *GetDatasetVersionListReq, opts ...grpc.CallOption) (*GetDatasetVersionListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetDatasetVersionListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetDatasetVersionList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetDatasetVersionList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -341,8 +336,9 @@ func (c *octopusClient) GetDatasetVersionList(ctx context.Context, in *GetDatase
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateDataSetResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateDataSet_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateDataSet_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -350,8 +346,9 @@ func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq,
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteDataSetResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteDataSet_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteDataSet_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -359,8 +356,9 @@ func (c *octopusClient) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq,
|
|||
}
|
||||
|
||||
func (c *octopusClient) UploadDataSet(ctx context.Context, in *UploadDataSetReq, opts ...grpc.CallOption) (*UploadDataSetResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(UploadDataSetResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadDataSet_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadDataSet_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -368,8 +366,9 @@ func (c *octopusClient) UploadDataSet(ctx context.Context, in *UploadDataSetReq,
|
|||
}
|
||||
|
||||
func (c *octopusClient) UploadDataSetConfirm(ctx context.Context, in *UploadDataSetConfirmReq, opts ...grpc.CallOption) (*UploadDataSetConfirmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(UploadDataSetConfirmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadDataSetConfirm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadDataSetConfirm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -377,8 +376,9 @@ func (c *octopusClient) UploadDataSetConfirm(ctx context.Context, in *UploadData
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateDataSetVersion(ctx context.Context, in *CreateDataSetVersionReq, opts ...grpc.CallOption) (*CreateDataSetVersionResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateDataSetVersionResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateDataSetVersion_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateDataSetVersion_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -386,8 +386,9 @@ func (c *octopusClient) CreateDataSetVersion(ctx context.Context, in *CreateData
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteDataSetVersion(ctx context.Context, in *DeleteDataSetVersionReq, opts ...grpc.CallOption) (*DeleteDataSetVersionResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteDataSetVersionResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteDataSetVersion_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteDataSetVersion_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -395,8 +396,9 @@ func (c *octopusClient) DeleteDataSetVersion(ctx context.Context, in *DeleteData
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetDatasetApplyList(ctx context.Context, in *GetDatasetApplyListReq, opts ...grpc.CallOption) (*GetDatasetApplyListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetDatasetApplyListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetDatasetApplyList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetDatasetApplyList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -404,8 +406,9 @@ func (c *octopusClient) GetDatasetApplyList(ctx context.Context, in *GetDatasetA
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetDatasetTypeList(ctx context.Context, in *GetDatasetTypeListRep, opts ...grpc.CallOption) (*GetDatasetTypeListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetDatasetTypeListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetDatasetTypeList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetDatasetTypeList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -413,8 +416,9 @@ func (c *octopusClient) GetDatasetTypeList(ctx context.Context, in *GetDatasetTy
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateModelDeploy(ctx context.Context, in *CreateModelDeployReq, opts ...grpc.CallOption) (*CreateModelDeployResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateModelDeployResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateModelDeploy_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateModelDeploy_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -422,8 +426,9 @@ func (c *octopusClient) CreateModelDeploy(ctx context.Context, in *CreateModelDe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetModelDeployList(ctx context.Context, in *GetModelDeployListReq, opts ...grpc.CallOption) (*GetModelDeployListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetModelDeployListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelDeployList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelDeployList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -431,8 +436,9 @@ func (c *octopusClient) GetModelDeployList(ctx context.Context, in *GetModelDepl
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetModelDeploy(ctx context.Context, in *GetModelDeployReq, opts ...grpc.CallOption) (*GetModelDeployResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetModelDeployResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelDeploy_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelDeploy_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -440,8 +446,9 @@ func (c *octopusClient) GetModelDeploy(ctx context.Context, in *GetModelDeployRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetModelDeployEvent(ctx context.Context, in *GetModelDeployEventReq, opts ...grpc.CallOption) (*GetModelDeployEventResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetModelDeployEventResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelDeployEvent_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelDeployEvent_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -449,8 +456,9 @@ func (c *octopusClient) GetModelDeployEvent(ctx context.Context, in *GetModelDep
|
|||
}
|
||||
|
||||
func (c *octopusClient) StopModelDeploy(ctx context.Context, in *StopModelDeployReq, opts ...grpc.CallOption) (*StopModelDeployResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(StopModelDeployResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_StopModelDeploy_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_StopModelDeploy_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -458,8 +466,9 @@ func (c *octopusClient) StopModelDeploy(ctx context.Context, in *StopModelDeploy
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteModelDeploy(ctx context.Context, in *DeleteModelDeployReq, opts ...grpc.CallOption) (*DeleteModelDeployResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteModelDeployResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteModelDeploy_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteModelDeploy_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -467,8 +476,9 @@ func (c *octopusClient) DeleteModelDeploy(ctx context.Context, in *DeleteModelDe
|
|||
}
|
||||
|
||||
func (c *octopusClient) InferModelDeploy(ctx context.Context, in *InferModelDeployReq, opts ...grpc.CallOption) (*InferModelDeployResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(InferModelDeployResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_InferModelDeploy_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_InferModelDeploy_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -476,8 +486,9 @@ func (c *octopusClient) InferModelDeploy(ctx context.Context, in *InferModelDepl
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetNotebookListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetNotebookList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetNotebookList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -485,8 +496,9 @@ func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookList
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetNotebook(ctx context.Context, in *GetNotebookReq, opts ...grpc.CallOption) (*GetNotebookResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetNotebookResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetNotebook_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetNotebook_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -494,8 +506,9 @@ func (c *octopusClient) GetNotebook(ctx context.Context, in *GetNotebookReq, opt
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteNotebook(ctx context.Context, in *DeleteNotebookReq, opts ...grpc.CallOption) (*DeleteNotebookResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteNotebookResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteNotebook_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteNotebook_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -503,8 +516,9 @@ func (c *octopusClient) DeleteNotebook(ctx context.Context, in *DeleteNotebookRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateNotebook(ctx context.Context, in *CreateNotebookReq, opts ...grpc.CallOption) (*CreateNotebookResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateNotebookResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateNotebook_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateNotebook_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -512,8 +526,9 @@ func (c *octopusClient) CreateNotebook(ctx context.Context, in *CreateNotebookRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) StartNotebook(ctx context.Context, in *StartNotebookReq, opts ...grpc.CallOption) (*StartNotebookResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(StartNotebookResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_StartNotebook_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_StartNotebook_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -521,8 +536,9 @@ func (c *octopusClient) StartNotebook(ctx context.Context, in *StartNotebookReq,
|
|||
}
|
||||
|
||||
func (c *octopusClient) StopNotebook(ctx context.Context, in *StopNotebookReq, opts ...grpc.CallOption) (*StopNotebookResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(StopNotebookResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_StopNotebook_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_StopNotebook_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -530,8 +546,9 @@ func (c *octopusClient) StopNotebook(ctx context.Context, in *StopNotebookReq, o
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetUserImageListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetUserImageList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetUserImageList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -539,8 +556,9 @@ func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageLi
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetPresetImageList(ctx context.Context, in *GetPresetImageListReq, opts ...grpc.CallOption) (*GetPresetImageListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetPresetImageListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetPresetImageList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetPresetImageList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -548,8 +566,9 @@ func (c *octopusClient) GetPresetImageList(ctx context.Context, in *GetPresetIma
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateImageResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateImage_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateImage_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -557,8 +576,9 @@ func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opt
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteImageResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteImage_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteImage_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -566,8 +586,9 @@ func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opt
|
|||
}
|
||||
|
||||
func (c *octopusClient) UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(UploadImageResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadImage_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadImage_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -575,8 +596,9 @@ func (c *octopusClient) UploadImage(ctx context.Context, in *UploadImageReq, opt
|
|||
}
|
||||
|
||||
func (c *octopusClient) UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(UploadImageConfirmResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadImageConfirm_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_UploadImageConfirm_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -584,8 +606,9 @@ func (c *octopusClient) UploadImageConfirm(ctx context.Context, in *UploadImageC
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetMyModelList(ctx context.Context, in *GetMyModelListReq, opts ...grpc.CallOption) (*GetMyModelListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetMyModelListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetMyModelList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetMyModelList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -593,8 +616,9 @@ func (c *octopusClient) GetMyModelList(ctx context.Context, in *GetMyModelListRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetModelVersionList(ctx context.Context, in *GetModelVersionListReq, opts ...grpc.CallOption) (*GetModelVersionListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetModelVersionListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelVersionList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetModelVersionList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -602,8 +626,9 @@ func (c *octopusClient) GetModelVersionList(ctx context.Context, in *GetModelVer
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteMyModel(ctx context.Context, in *DeleteMyModelReq, opts ...grpc.CallOption) (*DeleteMyModelResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteMyModelResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteMyModel_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteMyModel_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -611,8 +636,9 @@ func (c *octopusClient) DeleteMyModel(ctx context.Context, in *DeleteMyModelReq,
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteModelVersion(ctx context.Context, in *DeleteModelVersionReq, opts ...grpc.CallOption) (*DeleteModelVersionResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteModelVersionResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteModelVersion_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteModelVersion_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -620,8 +646,9 @@ func (c *octopusClient) DeleteModelVersion(ctx context.Context, in *DeleteModelV
|
|||
}
|
||||
|
||||
func (c *octopusClient) DownloadModelVersion(ctx context.Context, in *DownloadModelVersionReq, opts ...grpc.CallOption) (*DownloadModelVersionResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DownloadModelVersionResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadModelVersion_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DownloadModelVersion_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -629,8 +656,9 @@ func (c *octopusClient) DownloadModelVersion(ctx context.Context, in *DownloadMo
|
|||
}
|
||||
|
||||
func (c *octopusClient) CreateTrainJob(ctx context.Context, in *CreateTrainJobReq, opts ...grpc.CallOption) (*CreateTrainJobResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(CreateTrainJobResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateTrainJob_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_CreateTrainJob_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -638,8 +666,9 @@ func (c *octopusClient) CreateTrainJob(ctx context.Context, in *CreateTrainJobRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetTrainJobList(ctx context.Context, in *GetTrainJobListReq, opts ...grpc.CallOption) (*GetTrainJobListResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetTrainJobListResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobList_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobList_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -647,8 +676,9 @@ func (c *octopusClient) GetTrainJobList(ctx context.Context, in *GetTrainJobList
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetTrainJob(ctx context.Context, in *GetTrainJobReq, opts ...grpc.CallOption) (*GetTrainJobResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetTrainJobResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJob_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJob_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -656,8 +686,9 @@ func (c *octopusClient) GetTrainJob(ctx context.Context, in *GetTrainJobReq, opt
|
|||
}
|
||||
|
||||
func (c *octopusClient) DeleteTrainJob(ctx context.Context, in *DeleteTrainJobReq, opts ...grpc.CallOption) (*DeleteTrainJobResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(DeleteTrainJobResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteTrainJob_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_DeleteTrainJob_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -665,8 +696,9 @@ func (c *octopusClient) DeleteTrainJob(ctx context.Context, in *DeleteTrainJobRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) StopTrainJob(ctx context.Context, in *StopTrainJobReq, opts ...grpc.CallOption) (*StopTrainJobResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(StopTrainJobResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_StopTrainJob_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_StopTrainJob_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -674,8 +706,9 @@ func (c *octopusClient) StopTrainJob(ctx context.Context, in *StopTrainJobReq, o
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetTrainJobEvent(ctx context.Context, in *GetTrainJobEventReq, opts ...grpc.CallOption) (*GetTrainJobEventResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetTrainJobEventResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobEvent_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobEvent_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -683,8 +716,9 @@ func (c *octopusClient) GetTrainJobEvent(ctx context.Context, in *GetTrainJobEve
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetTrainJobMetric(ctx context.Context, in *GetTrainJobMetricReq, opts ...grpc.CallOption) (*GetTrainJobMetricResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetTrainJobMetricResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobMetric_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobMetric_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -692,8 +726,9 @@ func (c *octopusClient) GetTrainJobMetric(ctx context.Context, in *GetTrainJobMe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetTrainJobLog(ctx context.Context, in *GetTrainJobLogReq, opts ...grpc.CallOption) (*GetTrainJobLogResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetTrainJobLogResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobLog_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetTrainJobLog_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -701,8 +736,9 @@ func (c *octopusClient) GetTrainJobLog(ctx context.Context, in *GetTrainJobLogRe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetResourceSpecs(ctx context.Context, in *GetResourceSpecsReq, opts ...grpc.CallOption) (*GetResourceSpecsResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetResourceSpecsResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetResourceSpecs_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetResourceSpecs_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -710,8 +746,9 @@ func (c *octopusClient) GetResourceSpecs(ctx context.Context, in *GetResourceSpe
|
|||
}
|
||||
|
||||
func (c *octopusClient) GetUserBalance(ctx context.Context, in *GetUserBalanceReq, opts ...grpc.CallOption) (*GetUserBalanceResp, error) {
|
||||
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
||||
out := new(GetUserBalanceResp)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetUserBalance_FullMethodName, in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, Octopus_GetUserBalance_FullMethodName, in, out, cOpts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
@ -720,11 +757,11 @@ func (c *octopusClient) GetUserBalance(ctx context.Context, in *GetUserBalanceRe
|
|||
|
||||
// OctopusServer is the server API for Octopus service.
|
||||
// All implementations must embed UnimplementedOctopusServer
|
||||
// for forward compatibility
|
||||
// for forward compatibility.
|
||||
type OctopusServer interface {
|
||||
GetComputingPower(context.Context, *ResourceReq) (*CpResp, error)
|
||||
GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error)
|
||||
GetInferResult(Octopus_GetInferResultServer) error
|
||||
GetInferResult(grpc.ClientStreamingServer[InferResultReq, InferResultResp]) error
|
||||
// Algorithm
|
||||
GetMyAlgorithmList(context.Context, *GetMyAlgorithmListReq) (*GetMyAlgorithmListResp, error)
|
||||
GetAlgorithmList(context.Context, *GetAlgorithmListReq) (*GetAlgorithmListResp, error)
|
||||
|
|
@ -793,9 +830,12 @@ type OctopusServer interface {
|
|||
mustEmbedUnimplementedOctopusServer()
|
||||
}
|
||||
|
||||
// UnimplementedOctopusServer must be embedded to have forward compatible implementations.
|
||||
type UnimplementedOctopusServer struct {
|
||||
}
|
||||
// UnimplementedOctopusServer must be embedded to have
|
||||
// forward compatible implementations.
|
||||
//
|
||||
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
||||
// pointer dereference when methods are called.
|
||||
type UnimplementedOctopusServer struct{}
|
||||
|
||||
func (UnimplementedOctopusServer) GetComputingPower(context.Context, *ResourceReq) (*CpResp, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetComputingPower not implemented")
|
||||
|
|
@ -803,7 +843,7 @@ func (UnimplementedOctopusServer) GetComputingPower(context.Context, *ResourceRe
|
|||
func (UnimplementedOctopusServer) GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetGeneralInfo not implemented")
|
||||
}
|
||||
func (UnimplementedOctopusServer) GetInferResult(Octopus_GetInferResultServer) error {
|
||||
func (UnimplementedOctopusServer) GetInferResult(grpc.ClientStreamingServer[InferResultReq, InferResultResp]) error {
|
||||
return status.Errorf(codes.Unimplemented, "method GetInferResult not implemented")
|
||||
}
|
||||
func (UnimplementedOctopusServer) GetMyAlgorithmList(context.Context, *GetMyAlgorithmListReq) (*GetMyAlgorithmListResp, error) {
|
||||
|
|
@ -975,6 +1015,7 @@ func (UnimplementedOctopusServer) GetUserBalance(context.Context, *GetUserBalanc
|
|||
return nil, status.Errorf(codes.Unimplemented, "method GetUserBalance not implemented")
|
||||
}
|
||||
func (UnimplementedOctopusServer) mustEmbedUnimplementedOctopusServer() {}
|
||||
func (UnimplementedOctopusServer) testEmbeddedByValue() {}
|
||||
|
||||
// UnsafeOctopusServer may be embedded to opt out of forward compatibility for this service.
|
||||
// Use of this interface is not recommended, as added methods to OctopusServer will
|
||||
|
|
@ -984,6 +1025,13 @@ type UnsafeOctopusServer interface {
|
|||
}
|
||||
|
||||
func RegisterOctopusServer(s grpc.ServiceRegistrar, srv OctopusServer) {
|
||||
// If the following call pancis, it indicates UnimplementedOctopusServer was
|
||||
// embedded by pointer and is nil. This will cause panics if an
|
||||
// unimplemented method is ever invoked, so we test this at initialization
|
||||
// time to prevent it from happening at runtime later due to I/O.
|
||||
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
||||
t.testEmbeddedByValue()
|
||||
}
|
||||
s.RegisterService(&Octopus_ServiceDesc, srv)
|
||||
}
|
||||
|
||||
|
|
@ -1024,30 +1072,11 @@ func _Octopus_GetGeneralInfo_Handler(srv interface{}, ctx context.Context, dec f
|
|||
}
|
||||
|
||||
func _Octopus_GetInferResult_Handler(srv interface{}, stream grpc.ServerStream) error {
|
||||
return srv.(OctopusServer).GetInferResult(&octopusGetInferResultServer{stream})
|
||||
return srv.(OctopusServer).GetInferResult(&grpc.GenericServerStream[InferResultReq, InferResultResp]{ServerStream: stream})
|
||||
}
|
||||
|
||||
type Octopus_GetInferResultServer interface {
|
||||
SendAndClose(*InferResultResp) error
|
||||
Recv() (*InferResultReq, error)
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
type octopusGetInferResultServer struct {
|
||||
grpc.ServerStream
|
||||
}
|
||||
|
||||
func (x *octopusGetInferResultServer) SendAndClose(m *InferResultResp) error {
|
||||
return x.ServerStream.SendMsg(m)
|
||||
}
|
||||
|
||||
func (x *octopusGetInferResultServer) Recv() (*InferResultReq, error) {
|
||||
m := new(InferResultReq)
|
||||
if err := x.ServerStream.RecvMsg(m); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return m, nil
|
||||
}
|
||||
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
||||
type Octopus_GetInferResultServer = grpc.ClientStreamingServer[InferResultReq, InferResultResp]
|
||||
|
||||
func _Octopus_GetMyAlgorithmList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||
in := new(GetMyAlgorithmListReq)
|
||||
|
|
|
|||
|
|
@ -1,4 +1,5 @@
|
|||
// Code generated by goctl. DO NOT EDIT.
|
||||
// goctl 1.7.2
|
||||
// Source: octopus.proto
|
||||
|
||||
package octopusclient
|
||||
|
|
|
|||
Loading…
Reference in New Issue