| @@ -2,11 +2,12 @@ package pod | |||||
| import ( | import ( | ||||
| "context" | "context" | ||||
| "sync" | |||||
| "gitlink.org.cn/JCCE/PCM/adaptor/pod_adaptor/service/poder" | "gitlink.org.cn/JCCE/PCM/adaptor/pod_adaptor/service/poder" | ||||
| "gitlink.org.cn/JCCE/PCM/common/tenanter" | "gitlink.org.cn/JCCE/PCM/common/tenanter" | ||||
| "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | ||||
| "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant" | "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant" | ||||
| "sync" | |||||
| "github.com/golang/glog" | "github.com/golang/glog" | ||||
| "github.com/pkg/errors" | "github.com/pkg/errors" | ||||
| @@ -39,6 +40,33 @@ func CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (*pbpod.CreatePodRe | |||||
| return pod.CreatePod(ctx, req) | return pod.CreatePod(ctx, req) | ||||
| } | } | ||||
| func DeletePod(ctx context.Context, req *pbpod.DeletePodReq) (*pbpod.DeletePodResp, error) { | |||||
| var ( | |||||
| pod poder.Poder | |||||
| ) | |||||
| tenanters, err := tenanter.GetTenanters(req.Provider) | |||||
| if err != nil { | |||||
| return nil, errors.WithMessage(err, "getTenanters error") | |||||
| } | |||||
| region, err := tenanter.NewRegion(req.Provider, req.RegionId) | |||||
| if err != nil { | |||||
| return nil, errors.WithMessagef(err, "provider %v regionId %v", req.Provider, req.RegionId) | |||||
| } | |||||
| for _, tenanter := range tenanters { | |||||
| if req.AccountName == "" || tenanter.AccountName() == req.AccountName { | |||||
| if pod, err = poder.NewPodClient(req.Provider, region, tenanter); err != nil { | |||||
| return nil, errors.WithMessage(err, "NewPodClient error") | |||||
| } | |||||
| break | |||||
| } | |||||
| } | |||||
| return pod.DeletePod(ctx, req) | |||||
| } | |||||
| func ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (*pbpod.ListPodDetailResp, error) { | func ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (*pbpod.ListPodDetailResp, error) { | ||||
| var ( | var ( | ||||
| pod poder.Poder | pod poder.Poder | ||||
| @@ -2,11 +2,12 @@ package poder | |||||
| import ( | import ( | ||||
| "context" | "context" | ||||
| "strconv" | |||||
| "sync" | |||||
| "gitlink.org.cn/JCCE/PCM/common/tenanter" | "gitlink.org.cn/JCCE/PCM/common/tenanter" | ||||
| "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | ||||
| "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant" | "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant" | ||||
| "strconv" | |||||
| "sync" | |||||
| alieci "github.com/aliyun/alibaba-cloud-sdk-go/services/eci" | alieci "github.com/aliyun/alibaba-cloud-sdk-go/services/eci" | ||||
| "github.com/pkg/errors" | "github.com/pkg/errors" | ||||
| @@ -72,6 +73,11 @@ func (eci *AliEci) CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (*pbp | |||||
| }, nil | }, nil | ||||
| } | } | ||||
| func (eci *AliEci) DeletePod(ctx context.Context, req *pbpod.DeletePodReq) (*pbpod.DeletePodResp, error) { | |||||
| //TODO implement ali eci delete pod | |||||
| return nil, nil | |||||
| } | |||||
| func (eci *AliEci) ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (*pbpod.ListPodDetailResp, error) { | func (eci *AliEci) ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (*pbpod.ListPodDetailResp, error) { | ||||
| request := alieci.CreateDescribeContainerGroupsRequest() | request := alieci.CreateDescribeContainerGroupsRequest() | ||||
| request.NextToken = req.NextToken | request.NextToken = req.NextToken | ||||
| @@ -161,3 +161,22 @@ func (cci *HuaweiCci) CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (* | |||||
| //RequestId: resp.RequestId, | //RequestId: resp.RequestId, | ||||
| }, nil | }, nil | ||||
| } | } | ||||
| func (cci *HuaweiCci) DeletePod(ctx context.Context, req *pbpod.DeletePodReq) (*pbpod.DeletePodResp, error) { | |||||
| podName := req.PodName | |||||
| fmt.Println("Huawei ContainerGroup:", podName, " Deleted") | |||||
| err := cci.cli.CoreV1().Pods(req.Namespace).Delete(podName, &metav1.DeleteOptions{}) | |||||
| glog.Info("Huawei create pod resp", err) | |||||
| isFinished := true | |||||
| if err != nil { | |||||
| isFinished = false | |||||
| return nil, errors.Wrap(err, "Huaweiyun DeletePod error") | |||||
| } | |||||
| return &pbpod.DeletePodResp{ | |||||
| //Pods: err, | |||||
| Finished: isFinished, | |||||
| //RequestId: resp.RequestId, | |||||
| }, nil | |||||
| } | |||||
| @@ -19,6 +19,7 @@ var ( | |||||
| type Poder interface { | type Poder interface { | ||||
| ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (resp *pbpod.ListPodDetailResp, err error) | ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (resp *pbpod.ListPodDetailResp, err error) | ||||
| CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (resp *pbpod.CreatePodResp, err error) | CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (resp *pbpod.CreatePodResp, err error) | ||||
| DeletePod(ctx context.Context, req *pbpod.DeletePodReq) (*pbpod.DeletePodResp, error) | |||||
| } | } | ||||
| func NewPodClient(provider pbtenant.CloudProvider, region tenanter.Region, tenant tenanter.Tenanter) (poder Poder, err error) { | func NewPodClient(provider pbtenant.CloudProvider, region tenanter.Region, tenant tenanter.Tenanter) (poder Poder, err error) { | ||||
| @@ -2,14 +2,15 @@ package poder | |||||
| import ( | import ( | ||||
| "context" | "context" | ||||
| "strconv" | |||||
| "sync" | |||||
| "github.com/pkg/errors" | "github.com/pkg/errors" | ||||
| "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common" | "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common" | ||||
| "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile" | "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile" | ||||
| tencenteks "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525" | tencenteks "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525" | ||||
| "gitlink.org.cn/JCCE/PCM/common/tenanter" | "gitlink.org.cn/JCCE/PCM/common/tenanter" | ||||
| "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | ||||
| "strconv" | |||||
| "sync" | |||||
| ) | ) | ||||
| var tencentClientMutex sync.Mutex | var tencentClientMutex sync.Mutex | ||||
| @@ -102,6 +103,11 @@ func (eks TencentEks) CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (* | |||||
| } | } | ||||
| func (eks *TencentEks) DeletePod(ctx context.Context, req *pbpod.DeletePodReq) (*pbpod.DeletePodResp, error) { | |||||
| //TODO implement ali eci delete pod | |||||
| return nil, nil | |||||
| } | |||||
| func (eks TencentEks) ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (resp *pbpod.ListPodDetailResp, err error) { | func (eks TencentEks) ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (resp *pbpod.ListPodDetailResp, err error) { | ||||
| //TODO implement me | //TODO implement me | ||||
| panic("implement me") | panic("implement me") | ||||
| @@ -2,6 +2,7 @@ package server | |||||
| import ( | import ( | ||||
| "context" | "context" | ||||
| "gitlink.org.cn/JCCE/PCM/adaptor/pod_adaptor/server/pod" | "gitlink.org.cn/JCCE/PCM/adaptor/pod_adaptor/server/pod" | ||||
| "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | "gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod" | ||||
| @@ -19,6 +20,15 @@ func (s *Server) CreatePod(ctx context.Context, req *pbpod.CreatePodReq) (*pbpod | |||||
| return resp, nil | return resp, nil | ||||
| } | } | ||||
| func (s *Server) DeletePod(ctx context.Context, req *pbpod.DeletePodReq) (*pbpod.DeletePodResp, error) { | |||||
| resp, err := pod.DeletePod(ctx, req) | |||||
| if err != nil { | |||||
| glog.Errorf("DeletePod error %+v", err) | |||||
| return nil, status.Errorf(codes.Internal, err.Error()) | |||||
| } | |||||
| return resp, nil | |||||
| } | |||||
| func (s *Server) ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (*pbpod.ListPodDetailResp, error) { | func (s *Server) ListPodDetail(ctx context.Context, req *pbpod.ListPodDetailReq) (*pbpod.ListPodDetailResp, error) { | ||||
| resp, err := pod.ListPodDetail(ctx, req) | resp, err := pod.ListPodDetail(ctx, req) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -75,6 +75,27 @@ message CreatePodResp { | |||||
| string request_id = 3; | string request_id = 3; | ||||
| } | } | ||||
| message DeletePodReq { | |||||
| // 云类型 | |||||
| pbtenant.CloudProvider provider = 1; | |||||
| // 账号名称 | |||||
| string account_name = 2; | |||||
| // 实例名称 | |||||
| string pod_name = 3; | |||||
| //namespace | |||||
| string namespace = 4; | |||||
| // 地域,数据中心 | |||||
| int32 region_id = 5; | |||||
| } | |||||
| message DeletePodResp { | |||||
| // Pod集合 | |||||
| repeated PodInstance pods = 1; | |||||
| // 查询是否完成,如果为否-false,则可以将下面三个分页参数填入到请求中,继续查询 | |||||
| bool finished = 2; | |||||
| // 请求id,出现问题后提供给云厂商,排查问题 | |||||
| string request_id = 3; | |||||
| } | |||||
| message ListPodDetailReq { | message ListPodDetailReq { | ||||
| // 云名称 | // 云名称 | ||||
| @@ -138,6 +159,13 @@ service PodService { | |||||
| }; | }; | ||||
| } | } | ||||
| // 删除Pod | |||||
| rpc DeletePod(DeletePodReq) returns (DeletePodResp) { | |||||
| option (google.api.http) = { | |||||
| post : "/apis/pod/delete/{namespace}/{pod_name}" | |||||
| body : "*" | |||||
| }; | |||||
| } | |||||
| // 查询Pod明细 | // 查询Pod明细 | ||||
| rpc ListPodDetail(ListPodDetailReq) returns (ListPodDetailResp) { | rpc ListPodDetail(ListPodDetailReq) returns (ListPodDetailResp) { | ||||
| @@ -77,12 +77,13 @@ func RegisterDemoServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/demo.DemoService/Echo") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/demo.DemoService/Echo", runtime.WithHTTPPathPattern("/apis/demo")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_DemoService_Echo_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_DemoService_Echo_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -139,12 +140,13 @@ func RegisterDemoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/demo.DemoService/Echo") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/demo.DemoService/Echo", runtime.WithHTTPPathPattern("/apis/demo")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_DemoService_Echo_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_DemoService_Echo_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -145,12 +145,13 @@ func RegisterEcsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbecs.EcsService/ListEcsDetail") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbecs.EcsService/ListEcsDetail", runtime.WithHTTPPathPattern("/apis/ecs/detail")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_EcsService_ListEcsDetail_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_EcsService_ListEcsDetail_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -168,12 +169,13 @@ func RegisterEcsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbecs.EcsService/ListEcs") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbecs.EcsService/ListEcs", runtime.WithHTTPPathPattern("/apis/ecs")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_EcsService_ListEcs_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_EcsService_ListEcs_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -191,12 +193,13 @@ func RegisterEcsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbecs.EcsService/ListEcsAll") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbecs.EcsService/ListEcsAll", runtime.WithHTTPPathPattern("/apis/ecs/all")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_EcsService_ListEcsAll_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_EcsService_ListEcsAll_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -253,12 +256,13 @@ func RegisterEcsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbecs.EcsService/ListEcsDetail") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbecs.EcsService/ListEcsDetail", runtime.WithHTTPPathPattern("/apis/ecs/detail")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_EcsService_ListEcsDetail_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_EcsService_ListEcsDetail_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -273,12 +277,13 @@ func RegisterEcsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbecs.EcsService/ListEcs") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbecs.EcsService/ListEcs", runtime.WithHTTPPathPattern("/apis/ecs")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_EcsService_ListEcs_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_EcsService_ListEcs_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -293,12 +298,13 @@ func RegisterEcsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbecs.EcsService/ListEcsAll") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbecs.EcsService/ListEcsAll", runtime.WithHTTPPathPattern("/apis/ecs/all")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_EcsService_ListEcsAll_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_EcsService_ListEcsAll_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -400,6 +400,156 @@ func (x *CreatePodResp) GetRequestId() string { | |||||
| return "" | return "" | ||||
| } | } | ||||
| type DeletePodReq struct { | |||||
| state protoimpl.MessageState | |||||
| sizeCache protoimpl.SizeCache | |||||
| unknownFields protoimpl.UnknownFields | |||||
| // 云类型 | |||||
| Provider pbtenant.CloudProvider `protobuf:"varint,1,opt,name=provider,proto3,enum=pbtenant.CloudProvider" json:"provider,omitempty"` | |||||
| // 账号名称 | |||||
| AccountName string `protobuf:"bytes,2,opt,name=account_name,json=accountName,proto3" json:"account_name,omitempty"` | |||||
| // 实例名称 | |||||
| PodName string `protobuf:"bytes,3,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"` | |||||
| //namespace | |||||
| Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` | |||||
| // 地域,数据中心 | |||||
| RegionId int32 `protobuf:"varint,5,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` | |||||
| } | |||||
| func (x *DeletePodReq) Reset() { | |||||
| *x = DeletePodReq{} | |||||
| if protoimpl.UnsafeEnabled { | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[3] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | |||||
| ms.StoreMessageInfo(mi) | |||||
| } | |||||
| } | |||||
| func (x *DeletePodReq) String() string { | |||||
| return protoimpl.X.MessageStringOf(x) | |||||
| } | |||||
| func (*DeletePodReq) ProtoMessage() {} | |||||
| func (x *DeletePodReq) ProtoReflect() protoreflect.Message { | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[3] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | |||||
| if ms.LoadMessageInfo() == nil { | |||||
| ms.StoreMessageInfo(mi) | |||||
| } | |||||
| return ms | |||||
| } | |||||
| return mi.MessageOf(x) | |||||
| } | |||||
| // Deprecated: Use DeletePodReq.ProtoReflect.Descriptor instead. | |||||
| func (*DeletePodReq) Descriptor() ([]byte, []int) { | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{3} | |||||
| } | |||||
| func (x *DeletePodReq) GetProvider() pbtenant.CloudProvider { | |||||
| if x != nil { | |||||
| return x.Provider | |||||
| } | |||||
| return pbtenant.CloudProvider(0) | |||||
| } | |||||
| func (x *DeletePodReq) GetAccountName() string { | |||||
| if x != nil { | |||||
| return x.AccountName | |||||
| } | |||||
| return "" | |||||
| } | |||||
| func (x *DeletePodReq) GetPodName() string { | |||||
| if x != nil { | |||||
| return x.PodName | |||||
| } | |||||
| return "" | |||||
| } | |||||
| func (x *DeletePodReq) GetNamespace() string { | |||||
| if x != nil { | |||||
| return x.Namespace | |||||
| } | |||||
| return "" | |||||
| } | |||||
| func (x *DeletePodReq) GetRegionId() int32 { | |||||
| if x != nil { | |||||
| return x.RegionId | |||||
| } | |||||
| return 0 | |||||
| } | |||||
| type DeletePodResp struct { | |||||
| state protoimpl.MessageState | |||||
| sizeCache protoimpl.SizeCache | |||||
| unknownFields protoimpl.UnknownFields | |||||
| // Pod集合 | |||||
| Pods []*PodInstance `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"` | |||||
| // 查询是否完成,如果为否-false,则可以将下面三个分页参数填入到请求中,继续查询 | |||||
| Finished bool `protobuf:"varint,2,opt,name=finished,proto3" json:"finished,omitempty"` | |||||
| // 请求id,出现问题后提供给云厂商,排查问题 | |||||
| RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` | |||||
| } | |||||
| func (x *DeletePodResp) Reset() { | |||||
| *x = DeletePodResp{} | |||||
| if protoimpl.UnsafeEnabled { | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[4] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | |||||
| ms.StoreMessageInfo(mi) | |||||
| } | |||||
| } | |||||
| func (x *DeletePodResp) String() string { | |||||
| return protoimpl.X.MessageStringOf(x) | |||||
| } | |||||
| func (*DeletePodResp) ProtoMessage() {} | |||||
| func (x *DeletePodResp) ProtoReflect() protoreflect.Message { | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[4] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | |||||
| if ms.LoadMessageInfo() == nil { | |||||
| ms.StoreMessageInfo(mi) | |||||
| } | |||||
| return ms | |||||
| } | |||||
| return mi.MessageOf(x) | |||||
| } | |||||
| // Deprecated: Use DeletePodResp.ProtoReflect.Descriptor instead. | |||||
| func (*DeletePodResp) Descriptor() ([]byte, []int) { | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{4} | |||||
| } | |||||
| func (x *DeletePodResp) GetPods() []*PodInstance { | |||||
| if x != nil { | |||||
| return x.Pods | |||||
| } | |||||
| return nil | |||||
| } | |||||
| func (x *DeletePodResp) GetFinished() bool { | |||||
| if x != nil { | |||||
| return x.Finished | |||||
| } | |||||
| return false | |||||
| } | |||||
| func (x *DeletePodResp) GetRequestId() string { | |||||
| if x != nil { | |||||
| return x.RequestId | |||||
| } | |||||
| return "" | |||||
| } | |||||
| type ListPodDetailReq struct { | type ListPodDetailReq struct { | ||||
| state protoimpl.MessageState | state protoimpl.MessageState | ||||
| sizeCache protoimpl.SizeCache | sizeCache protoimpl.SizeCache | ||||
| @@ -426,7 +576,7 @@ type ListPodDetailReq struct { | |||||
| func (x *ListPodDetailReq) Reset() { | func (x *ListPodDetailReq) Reset() { | ||||
| *x = ListPodDetailReq{} | *x = ListPodDetailReq{} | ||||
| if protoimpl.UnsafeEnabled { | if protoimpl.UnsafeEnabled { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[3] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[5] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| ms.StoreMessageInfo(mi) | ms.StoreMessageInfo(mi) | ||||
| } | } | ||||
| @@ -439,7 +589,7 @@ func (x *ListPodDetailReq) String() string { | |||||
| func (*ListPodDetailReq) ProtoMessage() {} | func (*ListPodDetailReq) ProtoMessage() {} | ||||
| func (x *ListPodDetailReq) ProtoReflect() protoreflect.Message { | func (x *ListPodDetailReq) ProtoReflect() protoreflect.Message { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[3] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[5] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | if protoimpl.UnsafeEnabled && x != nil { | ||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| if ms.LoadMessageInfo() == nil { | if ms.LoadMessageInfo() == nil { | ||||
| @@ -452,7 +602,7 @@ func (x *ListPodDetailReq) ProtoReflect() protoreflect.Message { | |||||
| // Deprecated: Use ListPodDetailReq.ProtoReflect.Descriptor instead. | // Deprecated: Use ListPodDetailReq.ProtoReflect.Descriptor instead. | ||||
| func (*ListPodDetailReq) Descriptor() ([]byte, []int) { | func (*ListPodDetailReq) Descriptor() ([]byte, []int) { | ||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{3} | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{5} | |||||
| } | } | ||||
| func (x *ListPodDetailReq) GetProvider() pbtenant.CloudProvider { | func (x *ListPodDetailReq) GetProvider() pbtenant.CloudProvider { | ||||
| @@ -533,7 +683,7 @@ type ListPodDetailResp struct { | |||||
| func (x *ListPodDetailResp) Reset() { | func (x *ListPodDetailResp) Reset() { | ||||
| *x = ListPodDetailResp{} | *x = ListPodDetailResp{} | ||||
| if protoimpl.UnsafeEnabled { | if protoimpl.UnsafeEnabled { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[4] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[6] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| ms.StoreMessageInfo(mi) | ms.StoreMessageInfo(mi) | ||||
| } | } | ||||
| @@ -546,7 +696,7 @@ func (x *ListPodDetailResp) String() string { | |||||
| func (*ListPodDetailResp) ProtoMessage() {} | func (*ListPodDetailResp) ProtoMessage() {} | ||||
| func (x *ListPodDetailResp) ProtoReflect() protoreflect.Message { | func (x *ListPodDetailResp) ProtoReflect() protoreflect.Message { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[4] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[6] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | if protoimpl.UnsafeEnabled && x != nil { | ||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| if ms.LoadMessageInfo() == nil { | if ms.LoadMessageInfo() == nil { | ||||
| @@ -559,7 +709,7 @@ func (x *ListPodDetailResp) ProtoReflect() protoreflect.Message { | |||||
| // Deprecated: Use ListPodDetailResp.ProtoReflect.Descriptor instead. | // Deprecated: Use ListPodDetailResp.ProtoReflect.Descriptor instead. | ||||
| func (*ListPodDetailResp) Descriptor() ([]byte, []int) { | func (*ListPodDetailResp) Descriptor() ([]byte, []int) { | ||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{4} | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{6} | |||||
| } | } | ||||
| func (x *ListPodDetailResp) GetPods() []*PodInstance { | func (x *ListPodDetailResp) GetPods() []*PodInstance { | ||||
| @@ -616,7 +766,7 @@ type ListPodReq struct { | |||||
| func (x *ListPodReq) Reset() { | func (x *ListPodReq) Reset() { | ||||
| *x = ListPodReq{} | *x = ListPodReq{} | ||||
| if protoimpl.UnsafeEnabled { | if protoimpl.UnsafeEnabled { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[5] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[7] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| ms.StoreMessageInfo(mi) | ms.StoreMessageInfo(mi) | ||||
| } | } | ||||
| @@ -629,7 +779,7 @@ func (x *ListPodReq) String() string { | |||||
| func (*ListPodReq) ProtoMessage() {} | func (*ListPodReq) ProtoMessage() {} | ||||
| func (x *ListPodReq) ProtoReflect() protoreflect.Message { | func (x *ListPodReq) ProtoReflect() protoreflect.Message { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[5] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[7] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | if protoimpl.UnsafeEnabled && x != nil { | ||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| if ms.LoadMessageInfo() == nil { | if ms.LoadMessageInfo() == nil { | ||||
| @@ -642,7 +792,7 @@ func (x *ListPodReq) ProtoReflect() protoreflect.Message { | |||||
| // Deprecated: Use ListPodReq.ProtoReflect.Descriptor instead. | // Deprecated: Use ListPodReq.ProtoReflect.Descriptor instead. | ||||
| func (*ListPodReq) Descriptor() ([]byte, []int) { | func (*ListPodReq) Descriptor() ([]byte, []int) { | ||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{5} | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{7} | |||||
| } | } | ||||
| func (x *ListPodReq) GetProvider() pbtenant.CloudProvider { | func (x *ListPodReq) GetProvider() pbtenant.CloudProvider { | ||||
| @@ -664,7 +814,7 @@ type ListPodResp struct { | |||||
| func (x *ListPodResp) Reset() { | func (x *ListPodResp) Reset() { | ||||
| *x = ListPodResp{} | *x = ListPodResp{} | ||||
| if protoimpl.UnsafeEnabled { | if protoimpl.UnsafeEnabled { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[6] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[8] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| ms.StoreMessageInfo(mi) | ms.StoreMessageInfo(mi) | ||||
| } | } | ||||
| @@ -677,7 +827,7 @@ func (x *ListPodResp) String() string { | |||||
| func (*ListPodResp) ProtoMessage() {} | func (*ListPodResp) ProtoMessage() {} | ||||
| func (x *ListPodResp) ProtoReflect() protoreflect.Message { | func (x *ListPodResp) ProtoReflect() protoreflect.Message { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[6] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[8] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | if protoimpl.UnsafeEnabled && x != nil { | ||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| if ms.LoadMessageInfo() == nil { | if ms.LoadMessageInfo() == nil { | ||||
| @@ -690,7 +840,7 @@ func (x *ListPodResp) ProtoReflect() protoreflect.Message { | |||||
| // Deprecated: Use ListPodResp.ProtoReflect.Descriptor instead. | // Deprecated: Use ListPodResp.ProtoReflect.Descriptor instead. | ||||
| func (*ListPodResp) Descriptor() ([]byte, []int) { | func (*ListPodResp) Descriptor() ([]byte, []int) { | ||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{6} | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{8} | |||||
| } | } | ||||
| func (x *ListPodResp) GetPods() []*PodInstance { | func (x *ListPodResp) GetPods() []*PodInstance { | ||||
| @@ -709,7 +859,7 @@ type ListPodAllReq struct { | |||||
| func (x *ListPodAllReq) Reset() { | func (x *ListPodAllReq) Reset() { | ||||
| *x = ListPodAllReq{} | *x = ListPodAllReq{} | ||||
| if protoimpl.UnsafeEnabled { | if protoimpl.UnsafeEnabled { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[7] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[9] | |||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| ms.StoreMessageInfo(mi) | ms.StoreMessageInfo(mi) | ||||
| } | } | ||||
| @@ -722,7 +872,7 @@ func (x *ListPodAllReq) String() string { | |||||
| func (*ListPodAllReq) ProtoMessage() {} | func (*ListPodAllReq) ProtoMessage() {} | ||||
| func (x *ListPodAllReq) ProtoReflect() protoreflect.Message { | func (x *ListPodAllReq) ProtoReflect() protoreflect.Message { | ||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[7] | |||||
| mi := &file_idl_pbpod_pod_proto_msgTypes[9] | |||||
| if protoimpl.UnsafeEnabled && x != nil { | if protoimpl.UnsafeEnabled && x != nil { | ||||
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) | ||||
| if ms.LoadMessageInfo() == nil { | if ms.LoadMessageInfo() == nil { | ||||
| @@ -735,7 +885,7 @@ func (x *ListPodAllReq) ProtoReflect() protoreflect.Message { | |||||
| // Deprecated: Use ListPodAllReq.ProtoReflect.Descriptor instead. | // Deprecated: Use ListPodAllReq.ProtoReflect.Descriptor instead. | ||||
| func (*ListPodAllReq) Descriptor() ([]byte, []int) { | func (*ListPodAllReq) Descriptor() ([]byte, []int) { | ||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{7} | |||||
| return file_idl_pbpod_pod_proto_rawDescGZIP(), []int{9} | |||||
| } | } | ||||
| var File_idl_pbpod_pod_proto protoreflect.FileDescriptor | var File_idl_pbpod_pod_proto protoreflect.FileDescriptor | ||||
| @@ -809,72 +959,98 @@ var file_idl_pbpod_pod_proto_rawDesc = []byte{ | |||||
| 0x69, 0x73, 0x68, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x66, 0x69, 0x6e, | 0x69, 0x73, 0x68, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x66, 0x69, 0x6e, | ||||
| 0x69, 0x73, 0x68, 0x65, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, | 0x69, 0x73, 0x68, 0x65, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, | ||||
| 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, | 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x71, 0x75, 0x65, | ||||
| 0x73, 0x74, 0x49, 0x64, 0x22, 0x99, 0x02, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, | |||||
| 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x12, 0x33, 0x0a, 0x08, 0x70, 0x72, 0x6f, | |||||
| 0x76, 0x69, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x70, 0x62, | |||||
| 0x74, 0x65, 0x6e, 0x61, 0x6e, 0x74, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x50, 0x72, 0x6f, 0x76, | |||||
| 0x69, 0x64, 0x65, 0x72, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x12, 0x21, | |||||
| 0x0a, 0x0c, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, | |||||
| 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x4e, 0x61, 0x6d, | |||||
| 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x03, | |||||
| 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x15, | |||||
| 0x0a, 0x06, 0x70, 0x6f, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, | |||||
| 0x70, 0x6f, 0x64, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x75, | |||||
| 0x6d, 0x62, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x70, 0x61, 0x67, 0x65, | |||||
| 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, | |||||
| 0x69, 0x7a, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, | |||||
| 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x74, 0x6f, 0x6b, 0x65, | |||||
| 0x6e, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x65, 0x78, 0x74, 0x54, 0x6f, 0x6b, | |||||
| 0x65, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, | |||||
| 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, | |||||
| 0x22, 0xd3, 0x01, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, 0x65, 0x74, 0x61, | |||||
| 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x12, 0x26, 0x0a, 0x04, 0x70, 0x6f, 0x64, 0x73, 0x18, 0x01, | |||||
| 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x50, 0x6f, 0x64, | |||||
| 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x52, 0x04, 0x70, 0x6f, 0x64, 0x73, 0x12, 0x1a, | |||||
| 0x0a, 0x08, 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, | |||||
| 0x52, 0x08, 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x61, | |||||
| 0x67, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, | |||||
| 0x0a, 0x70, 0x61, 0x67, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, | |||||
| 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, | |||||
| 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x6e, 0x65, 0x78, 0x74, | |||||
| 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x65, | |||||
| 0x78, 0x74, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, 0x65, | |||||
| 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x71, | |||||
| 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0x41, 0x0a, 0x0a, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, | |||||
| 0x64, 0x52, 0x65, 0x71, 0x12, 0x33, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, | |||||
| 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x70, 0x62, 0x74, 0x65, 0x6e, 0x61, 0x6e, | |||||
| 0x74, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x52, | |||||
| 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x22, 0x35, 0x0a, 0x0b, 0x4c, 0x69, 0x73, | |||||
| 0x74, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x12, 0x26, 0x0a, 0x04, 0x70, 0x6f, 0x64, 0x73, | |||||
| 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x50, | |||||
| 0x6f, 0x64, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x52, 0x04, 0x70, 0x6f, 0x64, 0x73, | |||||
| 0x22, 0x0f, 0x0a, 0x0d, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x41, 0x6c, 0x6c, 0x52, 0x65, | |||||
| 0x71, 0x32, 0xdc, 0x02, 0x0a, 0x0a, 0x50, 0x6f, 0x64, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, | |||||
| 0x12, 0x53, 0x0a, 0x09, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x6f, 0x64, 0x12, 0x13, 0x2e, | |||||
| 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x6f, 0x64, 0x52, | |||||
| 0x65, 0x71, 0x1a, 0x14, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, | |||||
| 0x65, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x22, 0x1b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x15, | |||||
| 0x22, 0x10, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x2f, 0x63, 0x72, 0x65, 0x61, | |||||
| 0x74, 0x65, 0x3a, 0x01, 0x2a, 0x12, 0x5f, 0x0a, 0x0d, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, | |||||
| 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, | |||||
| 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x1a, | |||||
| 0x18, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, | |||||
| 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x22, 0x1b, 0x82, 0xd3, 0xe4, 0x93, 0x02, | |||||
| 0x15, 0x22, 0x10, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x2f, 0x64, 0x65, 0x74, | |||||
| 0x61, 0x69, 0x6c, 0x3a, 0x01, 0x2a, 0x12, 0x46, 0x0a, 0x07, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, | |||||
| 0x64, 0x12, 0x11, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, | |||||
| 0x64, 0x52, 0x65, 0x71, 0x1a, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, | |||||
| 0x74, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x22, 0x14, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x0e, | |||||
| 0x22, 0x09, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x3a, 0x01, 0x2a, 0x12, 0x50, | |||||
| 0x0a, 0x0a, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x41, 0x6c, 0x6c, 0x12, 0x14, 0x2e, 0x70, | |||||
| 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x41, 0x6c, 0x6c, 0x52, | |||||
| 0x65, 0x71, 0x1a, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, | |||||
| 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x22, 0x18, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x12, 0x22, 0x0d, | |||||
| 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x2f, 0x61, 0x6c, 0x6c, 0x3a, 0x01, 0x2a, | |||||
| 0x42, 0x2d, 0x5a, 0x2b, 0x67, 0x69, 0x74, 0x6c, 0x69, 0x6e, 0x6b, 0x2e, 0x6f, 0x72, 0x67, 0x2e, | |||||
| 0x63, 0x6e, 0x2f, 0x4a, 0x43, 0x43, 0x45, 0x2f, 0x50, 0x43, 0x4d, 0x2f, 0x6c, 0x61, 0x6e, 0x5f, | |||||
| 0x74, 0x72, 0x61, 0x6e, 0x73, 0x2f, 0x69, 0x64, 0x6c, 0x2f, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x62, | |||||
| 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, | |||||
| 0x73, 0x74, 0x49, 0x64, 0x22, 0xbc, 0x01, 0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, | |||||
| 0x6f, 0x64, 0x52, 0x65, 0x71, 0x12, 0x33, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, | |||||
| 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x70, 0x62, 0x74, 0x65, 0x6e, 0x61, | |||||
| 0x6e, 0x74, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, | |||||
| 0x52, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x63, | |||||
| 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, | |||||
| 0x52, 0x0b, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x19, 0x0a, | |||||
| 0x08, 0x70, 0x6f, 0x64, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, | |||||
| 0x07, 0x70, 0x6f, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, | |||||
| 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, | |||||
| 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, | |||||
| 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, | |||||
| 0x6e, 0x49, 0x64, 0x22, 0x72, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, 0x6f, 0x64, | |||||
| 0x52, 0x65, 0x73, 0x70, 0x12, 0x26, 0x0a, 0x04, 0x70, 0x6f, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, | |||||
| 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x50, 0x6f, 0x64, 0x49, 0x6e, | |||||
| 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x52, 0x04, 0x70, 0x6f, 0x64, 0x73, 0x12, 0x1a, 0x0a, 0x08, | |||||
| 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, | |||||
| 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x71, 0x75, | |||||
| 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, | |||||
| 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0x99, 0x02, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, | |||||
| 0x50, 0x6f, 0x64, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x12, 0x33, 0x0a, 0x08, | |||||
| 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, | |||||
| 0x2e, 0x70, 0x62, 0x74, 0x65, 0x6e, 0x61, 0x6e, 0x74, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x50, | |||||
| 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, | |||||
| 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x6e, 0x61, 0x6d, | |||||
| 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, | |||||
| 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, | |||||
| 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, | |||||
| 0x64, 0x12, 0x15, 0x0a, 0x06, 0x70, 0x6f, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, | |||||
| 0x05, 0x52, 0x05, 0x70, 0x6f, 0x64, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x70, 0x61, 0x67, 0x65, | |||||
| 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x70, | |||||
| 0x61, 0x67, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, | |||||
| 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, | |||||
| 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x74, | |||||
| 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x65, 0x78, 0x74, | |||||
| 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, | |||||
| 0x63, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, | |||||
| 0x61, 0x63, 0x65, 0x22, 0xd3, 0x01, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, | |||||
| 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x12, 0x26, 0x0a, 0x04, 0x70, 0x6f, 0x64, | |||||
| 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, | |||||
| 0x50, 0x6f, 0x64, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x52, 0x04, 0x70, 0x6f, 0x64, | |||||
| 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x18, 0x02, 0x20, | |||||
| 0x01, 0x28, 0x08, 0x52, 0x08, 0x66, 0x69, 0x6e, 0x69, 0x73, 0x68, 0x65, 0x64, 0x12, 0x1f, 0x0a, | |||||
| 0x0b, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, | |||||
| 0x28, 0x05, 0x52, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x1b, | |||||
| 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, | |||||
| 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x6e, | |||||
| 0x65, 0x78, 0x74, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, | |||||
| 0x09, 0x6e, 0x65, 0x78, 0x74, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x1d, 0x0a, 0x0a, 0x72, 0x65, | |||||
| 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, | |||||
| 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x22, 0x41, 0x0a, 0x0a, 0x4c, 0x69, 0x73, | |||||
| 0x74, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x71, 0x12, 0x33, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, | |||||
| 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x70, 0x62, 0x74, 0x65, | |||||
| 0x6e, 0x61, 0x6e, 0x74, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x50, 0x72, 0x6f, 0x76, 0x69, 0x64, | |||||
| 0x65, 0x72, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x22, 0x35, 0x0a, 0x0b, | |||||
| 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x12, 0x26, 0x0a, 0x04, 0x70, | |||||
| 0x6f, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, | |||||
| 0x64, 0x2e, 0x50, 0x6f, 0x64, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x52, 0x04, 0x70, | |||||
| 0x6f, 0x64, 0x73, 0x22, 0x0f, 0x0a, 0x0d, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x41, 0x6c, | |||||
| 0x6c, 0x52, 0x65, 0x71, 0x32, 0xc8, 0x03, 0x0a, 0x0a, 0x50, 0x6f, 0x64, 0x53, 0x65, 0x72, 0x76, | |||||
| 0x69, 0x63, 0x65, 0x12, 0x53, 0x0a, 0x09, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, 0x6f, 0x64, | |||||
| 0x12, 0x13, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x50, | |||||
| 0x6f, 0x64, 0x52, 0x65, 0x71, 0x1a, 0x14, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x43, 0x72, | |||||
| 0x65, 0x61, 0x74, 0x65, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x22, 0x1b, 0x82, 0xd3, 0xe4, | |||||
| 0x93, 0x02, 0x15, 0x22, 0x10, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x2f, 0x63, | |||||
| 0x72, 0x65, 0x61, 0x74, 0x65, 0x3a, 0x01, 0x2a, 0x12, 0x6a, 0x0a, 0x09, 0x44, 0x65, 0x6c, 0x65, | |||||
| 0x74, 0x65, 0x50, 0x6f, 0x64, 0x12, 0x13, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x44, 0x65, | |||||
| 0x6c, 0x65, 0x74, 0x65, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x71, 0x1a, 0x14, 0x2e, 0x70, 0x62, 0x70, | |||||
| 0x6f, 0x64, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, | |||||
| 0x22, 0x32, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x2c, 0x22, 0x27, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, | |||||
| 0x70, 0x6f, 0x64, 0x2f, 0x64, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x2f, 0x7b, 0x6e, 0x61, 0x6d, 0x65, | |||||
| 0x73, 0x70, 0x61, 0x63, 0x65, 0x7d, 0x2f, 0x7b, 0x70, 0x6f, 0x64, 0x5f, 0x6e, 0x61, 0x6d, 0x65, | |||||
| 0x7d, 0x3a, 0x01, 0x2a, 0x12, 0x5f, 0x0a, 0x0d, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, | |||||
| 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, | |||||
| 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x1a, 0x18, | |||||
| 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x44, 0x65, | |||||
| 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x22, 0x1b, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x15, | |||||
| 0x22, 0x10, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x2f, 0x64, 0x65, 0x74, 0x61, | |||||
| 0x69, 0x6c, 0x3a, 0x01, 0x2a, 0x12, 0x46, 0x0a, 0x07, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, | |||||
| 0x12, 0x11, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, | |||||
| 0x52, 0x65, 0x71, 0x1a, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, | |||||
| 0x50, 0x6f, 0x64, 0x52, 0x65, 0x73, 0x70, 0x22, 0x14, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x0e, 0x22, | |||||
| 0x09, 0x2f, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x3a, 0x01, 0x2a, 0x12, 0x50, 0x0a, | |||||
| 0x0a, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x41, 0x6c, 0x6c, 0x12, 0x14, 0x2e, 0x70, 0x62, | |||||
| 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, 0x64, 0x41, 0x6c, 0x6c, 0x52, 0x65, | |||||
| 0x71, 0x1a, 0x12, 0x2e, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x6f, | |||||
| 0x64, 0x52, 0x65, 0x73, 0x70, 0x22, 0x18, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x12, 0x22, 0x0d, 0x2f, | |||||
| 0x61, 0x70, 0x69, 0x73, 0x2f, 0x70, 0x6f, 0x64, 0x2f, 0x61, 0x6c, 0x6c, 0x3a, 0x01, 0x2a, 0x42, | |||||
| 0x2d, 0x5a, 0x2b, 0x67, 0x69, 0x74, 0x6c, 0x69, 0x6e, 0x6b, 0x2e, 0x6f, 0x72, 0x67, 0x2e, 0x63, | |||||
| 0x6e, 0x2f, 0x4a, 0x43, 0x43, 0x45, 0x2f, 0x50, 0x43, 0x4d, 0x2f, 0x6c, 0x61, 0x6e, 0x5f, 0x74, | |||||
| 0x72, 0x61, 0x6e, 0x73, 0x2f, 0x69, 0x64, 0x6c, 0x2f, 0x70, 0x62, 0x70, 0x6f, 0x64, 0x62, 0x06, | |||||
| 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, | |||||
| } | } | ||||
| var ( | var ( | ||||
| @@ -889,39 +1065,45 @@ func file_idl_pbpod_pod_proto_rawDescGZIP() []byte { | |||||
| return file_idl_pbpod_pod_proto_rawDescData | return file_idl_pbpod_pod_proto_rawDescData | ||||
| } | } | ||||
| var file_idl_pbpod_pod_proto_msgTypes = make([]protoimpl.MessageInfo, 8) | |||||
| var file_idl_pbpod_pod_proto_msgTypes = make([]protoimpl.MessageInfo, 10) | |||||
| var file_idl_pbpod_pod_proto_goTypes = []interface{}{ | var file_idl_pbpod_pod_proto_goTypes = []interface{}{ | ||||
| (*PodInstance)(nil), // 0: pbpod.PodInstance | (*PodInstance)(nil), // 0: pbpod.PodInstance | ||||
| (*CreatePodReq)(nil), // 1: pbpod.CreatePodReq | (*CreatePodReq)(nil), // 1: pbpod.CreatePodReq | ||||
| (*CreatePodResp)(nil), // 2: pbpod.CreatePodResp | (*CreatePodResp)(nil), // 2: pbpod.CreatePodResp | ||||
| (*ListPodDetailReq)(nil), // 3: pbpod.ListPodDetailReq | |||||
| (*ListPodDetailResp)(nil), // 4: pbpod.ListPodDetailResp | |||||
| (*ListPodReq)(nil), // 5: pbpod.ListPodReq | |||||
| (*ListPodResp)(nil), // 6: pbpod.ListPodResp | |||||
| (*ListPodAllReq)(nil), // 7: pbpod.ListPodAllReq | |||||
| (pbtenant.CloudProvider)(0), // 8: pbtenant.CloudProvider | |||||
| (*DeletePodReq)(nil), // 3: pbpod.DeletePodReq | |||||
| (*DeletePodResp)(nil), // 4: pbpod.DeletePodResp | |||||
| (*ListPodDetailReq)(nil), // 5: pbpod.ListPodDetailReq | |||||
| (*ListPodDetailResp)(nil), // 6: pbpod.ListPodDetailResp | |||||
| (*ListPodReq)(nil), // 7: pbpod.ListPodReq | |||||
| (*ListPodResp)(nil), // 8: pbpod.ListPodResp | |||||
| (*ListPodAllReq)(nil), // 9: pbpod.ListPodAllReq | |||||
| (pbtenant.CloudProvider)(0), // 10: pbtenant.CloudProvider | |||||
| } | } | ||||
| var file_idl_pbpod_pod_proto_depIdxs = []int32{ | var file_idl_pbpod_pod_proto_depIdxs = []int32{ | ||||
| 8, // 0: pbpod.PodInstance.provider:type_name -> pbtenant.CloudProvider | |||||
| 8, // 1: pbpod.CreatePodReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 10, // 0: pbpod.PodInstance.provider:type_name -> pbtenant.CloudProvider | |||||
| 10, // 1: pbpod.CreatePodReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 0, // 2: pbpod.CreatePodResp.pods:type_name -> pbpod.PodInstance | 0, // 2: pbpod.CreatePodResp.pods:type_name -> pbpod.PodInstance | ||||
| 8, // 3: pbpod.ListPodDetailReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 0, // 4: pbpod.ListPodDetailResp.pods:type_name -> pbpod.PodInstance | |||||
| 8, // 5: pbpod.ListPodReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 0, // 6: pbpod.ListPodResp.pods:type_name -> pbpod.PodInstance | |||||
| 1, // 7: pbpod.PodService.CreatePod:input_type -> pbpod.CreatePodReq | |||||
| 3, // 8: pbpod.PodService.ListPodDetail:input_type -> pbpod.ListPodDetailReq | |||||
| 5, // 9: pbpod.PodService.ListPod:input_type -> pbpod.ListPodReq | |||||
| 7, // 10: pbpod.PodService.ListPodAll:input_type -> pbpod.ListPodAllReq | |||||
| 2, // 11: pbpod.PodService.CreatePod:output_type -> pbpod.CreatePodResp | |||||
| 4, // 12: pbpod.PodService.ListPodDetail:output_type -> pbpod.ListPodDetailResp | |||||
| 6, // 13: pbpod.PodService.ListPod:output_type -> pbpod.ListPodResp | |||||
| 6, // 14: pbpod.PodService.ListPodAll:output_type -> pbpod.ListPodResp | |||||
| 11, // [11:15] is the sub-list for method output_type | |||||
| 7, // [7:11] is the sub-list for method input_type | |||||
| 7, // [7:7] is the sub-list for extension type_name | |||||
| 7, // [7:7] is the sub-list for extension extendee | |||||
| 0, // [0:7] is the sub-list for field type_name | |||||
| 10, // 3: pbpod.DeletePodReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 0, // 4: pbpod.DeletePodResp.pods:type_name -> pbpod.PodInstance | |||||
| 10, // 5: pbpod.ListPodDetailReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 0, // 6: pbpod.ListPodDetailResp.pods:type_name -> pbpod.PodInstance | |||||
| 10, // 7: pbpod.ListPodReq.provider:type_name -> pbtenant.CloudProvider | |||||
| 0, // 8: pbpod.ListPodResp.pods:type_name -> pbpod.PodInstance | |||||
| 1, // 9: pbpod.PodService.CreatePod:input_type -> pbpod.CreatePodReq | |||||
| 3, // 10: pbpod.PodService.DeletePod:input_type -> pbpod.DeletePodReq | |||||
| 5, // 11: pbpod.PodService.ListPodDetail:input_type -> pbpod.ListPodDetailReq | |||||
| 7, // 12: pbpod.PodService.ListPod:input_type -> pbpod.ListPodReq | |||||
| 9, // 13: pbpod.PodService.ListPodAll:input_type -> pbpod.ListPodAllReq | |||||
| 2, // 14: pbpod.PodService.CreatePod:output_type -> pbpod.CreatePodResp | |||||
| 4, // 15: pbpod.PodService.DeletePod:output_type -> pbpod.DeletePodResp | |||||
| 6, // 16: pbpod.PodService.ListPodDetail:output_type -> pbpod.ListPodDetailResp | |||||
| 8, // 17: pbpod.PodService.ListPod:output_type -> pbpod.ListPodResp | |||||
| 8, // 18: pbpod.PodService.ListPodAll:output_type -> pbpod.ListPodResp | |||||
| 14, // [14:19] is the sub-list for method output_type | |||||
| 9, // [9:14] is the sub-list for method input_type | |||||
| 9, // [9:9] is the sub-list for extension type_name | |||||
| 9, // [9:9] is the sub-list for extension extendee | |||||
| 0, // [0:9] is the sub-list for field type_name | |||||
| } | } | ||||
| func init() { file_idl_pbpod_pod_proto_init() } | func init() { file_idl_pbpod_pod_proto_init() } | ||||
| @@ -967,7 +1149,7 @@ func file_idl_pbpod_pod_proto_init() { | |||||
| } | } | ||||
| } | } | ||||
| file_idl_pbpod_pod_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { | file_idl_pbpod_pod_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { | ||||
| switch v := v.(*ListPodDetailReq); i { | |||||
| switch v := v.(*DeletePodReq); i { | |||||
| case 0: | case 0: | ||||
| return &v.state | return &v.state | ||||
| case 1: | case 1: | ||||
| @@ -979,7 +1161,7 @@ func file_idl_pbpod_pod_proto_init() { | |||||
| } | } | ||||
| } | } | ||||
| file_idl_pbpod_pod_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { | file_idl_pbpod_pod_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { | ||||
| switch v := v.(*ListPodDetailResp); i { | |||||
| switch v := v.(*DeletePodResp); i { | |||||
| case 0: | case 0: | ||||
| return &v.state | return &v.state | ||||
| case 1: | case 1: | ||||
| @@ -991,7 +1173,7 @@ func file_idl_pbpod_pod_proto_init() { | |||||
| } | } | ||||
| } | } | ||||
| file_idl_pbpod_pod_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { | file_idl_pbpod_pod_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { | ||||
| switch v := v.(*ListPodReq); i { | |||||
| switch v := v.(*ListPodDetailReq); i { | |||||
| case 0: | case 0: | ||||
| return &v.state | return &v.state | ||||
| case 1: | case 1: | ||||
| @@ -1003,7 +1185,7 @@ func file_idl_pbpod_pod_proto_init() { | |||||
| } | } | ||||
| } | } | ||||
| file_idl_pbpod_pod_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { | file_idl_pbpod_pod_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { | ||||
| switch v := v.(*ListPodResp); i { | |||||
| switch v := v.(*ListPodDetailResp); i { | |||||
| case 0: | case 0: | ||||
| return &v.state | return &v.state | ||||
| case 1: | case 1: | ||||
| @@ -1015,6 +1197,30 @@ func file_idl_pbpod_pod_proto_init() { | |||||
| } | } | ||||
| } | } | ||||
| file_idl_pbpod_pod_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { | file_idl_pbpod_pod_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { | ||||
| switch v := v.(*ListPodReq); i { | |||||
| case 0: | |||||
| return &v.state | |||||
| case 1: | |||||
| return &v.sizeCache | |||||
| case 2: | |||||
| return &v.unknownFields | |||||
| default: | |||||
| return nil | |||||
| } | |||||
| } | |||||
| file_idl_pbpod_pod_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { | |||||
| switch v := v.(*ListPodResp); i { | |||||
| case 0: | |||||
| return &v.state | |||||
| case 1: | |||||
| return &v.sizeCache | |||||
| case 2: | |||||
| return &v.unknownFields | |||||
| default: | |||||
| return nil | |||||
| } | |||||
| } | |||||
| file_idl_pbpod_pod_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { | |||||
| switch v := v.(*ListPodAllReq); i { | switch v := v.(*ListPodAllReq); i { | ||||
| case 0: | case 0: | ||||
| return &v.state | return &v.state | ||||
| @@ -1033,7 +1239,7 @@ func file_idl_pbpod_pod_proto_init() { | |||||
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), | GoPackagePath: reflect.TypeOf(x{}).PkgPath(), | ||||
| RawDescriptor: file_idl_pbpod_pod_proto_rawDesc, | RawDescriptor: file_idl_pbpod_pod_proto_rawDesc, | ||||
| NumEnums: 0, | NumEnums: 0, | ||||
| NumMessages: 8, | |||||
| NumMessages: 10, | |||||
| NumExtensions: 0, | NumExtensions: 0, | ||||
| NumServices: 1, | NumServices: 1, | ||||
| }, | }, | ||||
| @@ -65,6 +65,94 @@ func local_request_PodService_CreatePod_0(ctx context.Context, marshaler runtime | |||||
| } | } | ||||
| func request_PodService_DeletePod_0(ctx context.Context, marshaler runtime.Marshaler, client PodServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { | |||||
| var protoReq DeletePodReq | |||||
| var metadata runtime.ServerMetadata | |||||
| newReader, berr := utilities.IOReaderFactory(req.Body) | |||||
| if berr != nil { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr) | |||||
| } | |||||
| if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) | |||||
| } | |||||
| var ( | |||||
| val string | |||||
| ok bool | |||||
| err error | |||||
| _ = err | |||||
| ) | |||||
| val, ok = pathParams["namespace"] | |||||
| if !ok { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "namespace") | |||||
| } | |||||
| protoReq.Namespace, err = runtime.String(val) | |||||
| if err != nil { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "namespace", err) | |||||
| } | |||||
| val, ok = pathParams["pod_name"] | |||||
| if !ok { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "pod_name") | |||||
| } | |||||
| protoReq.PodName, err = runtime.String(val) | |||||
| if err != nil { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "pod_name", err) | |||||
| } | |||||
| msg, err := client.DeletePod(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) | |||||
| return msg, metadata, err | |||||
| } | |||||
| func local_request_PodService_DeletePod_0(ctx context.Context, marshaler runtime.Marshaler, server PodServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { | |||||
| var protoReq DeletePodReq | |||||
| var metadata runtime.ServerMetadata | |||||
| newReader, berr := utilities.IOReaderFactory(req.Body) | |||||
| if berr != nil { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr) | |||||
| } | |||||
| if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) | |||||
| } | |||||
| var ( | |||||
| val string | |||||
| ok bool | |||||
| err error | |||||
| _ = err | |||||
| ) | |||||
| val, ok = pathParams["namespace"] | |||||
| if !ok { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "namespace") | |||||
| } | |||||
| protoReq.Namespace, err = runtime.String(val) | |||||
| if err != nil { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "namespace", err) | |||||
| } | |||||
| val, ok = pathParams["pod_name"] | |||||
| if !ok { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "pod_name") | |||||
| } | |||||
| protoReq.PodName, err = runtime.String(val) | |||||
| if err != nil { | |||||
| return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "pod_name", err) | |||||
| } | |||||
| msg, err := server.DeletePod(ctx, &protoReq) | |||||
| return msg, metadata, err | |||||
| } | |||||
| func request_PodService_ListPodDetail_0(ctx context.Context, marshaler runtime.Marshaler, client PodServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { | func request_PodService_ListPodDetail_0(ctx context.Context, marshaler runtime.Marshaler, client PodServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { | ||||
| var protoReq ListPodDetailReq | var protoReq ListPodDetailReq | ||||
| var metadata runtime.ServerMetadata | var metadata runtime.ServerMetadata | ||||
| @@ -179,12 +267,13 @@ func RegisterPodServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/CreatePod") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/CreatePod", runtime.WithHTTPPathPattern("/apis/pod/create")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_PodService_CreatePod_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_PodService_CreatePod_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -196,18 +285,43 @@ func RegisterPodServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| }) | }) | ||||
| mux.Handle("POST", pattern_PodService_DeletePod_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { | |||||
| ctx, cancel := context.WithCancel(req.Context()) | |||||
| defer cancel() | |||||
| var stream runtime.ServerTransportStream | |||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | |||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/DeletePod", runtime.WithHTTPPathPattern("/apis/pod/delete/{namespace}/{pod_name}")) | |||||
| if err != nil { | |||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | |||||
| return | |||||
| } | |||||
| resp, md, err := local_request_PodService_DeletePod_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | |||||
| if err != nil { | |||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | |||||
| return | |||||
| } | |||||
| forward_PodService_DeletePod_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) | |||||
| }) | |||||
| mux.Handle("POST", pattern_PodService_ListPodDetail_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { | mux.Handle("POST", pattern_PodService_ListPodDetail_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { | ||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/ListPodDetail") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/ListPodDetail", runtime.WithHTTPPathPattern("/apis/pod/detail")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_PodService_ListPodDetail_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_PodService_ListPodDetail_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -225,12 +339,13 @@ func RegisterPodServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/ListPod") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/ListPod", runtime.WithHTTPPathPattern("/apis/pod")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_PodService_ListPod_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_PodService_ListPod_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -248,12 +363,13 @@ func RegisterPodServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, | |||||
| var stream runtime.ServerTransportStream | var stream runtime.ServerTransportStream | ||||
| ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ctx = grpc.NewContextWithServerTransportStream(ctx, &stream) | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/ListPodAll") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/pbpod.PodService/ListPodAll", runtime.WithHTTPPathPattern("/apis/pod/all")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := local_request_PodService_ListPodAll_0(rctx, inboundMarshaler, server, req, pathParams) | |||||
| resp, md, err := local_request_PodService_ListPodAll_0(ctx, inboundMarshaler, server, req, pathParams) | |||||
| md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer()) | ||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| @@ -310,12 +426,13 @@ func RegisterPodServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/CreatePod") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/CreatePod", runtime.WithHTTPPathPattern("/apis/pod/create")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_PodService_CreatePod_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_PodService_CreatePod_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -326,16 +443,38 @@ func RegisterPodServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| }) | }) | ||||
| mux.Handle("POST", pattern_PodService_DeletePod_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { | |||||
| ctx, cancel := context.WithCancel(req.Context()) | |||||
| defer cancel() | |||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/DeletePod", runtime.WithHTTPPathPattern("/apis/pod/delete/{namespace}/{pod_name}")) | |||||
| if err != nil { | |||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | |||||
| return | |||||
| } | |||||
| resp, md, err := request_PodService_DeletePod_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | |||||
| if err != nil { | |||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | |||||
| return | |||||
| } | |||||
| forward_PodService_DeletePod_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) | |||||
| }) | |||||
| mux.Handle("POST", pattern_PodService_ListPodDetail_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { | mux.Handle("POST", pattern_PodService_ListPodDetail_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { | ||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/ListPodDetail") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/ListPodDetail", runtime.WithHTTPPathPattern("/apis/pod/detail")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_PodService_ListPodDetail_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_PodService_ListPodDetail_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -350,12 +489,13 @@ func RegisterPodServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/ListPod") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/ListPod", runtime.WithHTTPPathPattern("/apis/pod")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_PodService_ListPod_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_PodService_ListPod_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -370,12 +510,13 @@ func RegisterPodServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| ctx, cancel := context.WithCancel(req.Context()) | ctx, cancel := context.WithCancel(req.Context()) | ||||
| defer cancel() | defer cancel() | ||||
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) | ||||
| rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/ListPodAll") | |||||
| var err error | |||||
| ctx, err = runtime.AnnotateContext(ctx, mux, req, "/pbpod.PodService/ListPodAll", runtime.WithHTTPPathPattern("/apis/pod/all")) | |||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| return | return | ||||
| } | } | ||||
| resp, md, err := request_PodService_ListPodAll_0(rctx, inboundMarshaler, client, req, pathParams) | |||||
| resp, md, err := request_PodService_ListPodAll_0(ctx, inboundMarshaler, client, req, pathParams) | |||||
| ctx = runtime.NewServerMetadataContext(ctx, md) | ctx = runtime.NewServerMetadataContext(ctx, md) | ||||
| if err != nil { | if err != nil { | ||||
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) | ||||
| @@ -392,6 +533,8 @@ func RegisterPodServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, | |||||
| var ( | var ( | ||||
| pattern_PodService_CreatePod_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "pod", "create"}, "")) | pattern_PodService_CreatePod_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "pod", "create"}, "")) | ||||
| pattern_PodService_DeletePod_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 1, 0, 4, 1, 5, 4}, []string{"apis", "pod", "delete", "namespace", "pod_name"}, "")) | |||||
| pattern_PodService_ListPodDetail_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "pod", "detail"}, "")) | pattern_PodService_ListPodDetail_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"apis", "pod", "detail"}, "")) | ||||
| pattern_PodService_ListPod_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"apis", "pod"}, "")) | pattern_PodService_ListPod_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"apis", "pod"}, "")) | ||||
| @@ -402,6 +545,8 @@ var ( | |||||
| var ( | var ( | ||||
| forward_PodService_CreatePod_0 = runtime.ForwardResponseMessage | forward_PodService_CreatePod_0 = runtime.ForwardResponseMessage | ||||
| forward_PodService_DeletePod_0 = runtime.ForwardResponseMessage | |||||
| forward_PodService_ListPodDetail_0 = runtime.ForwardResponseMessage | forward_PodService_ListPodDetail_0 = runtime.ForwardResponseMessage | ||||
| forward_PodService_ListPod_0 = runtime.ForwardResponseMessage | forward_PodService_ListPod_0 = runtime.ForwardResponseMessage | ||||
| @@ -24,6 +24,8 @@ const _ = grpc.SupportPackageIsVersion7 | |||||
| type PodServiceClient interface { | type PodServiceClient interface { | ||||
| // 创建Pod | // 创建Pod | ||||
| CreatePod(ctx context.Context, in *CreatePodReq, opts ...grpc.CallOption) (*CreatePodResp, error) | CreatePod(ctx context.Context, in *CreatePodReq, opts ...grpc.CallOption) (*CreatePodResp, error) | ||||
| // 删除Pod | |||||
| DeletePod(ctx context.Context, in *DeletePodReq, opts ...grpc.CallOption) (*DeletePodResp, error) | |||||
| // 查询Pod明细 | // 查询Pod明细 | ||||
| ListPodDetail(ctx context.Context, in *ListPodDetailReq, opts ...grpc.CallOption) (*ListPodDetailResp, error) | ListPodDetail(ctx context.Context, in *ListPodDetailReq, opts ...grpc.CallOption) (*ListPodDetailResp, error) | ||||
| // 查询Pod全量 - 根据云类型 | // 查询Pod全量 - 根据云类型 | ||||
| @@ -49,6 +51,15 @@ func (c *podServiceClient) CreatePod(ctx context.Context, in *CreatePodReq, opts | |||||
| return out, nil | return out, nil | ||||
| } | } | ||||
| func (c *podServiceClient) DeletePod(ctx context.Context, in *DeletePodReq, opts ...grpc.CallOption) (*DeletePodResp, error) { | |||||
| out := new(DeletePodResp) | |||||
| err := c.cc.Invoke(ctx, "/pbpod.PodService/DeletePod", in, out, opts...) | |||||
| if err != nil { | |||||
| return nil, err | |||||
| } | |||||
| return out, nil | |||||
| } | |||||
| func (c *podServiceClient) ListPodDetail(ctx context.Context, in *ListPodDetailReq, opts ...grpc.CallOption) (*ListPodDetailResp, error) { | func (c *podServiceClient) ListPodDetail(ctx context.Context, in *ListPodDetailReq, opts ...grpc.CallOption) (*ListPodDetailResp, error) { | ||||
| out := new(ListPodDetailResp) | out := new(ListPodDetailResp) | ||||
| err := c.cc.Invoke(ctx, "/pbpod.PodService/ListPodDetail", in, out, opts...) | err := c.cc.Invoke(ctx, "/pbpod.PodService/ListPodDetail", in, out, opts...) | ||||
| @@ -82,6 +93,8 @@ func (c *podServiceClient) ListPodAll(ctx context.Context, in *ListPodAllReq, op | |||||
| type PodServiceServer interface { | type PodServiceServer interface { | ||||
| // 创建Pod | // 创建Pod | ||||
| CreatePod(context.Context, *CreatePodReq) (*CreatePodResp, error) | CreatePod(context.Context, *CreatePodReq) (*CreatePodResp, error) | ||||
| // 删除Pod | |||||
| DeletePod(context.Context, *DeletePodReq) (*DeletePodResp, error) | |||||
| // 查询Pod明细 | // 查询Pod明细 | ||||
| ListPodDetail(context.Context, *ListPodDetailReq) (*ListPodDetailResp, error) | ListPodDetail(context.Context, *ListPodDetailReq) (*ListPodDetailResp, error) | ||||
| // 查询Pod全量 - 根据云类型 | // 查询Pod全量 - 根据云类型 | ||||
| @@ -98,6 +111,9 @@ type UnimplementedPodServiceServer struct { | |||||
| func (UnimplementedPodServiceServer) CreatePod(context.Context, *CreatePodReq) (*CreatePodResp, error) { | func (UnimplementedPodServiceServer) CreatePod(context.Context, *CreatePodReq) (*CreatePodResp, error) { | ||||
| return nil, status.Errorf(codes.Unimplemented, "method CreatePod not implemented") | return nil, status.Errorf(codes.Unimplemented, "method CreatePod not implemented") | ||||
| } | } | ||||
| func (UnimplementedPodServiceServer) DeletePod(context.Context, *DeletePodReq) (*DeletePodResp, error) { | |||||
| return nil, status.Errorf(codes.Unimplemented, "method DeletePod not implemented") | |||||
| } | |||||
| func (UnimplementedPodServiceServer) ListPodDetail(context.Context, *ListPodDetailReq) (*ListPodDetailResp, error) { | func (UnimplementedPodServiceServer) ListPodDetail(context.Context, *ListPodDetailReq) (*ListPodDetailResp, error) { | ||||
| return nil, status.Errorf(codes.Unimplemented, "method ListPodDetail not implemented") | return nil, status.Errorf(codes.Unimplemented, "method ListPodDetail not implemented") | ||||
| } | } | ||||
| @@ -138,6 +154,24 @@ func _PodService_CreatePod_Handler(srv interface{}, ctx context.Context, dec fun | |||||
| return interceptor(ctx, in, info, handler) | return interceptor(ctx, in, info, handler) | ||||
| } | } | ||||
| func _PodService_DeletePod_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { | |||||
| in := new(DeletePodReq) | |||||
| if err := dec(in); err != nil { | |||||
| return nil, err | |||||
| } | |||||
| if interceptor == nil { | |||||
| return srv.(PodServiceServer).DeletePod(ctx, in) | |||||
| } | |||||
| info := &grpc.UnaryServerInfo{ | |||||
| Server: srv, | |||||
| FullMethod: "/pbpod.PodService/DeletePod", | |||||
| } | |||||
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { | |||||
| return srv.(PodServiceServer).DeletePod(ctx, req.(*DeletePodReq)) | |||||
| } | |||||
| return interceptor(ctx, in, info, handler) | |||||
| } | |||||
| func _PodService_ListPodDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { | func _PodService_ListPodDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { | ||||
| in := new(ListPodDetailReq) | in := new(ListPodDetailReq) | ||||
| if err := dec(in); err != nil { | if err := dec(in); err != nil { | ||||
| @@ -203,6 +237,10 @@ var PodService_ServiceDesc = grpc.ServiceDesc{ | |||||
| MethodName: "CreatePod", | MethodName: "CreatePod", | ||||
| Handler: _PodService_CreatePod_Handler, | Handler: _PodService_CreatePod_Handler, | ||||
| }, | }, | ||||
| { | |||||
| MethodName: "DeletePod", | |||||
| Handler: _PodService_DeletePod_Handler, | |||||
| }, | |||||
| { | { | ||||
| MethodName: "ListPodDetail", | MethodName: "ListPodDetail", | ||||
| Handler: _PodService_ListPodDetail_Handler, | Handler: _PodService_ListPodDetail_Handler, | ||||
| @@ -68,14 +68,11 @@ | |||||
| "protobufAny": { | "protobufAny": { | ||||
| "type": "object", | "type": "object", | ||||
| "properties": { | "properties": { | ||||
| "typeUrl": { | |||||
| "@type": { | |||||
| "type": "string" | "type": "string" | ||||
| }, | |||||
| "value": { | |||||
| "type": "string", | |||||
| "format": "byte" | |||||
| } | } | ||||
| } | |||||
| }, | |||||
| "additionalProperties": {} | |||||
| }, | }, | ||||
| "rpcStatus": { | "rpcStatus": { | ||||
| "type": "object", | "type": "object", | ||||
| @@ -303,14 +303,11 @@ | |||||
| "protobufAny": { | "protobufAny": { | ||||
| "type": "object", | "type": "object", | ||||
| "properties": { | "properties": { | ||||
| "typeUrl": { | |||||
| "@type": { | |||||
| "type": "string" | "type": "string" | ||||
| }, | |||||
| "value": { | |||||
| "type": "string", | |||||
| "format": "byte" | |||||
| } | } | ||||
| } | |||||
| }, | |||||
| "additionalProperties": {} | |||||
| }, | }, | ||||
| "rpcStatus": { | "rpcStatus": { | ||||
| "type": "object", | "type": "object", | ||||
| @@ -115,6 +115,68 @@ | |||||
| ] | ] | ||||
| } | } | ||||
| }, | }, | ||||
| "/apis/pod/delete/{namespace}/{podName}": { | |||||
| "post": { | |||||
| "summary": "删除Pod", | |||||
| "operationId": "PodService_DeletePod", | |||||
| "responses": { | |||||
| "200": { | |||||
| "description": "A successful response.", | |||||
| "schema": { | |||||
| "$ref": "#/definitions/pbpodDeletePodResp" | |||||
| } | |||||
| }, | |||||
| "default": { | |||||
| "description": "An unexpected error response.", | |||||
| "schema": { | |||||
| "$ref": "#/definitions/rpcStatus" | |||||
| } | |||||
| } | |||||
| }, | |||||
| "parameters": [ | |||||
| { | |||||
| "name": "namespace", | |||||
| "description": "namespace", | |||||
| "in": "path", | |||||
| "required": true, | |||||
| "type": "string" | |||||
| }, | |||||
| { | |||||
| "name": "podName", | |||||
| "description": "实例名称", | |||||
| "in": "path", | |||||
| "required": true, | |||||
| "type": "string" | |||||
| }, | |||||
| { | |||||
| "name": "body", | |||||
| "in": "body", | |||||
| "required": true, | |||||
| "schema": { | |||||
| "type": "object", | |||||
| "properties": { | |||||
| "provider": { | |||||
| "$ref": "#/definitions/pbtenantCloudProvider", | |||||
| "title": "云类型" | |||||
| }, | |||||
| "accountName": { | |||||
| "type": "string", | |||||
| "title": "账号名称" | |||||
| }, | |||||
| "regionId": { | |||||
| "type": "integer", | |||||
| "format": "int32", | |||||
| "title": "地域,数据中心" | |||||
| } | |||||
| } | |||||
| } | |||||
| } | |||||
| ], | |||||
| "tags": [ | |||||
| "PodService" | |||||
| ] | |||||
| } | |||||
| }, | |||||
| "/apis/pod/detail": { | "/apis/pod/detail": { | ||||
| "post": { | "post": { | ||||
| "summary": "查询Pod明细", | "summary": "查询Pod明细", | ||||
| @@ -228,6 +290,26 @@ | |||||
| } | } | ||||
| } | } | ||||
| }, | }, | ||||
| "pbpodDeletePodResp": { | |||||
| "type": "object", | |||||
| "properties": { | |||||
| "pods": { | |||||
| "type": "array", | |||||
| "items": { | |||||
| "$ref": "#/definitions/pbpodPodInstance" | |||||
| }, | |||||
| "title": "Pod集合" | |||||
| }, | |||||
| "finished": { | |||||
| "type": "boolean", | |||||
| "title": "查询是否完成,如果为否-false,则可以将下面三个分页参数填入到请求中,继续查询" | |||||
| }, | |||||
| "requestId": { | |||||
| "type": "string", | |||||
| "title": "请求id,出现问题后提供给云厂商,排查问题" | |||||
| } | |||||
| } | |||||
| }, | |||||
| "pbpodListPodAllReq": { | "pbpodListPodAllReq": { | ||||
| "type": "object" | "type": "object" | ||||
| }, | }, | ||||
| @@ -400,14 +482,11 @@ | |||||
| "protobufAny": { | "protobufAny": { | ||||
| "type": "object", | "type": "object", | ||||
| "properties": { | "properties": { | ||||
| "typeUrl": { | |||||
| "@type": { | |||||
| "type": "string" | "type": "string" | ||||
| }, | |||||
| "value": { | |||||
| "type": "string", | |||||
| "format": "byte" | |||||
| } | } | ||||
| } | |||||
| }, | |||||
| "additionalProperties": {} | |||||
| }, | }, | ||||
| "rpcStatus": { | "rpcStatus": { | ||||
| "type": "object", | "type": "object", | ||||
| @@ -15,14 +15,11 @@ | |||||
| "protobufAny": { | "protobufAny": { | ||||
| "type": "object", | "type": "object", | ||||
| "properties": { | "properties": { | ||||
| "typeUrl": { | |||||
| "@type": { | |||||
| "type": "string" | "type": "string" | ||||
| }, | |||||
| "value": { | |||||
| "type": "string", | |||||
| "format": "byte" | |||||
| } | } | ||||
| } | |||||
| }, | |||||
| "additionalProperties": {} | |||||
| }, | }, | ||||
| "rpcStatus": { | "rpcStatus": { | ||||
| "type": "object", | "type": "object", | ||||