|
|
|
|
@ -45,9 +45,9 @@ const (
|
|
|
|
|
Live_GetHotspotList_FullMethodName = "/live.v1.Live/GetHotspotList" |
|
|
|
|
Live_GetLiveUserAuthList_FullMethodName = "/live.v1.Live/GetLiveUserAuthList" |
|
|
|
|
Live_SetLiveUserAuth_FullMethodName = "/live.v1.Live/SetLiveUserAuth" |
|
|
|
|
Live_GetLiveUserChatList_FullMethodName = "/live.v1.Live/GetLiveUserChatList" |
|
|
|
|
Live_GetLiveUserChatCount_FullMethodName = "/live.v1.Live/GetLiveUserChatCount" |
|
|
|
|
Live_SetLiveUserChat_FullMethodName = "/live.v1.Live/SetLiveUserChat" |
|
|
|
|
Live_GetUserChatRecordList_FullMethodName = "/live.v1.Live/GetUserChatRecordList" |
|
|
|
|
Live_GetUserChatRecordCount_FullMethodName = "/live.v1.Live/GetUserChatRecordCount" |
|
|
|
|
Live_SetUserChat_FullMethodName = "/live.v1.Live/SetUserChat" |
|
|
|
|
Live_SetDefaultHotValue_FullMethodName = "/live.v1.Live/SetDefaultHotValue" |
|
|
|
|
Live_GetDefaultHotValueList_FullMethodName = "/live.v1.Live/GetDefaultHotValueList" |
|
|
|
|
Live_GetProxyList_FullMethodName = "/live.v1.Live/GetProxyList" |
|
|
|
|
@ -129,11 +129,11 @@ type LiveClient interface {
|
|
|
|
|
// 设置直播用户权限
|
|
|
|
|
// Deprecated
|
|
|
|
|
SetLiveUserAuth(ctx context.Context, in *SetLiveUserAuthReq, opts ...grpc.CallOption) (*NilResp, error) |
|
|
|
|
// 获取用户禁言状态列表
|
|
|
|
|
GetLiveUserChatList(ctx context.Context, in *GetLiveUserChatListReq, opts ...grpc.CallOption) (*GetLiveUserAuthListResp, error) |
|
|
|
|
GetLiveUserChatCount(ctx context.Context, in *GetLiveUserChatListReq, opts ...grpc.CallOption) (*Total, error) |
|
|
|
|
// 获取用户禁言记录列表
|
|
|
|
|
GetUserChatRecordList(ctx context.Context, in *GetUserChatRecordListReq, opts ...grpc.CallOption) (*GetUserChatRecordListResp, error) |
|
|
|
|
GetUserChatRecordCount(ctx context.Context, in *GetUserChatRecordListReq, opts ...grpc.CallOption) (*Total, error) |
|
|
|
|
// 设置用户禁言状态
|
|
|
|
|
SetLiveUserChat(ctx context.Context, in *SetLiveUserChatReq, opts ...grpc.CallOption) (*NilResp, error) |
|
|
|
|
SetUserChat(ctx context.Context, in *SetUserChatReq, opts ...grpc.CallOption) (*NilResp, error) |
|
|
|
|
// 设置默认热度值
|
|
|
|
|
SetDefaultHotValue(ctx context.Context, in *SetDefaultHotValueReq, opts ...grpc.CallOption) (*NilResp, error) |
|
|
|
|
// 获取默认热度值
|
|
|
|
|
@ -420,27 +420,27 @@ func (c *liveClient) SetLiveUserAuth(ctx context.Context, in *SetLiveUserAuthReq
|
|
|
|
|
return out, nil |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (c *liveClient) GetLiveUserChatList(ctx context.Context, in *GetLiveUserChatListReq, opts ...grpc.CallOption) (*GetLiveUserAuthListResp, error) { |
|
|
|
|
out := new(GetLiveUserAuthListResp) |
|
|
|
|
err := c.cc.Invoke(ctx, Live_GetLiveUserChatList_FullMethodName, in, out, opts...) |
|
|
|
|
func (c *liveClient) GetUserChatRecordList(ctx context.Context, in *GetUserChatRecordListReq, opts ...grpc.CallOption) (*GetUserChatRecordListResp, error) { |
|
|
|
|
out := new(GetUserChatRecordListResp) |
|
|
|
|
err := c.cc.Invoke(ctx, Live_GetUserChatRecordList_FullMethodName, in, out, opts...) |
|
|
|
|
if err != nil { |
|
|
|
|
return nil, err |
|
|
|
|
} |
|
|
|
|
return out, nil |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (c *liveClient) GetLiveUserChatCount(ctx context.Context, in *GetLiveUserChatListReq, opts ...grpc.CallOption) (*Total, error) { |
|
|
|
|
func (c *liveClient) GetUserChatRecordCount(ctx context.Context, in *GetUserChatRecordListReq, opts ...grpc.CallOption) (*Total, error) { |
|
|
|
|
out := new(Total) |
|
|
|
|
err := c.cc.Invoke(ctx, Live_GetLiveUserChatCount_FullMethodName, in, out, opts...) |
|
|
|
|
err := c.cc.Invoke(ctx, Live_GetUserChatRecordCount_FullMethodName, in, out, opts...) |
|
|
|
|
if err != nil { |
|
|
|
|
return nil, err |
|
|
|
|
} |
|
|
|
|
return out, nil |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (c *liveClient) SetLiveUserChat(ctx context.Context, in *SetLiveUserChatReq, opts ...grpc.CallOption) (*NilResp, error) { |
|
|
|
|
func (c *liveClient) SetUserChat(ctx context.Context, in *SetUserChatReq, opts ...grpc.CallOption) (*NilResp, error) { |
|
|
|
|
out := new(NilResp) |
|
|
|
|
err := c.cc.Invoke(ctx, Live_SetLiveUserChat_FullMethodName, in, out, opts...) |
|
|
|
|
err := c.cc.Invoke(ctx, Live_SetUserChat_FullMethodName, in, out, opts...) |
|
|
|
|
if err != nil { |
|
|
|
|
return nil, err |
|
|
|
|
} |
|
|
|
|
@ -694,11 +694,11 @@ type LiveServer interface {
|
|
|
|
|
// 设置直播用户权限
|
|
|
|
|
// Deprecated
|
|
|
|
|
SetLiveUserAuth(context.Context, *SetLiveUserAuthReq) (*NilResp, error) |
|
|
|
|
// 获取用户禁言状态列表
|
|
|
|
|
GetLiveUserChatList(context.Context, *GetLiveUserChatListReq) (*GetLiveUserAuthListResp, error) |
|
|
|
|
GetLiveUserChatCount(context.Context, *GetLiveUserChatListReq) (*Total, error) |
|
|
|
|
// 获取用户禁言记录列表
|
|
|
|
|
GetUserChatRecordList(context.Context, *GetUserChatRecordListReq) (*GetUserChatRecordListResp, error) |
|
|
|
|
GetUserChatRecordCount(context.Context, *GetUserChatRecordListReq) (*Total, error) |
|
|
|
|
// 设置用户禁言状态
|
|
|
|
|
SetLiveUserChat(context.Context, *SetLiveUserChatReq) (*NilResp, error) |
|
|
|
|
SetUserChat(context.Context, *SetUserChatReq) (*NilResp, error) |
|
|
|
|
// 设置默认热度值
|
|
|
|
|
SetDefaultHotValue(context.Context, *SetDefaultHotValueReq) (*NilResp, error) |
|
|
|
|
// 获取默认热度值
|
|
|
|
|
@ -826,14 +826,14 @@ func (UnimplementedLiveServer) GetLiveUserAuthList(context.Context, *GetLiveUser
|
|
|
|
|
func (UnimplementedLiveServer) SetLiveUserAuth(context.Context, *SetLiveUserAuthReq) (*NilResp, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetLiveUserAuth not implemented") |
|
|
|
|
} |
|
|
|
|
func (UnimplementedLiveServer) GetLiveUserChatList(context.Context, *GetLiveUserChatListReq) (*GetLiveUserAuthListResp, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetLiveUserChatList not implemented") |
|
|
|
|
func (UnimplementedLiveServer) GetUserChatRecordList(context.Context, *GetUserChatRecordListReq) (*GetUserChatRecordListResp, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetUserChatRecordList not implemented") |
|
|
|
|
} |
|
|
|
|
func (UnimplementedLiveServer) GetLiveUserChatCount(context.Context, *GetLiveUserChatListReq) (*Total, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetLiveUserChatCount not implemented") |
|
|
|
|
func (UnimplementedLiveServer) GetUserChatRecordCount(context.Context, *GetUserChatRecordListReq) (*Total, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetUserChatRecordCount not implemented") |
|
|
|
|
} |
|
|
|
|
func (UnimplementedLiveServer) SetLiveUserChat(context.Context, *SetLiveUserChatReq) (*NilResp, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetLiveUserChat not implemented") |
|
|
|
|
func (UnimplementedLiveServer) SetUserChat(context.Context, *SetUserChatReq) (*NilResp, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetUserChat not implemented") |
|
|
|
|
} |
|
|
|
|
func (UnimplementedLiveServer) SetDefaultHotValue(context.Context, *SetDefaultHotValueReq) (*NilResp, error) { |
|
|
|
|
return nil, status.Errorf(codes.Unimplemented, "method SetDefaultHotValue not implemented") |
|
|
|
|
@ -1379,56 +1379,56 @@ func _Live_SetLiveUserAuth_Handler(srv interface{}, ctx context.Context, dec fun
|
|
|
|
|
return interceptor(ctx, in, info, handler) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func _Live_GetLiveUserChatList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|
|
|
|
in := new(GetLiveUserChatListReq) |
|
|
|
|
func _Live_GetUserChatRecordList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|
|
|
|
in := new(GetUserChatRecordListReq) |
|
|
|
|
if err := dec(in); err != nil { |
|
|
|
|
return nil, err |
|
|
|
|
} |
|
|
|
|
if interceptor == nil { |
|
|
|
|
return srv.(LiveServer).GetLiveUserChatList(ctx, in) |
|
|
|
|
return srv.(LiveServer).GetUserChatRecordList(ctx, in) |
|
|
|
|
} |
|
|
|
|
info := &grpc.UnaryServerInfo{ |
|
|
|
|
Server: srv, |
|
|
|
|
FullMethod: Live_GetLiveUserChatList_FullMethodName, |
|
|
|
|
FullMethod: Live_GetUserChatRecordList_FullMethodName, |
|
|
|
|
} |
|
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|
|
|
|
return srv.(LiveServer).GetLiveUserChatList(ctx, req.(*GetLiveUserChatListReq)) |
|
|
|
|
return srv.(LiveServer).GetUserChatRecordList(ctx, req.(*GetUserChatRecordListReq)) |
|
|
|
|
} |
|
|
|
|
return interceptor(ctx, in, info, handler) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func _Live_GetLiveUserChatCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|
|
|
|
in := new(GetLiveUserChatListReq) |
|
|
|
|
func _Live_GetUserChatRecordCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|
|
|
|
in := new(GetUserChatRecordListReq) |
|
|
|
|
if err := dec(in); err != nil { |
|
|
|
|
return nil, err |
|
|
|
|
} |
|
|
|
|
if interceptor == nil { |
|
|
|
|
return srv.(LiveServer).GetLiveUserChatCount(ctx, in) |
|
|
|
|
return srv.(LiveServer).GetUserChatRecordCount(ctx, in) |
|
|
|
|
} |
|
|
|
|
info := &grpc.UnaryServerInfo{ |
|
|
|
|
Server: srv, |
|
|
|
|
FullMethod: Live_GetLiveUserChatCount_FullMethodName, |
|
|
|
|
FullMethod: Live_GetUserChatRecordCount_FullMethodName, |
|
|
|
|
} |
|
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|
|
|
|
return srv.(LiveServer).GetLiveUserChatCount(ctx, req.(*GetLiveUserChatListReq)) |
|
|
|
|
return srv.(LiveServer).GetUserChatRecordCount(ctx, req.(*GetUserChatRecordListReq)) |
|
|
|
|
} |
|
|
|
|
return interceptor(ctx, in, info, handler) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func _Live_SetLiveUserChat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|
|
|
|
in := new(SetLiveUserChatReq) |
|
|
|
|
func _Live_SetUserChat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|
|
|
|
in := new(SetUserChatReq) |
|
|
|
|
if err := dec(in); err != nil { |
|
|
|
|
return nil, err |
|
|
|
|
} |
|
|
|
|
if interceptor == nil { |
|
|
|
|
return srv.(LiveServer).SetLiveUserChat(ctx, in) |
|
|
|
|
return srv.(LiveServer).SetUserChat(ctx, in) |
|
|
|
|
} |
|
|
|
|
info := &grpc.UnaryServerInfo{ |
|
|
|
|
Server: srv, |
|
|
|
|
FullMethod: Live_SetLiveUserChat_FullMethodName, |
|
|
|
|
FullMethod: Live_SetUserChat_FullMethodName, |
|
|
|
|
} |
|
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|
|
|
|
return srv.(LiveServer).SetLiveUserChat(ctx, req.(*SetLiveUserChatReq)) |
|
|
|
|
return srv.(LiveServer).SetUserChat(ctx, req.(*SetUserChatReq)) |
|
|
|
|
} |
|
|
|
|
return interceptor(ctx, in, info, handler) |
|
|
|
|
} |
|
|
|
|
@ -1923,16 +1923,16 @@ var Live_ServiceDesc = grpc.ServiceDesc{
|
|
|
|
|
Handler: _Live_SetLiveUserAuth_Handler, |
|
|
|
|
}, |
|
|
|
|
{ |
|
|
|
|
MethodName: "GetLiveUserChatList", |
|
|
|
|
Handler: _Live_GetLiveUserChatList_Handler, |
|
|
|
|
MethodName: "GetUserChatRecordList", |
|
|
|
|
Handler: _Live_GetUserChatRecordList_Handler, |
|
|
|
|
}, |
|
|
|
|
{ |
|
|
|
|
MethodName: "GetLiveUserChatCount", |
|
|
|
|
Handler: _Live_GetLiveUserChatCount_Handler, |
|
|
|
|
MethodName: "GetUserChatRecordCount", |
|
|
|
|
Handler: _Live_GetUserChatRecordCount_Handler, |
|
|
|
|
}, |
|
|
|
|
{ |
|
|
|
|
MethodName: "SetLiveUserChat", |
|
|
|
|
Handler: _Live_SetLiveUserChat_Handler, |
|
|
|
|
MethodName: "SetUserChat", |
|
|
|
|
Handler: _Live_SetUserChat_Handler, |
|
|
|
|
}, |
|
|
|
|
{ |
|
|
|
|
MethodName: "SetDefaultHotValue", |
|
|
|
|
|
