4 changed files with 6015 additions and 0 deletions
@ -0,0 +1,449 @@
|
||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.2.0
|
||||
// - protoc v3.19.5
|
||||
// source: game_pod/v1/game_pod.proto
|
||||
|
||||
package v1 |
||||
|
||||
import ( |
||||
context "context" |
||||
grpc "google.golang.org/grpc" |
||||
codes "google.golang.org/grpc/codes" |
||||
status "google.golang.org/grpc/status" |
||||
) |
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7 |
||||
|
||||
// GamePodClient is the client API for GamePod service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
||||
type GamePodClient interface { |
||||
// 获取镜像列表
|
||||
GetImageList(ctx context.Context, in *GetImageListReq, opts ...grpc.CallOption) (*GetImageListRsp, error) |
||||
// 获取镜像总数
|
||||
GetImageListCount(ctx context.Context, in *GetImageListReq, opts ...grpc.CallOption) (*CountRsp, error) |
||||
// 新增镜像
|
||||
CreateImage(ctx context.Context, in *Image, opts ...grpc.CallOption) (*NilRsp, error) |
||||
// 删除镜像
|
||||
DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*NilRsp, error) |
||||
// 修改镜像
|
||||
UpdateImage(ctx context.Context, in *Image, opts ...grpc.CallOption) (*NilRsp, error) |
||||
// 获取服务器ip
|
||||
GetServerIpList(ctx context.Context, in *GetServerIpListReq, opts ...grpc.CallOption) (*GetServerIpListRsp, error) |
||||
// 获取容器列表
|
||||
GetContainerList(ctx context.Context, in *GetContainerListReq, opts ...grpc.CallOption) (*GetContainerListRsp, error) |
||||
// 获取容器列表总数
|
||||
GetContainerCount(ctx context.Context, in *GetContainerListReq, opts ...grpc.CallOption) (*CountRsp, error) |
||||
// 创建容器
|
||||
CreateContainer(ctx context.Context, in *CreateContainerReq, opts ...grpc.CallOption) (*NilRsp, error) |
||||
// 删除容器
|
||||
DeleteContainer(ctx context.Context, in *DeleteContainerReq, opts ...grpc.CallOption) (*NilRsp, error) |
||||
} |
||||
|
||||
type gamePodClient struct { |
||||
cc grpc.ClientConnInterface |
||||
} |
||||
|
||||
func NewGamePodClient(cc grpc.ClientConnInterface) GamePodClient { |
||||
return &gamePodClient{cc} |
||||
} |
||||
|
||||
func (c *gamePodClient) GetImageList(ctx context.Context, in *GetImageListReq, opts ...grpc.CallOption) (*GetImageListRsp, error) { |
||||
out := new(GetImageListRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/GetImageList", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) GetImageListCount(ctx context.Context, in *GetImageListReq, opts ...grpc.CallOption) (*CountRsp, error) { |
||||
out := new(CountRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/GetImageListCount", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) CreateImage(ctx context.Context, in *Image, opts ...grpc.CallOption) (*NilRsp, error) { |
||||
out := new(NilRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/CreateImage", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*NilRsp, error) { |
||||
out := new(NilRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/DeleteImage", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) UpdateImage(ctx context.Context, in *Image, opts ...grpc.CallOption) (*NilRsp, error) { |
||||
out := new(NilRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/UpdateImage", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) GetServerIpList(ctx context.Context, in *GetServerIpListReq, opts ...grpc.CallOption) (*GetServerIpListRsp, error) { |
||||
out := new(GetServerIpListRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/GetServerIpList", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) GetContainerList(ctx context.Context, in *GetContainerListReq, opts ...grpc.CallOption) (*GetContainerListRsp, error) { |
||||
out := new(GetContainerListRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/GetContainerList", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) GetContainerCount(ctx context.Context, in *GetContainerListReq, opts ...grpc.CallOption) (*CountRsp, error) { |
||||
out := new(CountRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/GetContainerCount", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) CreateContainer(ctx context.Context, in *CreateContainerReq, opts ...grpc.CallOption) (*NilRsp, error) { |
||||
out := new(NilRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/CreateContainer", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *gamePodClient) DeleteContainer(ctx context.Context, in *DeleteContainerReq, opts ...grpc.CallOption) (*NilRsp, error) { |
||||
out := new(NilRsp) |
||||
err := c.cc.Invoke(ctx, "/game_pod.v1.GamePod/DeleteContainer", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
// GamePodServer is the server API for GamePod service.
|
||||
// All implementations must embed UnimplementedGamePodServer
|
||||
// for forward compatibility
|
||||
type GamePodServer interface { |
||||
// 获取镜像列表
|
||||
GetImageList(context.Context, *GetImageListReq) (*GetImageListRsp, error) |
||||
// 获取镜像总数
|
||||
GetImageListCount(context.Context, *GetImageListReq) (*CountRsp, error) |
||||
// 新增镜像
|
||||
CreateImage(context.Context, *Image) (*NilRsp, error) |
||||
// 删除镜像
|
||||
DeleteImage(context.Context, *DeleteImageReq) (*NilRsp, error) |
||||
// 修改镜像
|
||||
UpdateImage(context.Context, *Image) (*NilRsp, error) |
||||
// 获取服务器ip
|
||||
GetServerIpList(context.Context, *GetServerIpListReq) (*GetServerIpListRsp, error) |
||||
// 获取容器列表
|
||||
GetContainerList(context.Context, *GetContainerListReq) (*GetContainerListRsp, error) |
||||
// 获取容器列表总数
|
||||
GetContainerCount(context.Context, *GetContainerListReq) (*CountRsp, error) |
||||
// 创建容器
|
||||
CreateContainer(context.Context, *CreateContainerReq) (*NilRsp, error) |
||||
// 删除容器
|
||||
DeleteContainer(context.Context, *DeleteContainerReq) (*NilRsp, error) |
||||
mustEmbedUnimplementedGamePodServer() |
||||
} |
||||
|
||||
// UnimplementedGamePodServer must be embedded to have forward compatible implementations.
|
||||
type UnimplementedGamePodServer struct { |
||||
} |
||||
|
||||
func (UnimplementedGamePodServer) GetImageList(context.Context, *GetImageListReq) (*GetImageListRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetImageList not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) GetImageListCount(context.Context, *GetImageListReq) (*CountRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetImageListCount not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) CreateImage(context.Context, *Image) (*NilRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method CreateImage not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) DeleteImage(context.Context, *DeleteImageReq) (*NilRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method DeleteImage not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) UpdateImage(context.Context, *Image) (*NilRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method UpdateImage not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) GetServerIpList(context.Context, *GetServerIpListReq) (*GetServerIpListRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetServerIpList not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) GetContainerList(context.Context, *GetContainerListReq) (*GetContainerListRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetContainerList not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) GetContainerCount(context.Context, *GetContainerListReq) (*CountRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetContainerCount not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) CreateContainer(context.Context, *CreateContainerReq) (*NilRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method CreateContainer not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) DeleteContainer(context.Context, *DeleteContainerReq) (*NilRsp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method DeleteContainer not implemented") |
||||
} |
||||
func (UnimplementedGamePodServer) mustEmbedUnimplementedGamePodServer() {} |
||||
|
||||
// UnsafeGamePodServer may be embedded to opt out of forward compatibility for this service.
|
||||
// Use of this interface is not recommended, as added methods to GamePodServer will
|
||||
// result in compilation errors.
|
||||
type UnsafeGamePodServer interface { |
||||
mustEmbedUnimplementedGamePodServer() |
||||
} |
||||
|
||||
func RegisterGamePodServer(s grpc.ServiceRegistrar, srv GamePodServer) { |
||||
s.RegisterService(&GamePod_ServiceDesc, srv) |
||||
} |
||||
|
||||
func _GamePod_GetImageList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetImageListReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).GetImageList(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/GetImageList", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).GetImageList(ctx, req.(*GetImageListReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_GetImageListCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetImageListReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).GetImageListCount(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/GetImageListCount", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).GetImageListCount(ctx, req.(*GetImageListReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_CreateImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(Image) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).CreateImage(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/CreateImage", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).CreateImage(ctx, req.(*Image)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_DeleteImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(DeleteImageReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).DeleteImage(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/DeleteImage", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).DeleteImage(ctx, req.(*DeleteImageReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_UpdateImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(Image) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).UpdateImage(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/UpdateImage", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).UpdateImage(ctx, req.(*Image)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_GetServerIpList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetServerIpListReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).GetServerIpList(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/GetServerIpList", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).GetServerIpList(ctx, req.(*GetServerIpListReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_GetContainerList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetContainerListReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).GetContainerList(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/GetContainerList", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).GetContainerList(ctx, req.(*GetContainerListReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_GetContainerCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetContainerListReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).GetContainerCount(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/GetContainerCount", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).GetContainerCount(ctx, req.(*GetContainerListReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_CreateContainer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(CreateContainerReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).CreateContainer(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/CreateContainer", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).CreateContainer(ctx, req.(*CreateContainerReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _GamePod_DeleteContainer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(DeleteContainerReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(GamePodServer).DeleteContainer(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/game_pod.v1.GamePod/DeleteContainer", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(GamePodServer).DeleteContainer(ctx, req.(*DeleteContainerReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
// GamePod_ServiceDesc is the grpc.ServiceDesc for GamePod service.
|
||||
// It's only intended for direct use with grpc.RegisterService,
|
||||
// and not to be introspected or modified (even as a copy)
|
||||
var GamePod_ServiceDesc = grpc.ServiceDesc{ |
||||
ServiceName: "game_pod.v1.GamePod", |
||||
HandlerType: (*GamePodServer)(nil), |
||||
Methods: []grpc.MethodDesc{ |
||||
{ |
||||
MethodName: "GetImageList", |
||||
Handler: _GamePod_GetImageList_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetImageListCount", |
||||
Handler: _GamePod_GetImageListCount_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "CreateImage", |
||||
Handler: _GamePod_CreateImage_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "DeleteImage", |
||||
Handler: _GamePod_DeleteImage_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "UpdateImage", |
||||
Handler: _GamePod_UpdateImage_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetServerIpList", |
||||
Handler: _GamePod_GetServerIpList_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetContainerList", |
||||
Handler: _GamePod_GetContainerList_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetContainerCount", |
||||
Handler: _GamePod_GetContainerCount_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "CreateContainer", |
||||
Handler: _GamePod_CreateContainer_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "DeleteContainer", |
||||
Handler: _GamePod_DeleteContainer_Handler, |
||||
}, |
||||
}, |
||||
Streams: []grpc.StreamDesc{}, |
||||
Metadata: "game_pod/v1/game_pod.proto", |
||||
} |
||||
@ -0,0 +1,524 @@
|
||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.2.0
|
||||
// - protoc v3.19.5
|
||||
// source: pk/v1/pk.proto
|
||||
|
||||
package v1 |
||||
|
||||
import ( |
||||
context "context" |
||||
common "git.gz.internal.jumaiyx.cn/jm/jmproto/common" |
||||
grpc "google.golang.org/grpc" |
||||
codes "google.golang.org/grpc/codes" |
||||
status "google.golang.org/grpc/status" |
||||
) |
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the grpc package it is being compiled against.
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7 |
||||
|
||||
// PkServerClient is the client API for PkServer service.
|
||||
//
|
||||
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
||||
type PkServerClient interface { |
||||
GetPkRecord(ctx context.Context, in *GetPkRecordReq, opts ...grpc.CallOption) (*GetPkRecordResp, error) |
||||
// 创建PK
|
||||
CreatePkRecord(ctx context.Context, in *CreatePkRecordReq, opts ...grpc.CallOption) (*CreatePkRecordResp, error) |
||||
// 修改pK
|
||||
UpdatePkRecord(ctx context.Context, in *UpdatePkRecordReq, opts ...grpc.CallOption) (*CreatePkRecordResp, error) |
||||
// 发起邀请
|
||||
InvitePk(ctx context.Context, in *InvitePkReq, opts ...grpc.CallOption) (*InvitePkResp, error) |
||||
// 接受邀请
|
||||
AcceptPk(ctx context.Context, in *AcceptPkReq, opts ...grpc.CallOption) (*AcceptPkResp, error) |
||||
// 重新邀请
|
||||
Reset(ctx context.Context, in *ResetReq, opts ...grpc.CallOption) (*InvitePkResp, error) |
||||
// 获取pk的角色信息
|
||||
GetPkMikeRoleInfo(ctx context.Context, in *GetPkMikeRoleInfoReq, opts ...grpc.CallOption) (*GetPkMikeRoleInfoResp, error) |
||||
// 获取pk房间用户初始化的信息
|
||||
GetPkRoleDefaultInfo(ctx context.Context, in *GetPkRoleDefaultInfoReq, opts ...grpc.CallOption) (*GetPkRoleDefaultInfoResp, error) |
||||
// 获取pk房间默认配置信息
|
||||
GetPkRoomDefaultInfo(ctx context.Context, in *GetPkRoomDefaultInfoReq, opts ...grpc.CallOption) (*GetPkRoomDefaultInfoResp, error) |
||||
// 用户拾起buff礼物
|
||||
PickUpBuffGift(ctx context.Context, in *PickUpBuffGiftReq, opts ...grpc.CallOption) (*PickUpBuffGiftResp, error) |
||||
// buff礼物定时任务回调
|
||||
BuffGiftTimerTaskCallBack(ctx context.Context, in *BuffGiftTimerTaskCallBackReq, opts ...grpc.CallOption) (*common.Empty, error) |
||||
// 安全区定时任务回调
|
||||
SafeAreaTimerTaskCallBack(ctx context.Context, in *SafeAreaTimerTaskCallBackReq, opts ...grpc.CallOption) (*common.Empty, error) |
||||
} |
||||
|
||||
type pkServerClient struct { |
||||
cc grpc.ClientConnInterface |
||||
} |
||||
|
||||
func NewPkServerClient(cc grpc.ClientConnInterface) PkServerClient { |
||||
return &pkServerClient{cc} |
||||
} |
||||
|
||||
func (c *pkServerClient) GetPkRecord(ctx context.Context, in *GetPkRecordReq, opts ...grpc.CallOption) (*GetPkRecordResp, error) { |
||||
out := new(GetPkRecordResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/GetPkRecord", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) CreatePkRecord(ctx context.Context, in *CreatePkRecordReq, opts ...grpc.CallOption) (*CreatePkRecordResp, error) { |
||||
out := new(CreatePkRecordResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/CreatePkRecord", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) UpdatePkRecord(ctx context.Context, in *UpdatePkRecordReq, opts ...grpc.CallOption) (*CreatePkRecordResp, error) { |
||||
out := new(CreatePkRecordResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/UpdatePkRecord", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) InvitePk(ctx context.Context, in *InvitePkReq, opts ...grpc.CallOption) (*InvitePkResp, error) { |
||||
out := new(InvitePkResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/InvitePk", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) AcceptPk(ctx context.Context, in *AcceptPkReq, opts ...grpc.CallOption) (*AcceptPkResp, error) { |
||||
out := new(AcceptPkResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/AcceptPk", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) Reset(ctx context.Context, in *ResetReq, opts ...grpc.CallOption) (*InvitePkResp, error) { |
||||
out := new(InvitePkResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/Reset", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) GetPkMikeRoleInfo(ctx context.Context, in *GetPkMikeRoleInfoReq, opts ...grpc.CallOption) (*GetPkMikeRoleInfoResp, error) { |
||||
out := new(GetPkMikeRoleInfoResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/GetPkMikeRoleInfo", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) GetPkRoleDefaultInfo(ctx context.Context, in *GetPkRoleDefaultInfoReq, opts ...grpc.CallOption) (*GetPkRoleDefaultInfoResp, error) { |
||||
out := new(GetPkRoleDefaultInfoResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/GetPkRoleDefaultInfo", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) GetPkRoomDefaultInfo(ctx context.Context, in *GetPkRoomDefaultInfoReq, opts ...grpc.CallOption) (*GetPkRoomDefaultInfoResp, error) { |
||||
out := new(GetPkRoomDefaultInfoResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/GetPkRoomDefaultInfo", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) PickUpBuffGift(ctx context.Context, in *PickUpBuffGiftReq, opts ...grpc.CallOption) (*PickUpBuffGiftResp, error) { |
||||
out := new(PickUpBuffGiftResp) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/PickUpBuffGift", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) BuffGiftTimerTaskCallBack(ctx context.Context, in *BuffGiftTimerTaskCallBackReq, opts ...grpc.CallOption) (*common.Empty, error) { |
||||
out := new(common.Empty) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/BuffGiftTimerTaskCallBack", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
func (c *pkServerClient) SafeAreaTimerTaskCallBack(ctx context.Context, in *SafeAreaTimerTaskCallBackReq, opts ...grpc.CallOption) (*common.Empty, error) { |
||||
out := new(common.Empty) |
||||
err := c.cc.Invoke(ctx, "/pk.v1.PkServer/SafeAreaTimerTaskCallBack", in, out, opts...) |
||||
if err != nil { |
||||
return nil, err |
||||
} |
||||
return out, nil |
||||
} |
||||
|
||||
// PkServerServer is the server API for PkServer service.
|
||||
// All implementations must embed UnimplementedPkServerServer
|
||||
// for forward compatibility
|
||||
type PkServerServer interface { |
||||
GetPkRecord(context.Context, *GetPkRecordReq) (*GetPkRecordResp, error) |
||||
// 创建PK
|
||||
CreatePkRecord(context.Context, *CreatePkRecordReq) (*CreatePkRecordResp, error) |
||||
// 修改pK
|
||||
UpdatePkRecord(context.Context, *UpdatePkRecordReq) (*CreatePkRecordResp, error) |
||||
// 发起邀请
|
||||
InvitePk(context.Context, *InvitePkReq) (*InvitePkResp, error) |
||||
// 接受邀请
|
||||
AcceptPk(context.Context, *AcceptPkReq) (*AcceptPkResp, error) |
||||
// 重新邀请
|
||||
Reset(context.Context, *ResetReq) (*InvitePkResp, error) |
||||
// 获取pk的角色信息
|
||||
GetPkMikeRoleInfo(context.Context, *GetPkMikeRoleInfoReq) (*GetPkMikeRoleInfoResp, error) |
||||
// 获取pk房间用户初始化的信息
|
||||
GetPkRoleDefaultInfo(context.Context, *GetPkRoleDefaultInfoReq) (*GetPkRoleDefaultInfoResp, error) |
||||
// 获取pk房间默认配置信息
|
||||
GetPkRoomDefaultInfo(context.Context, *GetPkRoomDefaultInfoReq) (*GetPkRoomDefaultInfoResp, error) |
||||
// 用户拾起buff礼物
|
||||
PickUpBuffGift(context.Context, *PickUpBuffGiftReq) (*PickUpBuffGiftResp, error) |
||||
// buff礼物定时任务回调
|
||||
BuffGiftTimerTaskCallBack(context.Context, *BuffGiftTimerTaskCallBackReq) (*common.Empty, error) |
||||
// 安全区定时任务回调
|
||||
SafeAreaTimerTaskCallBack(context.Context, *SafeAreaTimerTaskCallBackReq) (*common.Empty, error) |
||||
mustEmbedUnimplementedPkServerServer() |
||||
} |
||||
|
||||
// UnimplementedPkServerServer must be embedded to have forward compatible implementations.
|
||||
type UnimplementedPkServerServer struct { |
||||
} |
||||
|
||||
func (UnimplementedPkServerServer) GetPkRecord(context.Context, *GetPkRecordReq) (*GetPkRecordResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetPkRecord not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) CreatePkRecord(context.Context, *CreatePkRecordReq) (*CreatePkRecordResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method CreatePkRecord not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) UpdatePkRecord(context.Context, *UpdatePkRecordReq) (*CreatePkRecordResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method UpdatePkRecord not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) InvitePk(context.Context, *InvitePkReq) (*InvitePkResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method InvitePk not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) AcceptPk(context.Context, *AcceptPkReq) (*AcceptPkResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method AcceptPk not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) Reset(context.Context, *ResetReq) (*InvitePkResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method Reset not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) GetPkMikeRoleInfo(context.Context, *GetPkMikeRoleInfoReq) (*GetPkMikeRoleInfoResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetPkMikeRoleInfo not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) GetPkRoleDefaultInfo(context.Context, *GetPkRoleDefaultInfoReq) (*GetPkRoleDefaultInfoResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetPkRoleDefaultInfo not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) GetPkRoomDefaultInfo(context.Context, *GetPkRoomDefaultInfoReq) (*GetPkRoomDefaultInfoResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method GetPkRoomDefaultInfo not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) PickUpBuffGift(context.Context, *PickUpBuffGiftReq) (*PickUpBuffGiftResp, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method PickUpBuffGift not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) BuffGiftTimerTaskCallBack(context.Context, *BuffGiftTimerTaskCallBackReq) (*common.Empty, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method BuffGiftTimerTaskCallBack not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) SafeAreaTimerTaskCallBack(context.Context, *SafeAreaTimerTaskCallBackReq) (*common.Empty, error) { |
||||
return nil, status.Errorf(codes.Unimplemented, "method SafeAreaTimerTaskCallBack not implemented") |
||||
} |
||||
func (UnimplementedPkServerServer) mustEmbedUnimplementedPkServerServer() {} |
||||
|
||||
// UnsafePkServerServer may be embedded to opt out of forward compatibility for this service.
|
||||
// Use of this interface is not recommended, as added methods to PkServerServer will
|
||||
// result in compilation errors.
|
||||
type UnsafePkServerServer interface { |
||||
mustEmbedUnimplementedPkServerServer() |
||||
} |
||||
|
||||
func RegisterPkServerServer(s grpc.ServiceRegistrar, srv PkServerServer) { |
||||
s.RegisterService(&PkServer_ServiceDesc, srv) |
||||
} |
||||
|
||||
func _PkServer_GetPkRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetPkRecordReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).GetPkRecord(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/GetPkRecord", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).GetPkRecord(ctx, req.(*GetPkRecordReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_CreatePkRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(CreatePkRecordReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).CreatePkRecord(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/CreatePkRecord", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).CreatePkRecord(ctx, req.(*CreatePkRecordReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_UpdatePkRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(UpdatePkRecordReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).UpdatePkRecord(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/UpdatePkRecord", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).UpdatePkRecord(ctx, req.(*UpdatePkRecordReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_InvitePk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(InvitePkReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).InvitePk(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/InvitePk", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).InvitePk(ctx, req.(*InvitePkReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_AcceptPk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(AcceptPkReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).AcceptPk(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/AcceptPk", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).AcceptPk(ctx, req.(*AcceptPkReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_Reset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(ResetReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).Reset(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/Reset", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).Reset(ctx, req.(*ResetReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_GetPkMikeRoleInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetPkMikeRoleInfoReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).GetPkMikeRoleInfo(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/GetPkMikeRoleInfo", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).GetPkMikeRoleInfo(ctx, req.(*GetPkMikeRoleInfoReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_GetPkRoleDefaultInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetPkRoleDefaultInfoReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).GetPkRoleDefaultInfo(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/GetPkRoleDefaultInfo", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).GetPkRoleDefaultInfo(ctx, req.(*GetPkRoleDefaultInfoReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_GetPkRoomDefaultInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(GetPkRoomDefaultInfoReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).GetPkRoomDefaultInfo(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/GetPkRoomDefaultInfo", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).GetPkRoomDefaultInfo(ctx, req.(*GetPkRoomDefaultInfoReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_PickUpBuffGift_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(PickUpBuffGiftReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).PickUpBuffGift(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/PickUpBuffGift", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).PickUpBuffGift(ctx, req.(*PickUpBuffGiftReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_BuffGiftTimerTaskCallBack_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(BuffGiftTimerTaskCallBackReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).BuffGiftTimerTaskCallBack(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/BuffGiftTimerTaskCallBack", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).BuffGiftTimerTaskCallBack(ctx, req.(*BuffGiftTimerTaskCallBackReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
func _PkServer_SafeAreaTimerTaskCallBack_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
||||
in := new(SafeAreaTimerTaskCallBackReq) |
||||
if err := dec(in); err != nil { |
||||
return nil, err |
||||
} |
||||
if interceptor == nil { |
||||
return srv.(PkServerServer).SafeAreaTimerTaskCallBack(ctx, in) |
||||
} |
||||
info := &grpc.UnaryServerInfo{ |
||||
Server: srv, |
||||
FullMethod: "/pk.v1.PkServer/SafeAreaTimerTaskCallBack", |
||||
} |
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
||||
return srv.(PkServerServer).SafeAreaTimerTaskCallBack(ctx, req.(*SafeAreaTimerTaskCallBackReq)) |
||||
} |
||||
return interceptor(ctx, in, info, handler) |
||||
} |
||||
|
||||
// PkServer_ServiceDesc is the grpc.ServiceDesc for PkServer service.
|
||||
// It's only intended for direct use with grpc.RegisterService,
|
||||
// and not to be introspected or modified (even as a copy)
|
||||
var PkServer_ServiceDesc = grpc.ServiceDesc{ |
||||
ServiceName: "pk.v1.PkServer", |
||||
HandlerType: (*PkServerServer)(nil), |
||||
Methods: []grpc.MethodDesc{ |
||||
{ |
||||
MethodName: "GetPkRecord", |
||||
Handler: _PkServer_GetPkRecord_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "CreatePkRecord", |
||||
Handler: _PkServer_CreatePkRecord_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "UpdatePkRecord", |
||||
Handler: _PkServer_UpdatePkRecord_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "InvitePk", |
||||
Handler: _PkServer_InvitePk_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "AcceptPk", |
||||
Handler: _PkServer_AcceptPk_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "Reset", |
||||
Handler: _PkServer_Reset_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetPkMikeRoleInfo", |
||||
Handler: _PkServer_GetPkMikeRoleInfo_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetPkRoleDefaultInfo", |
||||
Handler: _PkServer_GetPkRoleDefaultInfo_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "GetPkRoomDefaultInfo", |
||||
Handler: _PkServer_GetPkRoomDefaultInfo_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "PickUpBuffGift", |
||||
Handler: _PkServer_PickUpBuffGift_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "BuffGiftTimerTaskCallBack", |
||||
Handler: _PkServer_BuffGiftTimerTaskCallBack_Handler, |
||||
}, |
||||
{ |
||||
MethodName: "SafeAreaTimerTaskCallBack", |
||||
Handler: _PkServer_SafeAreaTimerTaskCallBack_Handler, |
||||
}, |
||||
}, |
||||
Streams: []grpc.StreamDesc{}, |
||||
Metadata: "pk/v1/pk.proto", |
||||
} |
||||
Loading…
Reference in new issue