msb-public
/
Open-IM-Server
mirror of https://github.com/OpenIMSDK/Open-IM-Server
2
0
Code Issues Projects Releases Wiki Activity

add function

Browse Source
pull/236/head
Gordon 2 years ago
parent 0a260a67d5
commit 8bd5db431b
3 changed files with 184 additions and 57 deletions
Show Stats Download Patch File Download Diff File

4
internal/msg_gateway/gate/rpc_server.go
Unescape View File

@ -29,6 +29,10 @@ type RPCServer struct {
pushTerminal []int
}
func (r *RPCServer) KickUserOffline(c context.Context, req *pbRelay.KickUserOfflineReq) (*pbRelay.KickUserOfflineResp, error) {
panic("implement me")
}
func (r *RPCServer) onInit(rpcPort int) {
r.rpcPort = rpcPort
r.rpcRegisterName = config.Config.RpcRegisterName.OpenImOnlineMessageRelayName

229
pkg/proto/relay/relay.pb.go
Unescape View File

@ -37,7 +37,7 @@ func (m *OnlinePushMsgReq) Reset() { *m = OnlinePushMsgReq{} }
func (m *OnlinePushMsgReq) String() string { return proto.CompactTextString(m) }
func (*OnlinePushMsgReq) ProtoMessage() {}
func (*OnlinePushMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{0}
return fileDescriptor_relay_335282936f1b89e7, []int{0}
}
func (m *OnlinePushMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlinePushMsgReq.Unmarshal(m, b)
@ -89,7 +89,7 @@ func (m *OnlinePushMsgResp) Reset() { *m = OnlinePushMsgResp{} }
func (m *OnlinePushMsgResp) String() string { return proto.CompactTextString(m) }
func (*OnlinePushMsgResp) ProtoMessage() {}
func (*OnlinePushMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{1}
return fileDescriptor_relay_335282936f1b89e7, []int{1}
}
func (m *OnlinePushMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlinePushMsgResp.Unmarshal(m, b)
@ -129,7 +129,7 @@ func (m *SingelMsgToUserResultList) Reset() { *m = SingelMsgToUserResult
func (m *SingelMsgToUserResultList) String() string { return proto.CompactTextString(m) }
func (*SingelMsgToUserResultList) ProtoMessage() {}
func (*SingelMsgToUserResultList) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{2}
return fileDescriptor_relay_335282936f1b89e7, []int{2}
}
func (m *SingelMsgToUserResultList) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SingelMsgToUserResultList.Unmarshal(m, b)
@ -183,7 +183,7 @@ func (m *OnlineBatchPushOneMsgReq) Reset() { *m = OnlineBatchPushOneMsgR
func (m *OnlineBatchPushOneMsgReq) String() string { return proto.CompactTextString(m) }
func (*OnlineBatchPushOneMsgReq) ProtoMessage() {}
func (*OnlineBatchPushOneMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{3}
return fileDescriptor_relay_335282936f1b89e7, []int{3}
}
func (m *OnlineBatchPushOneMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlineBatchPushOneMsgReq.Unmarshal(m, b)
@ -235,7 +235,7 @@ func (m *OnlineBatchPushOneMsgResp) Reset() { *m = OnlineBatchPushOneMsg
func (m *OnlineBatchPushOneMsgResp) String() string { return proto.CompactTextString(m) }
func (*OnlineBatchPushOneMsgResp) ProtoMessage() {}
func (*OnlineBatchPushOneMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{4}
return fileDescriptor_relay_335282936f1b89e7, []int{4}
}
func (m *OnlineBatchPushOneMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlineBatchPushOneMsgResp.Unmarshal(m, b)
@ -275,7 +275,7 @@ func (m *SingleMsgToUserPlatform) Reset() { *m = SingleMsgToUserPlatform
func (m *SingleMsgToUserPlatform) String() string { return proto.CompactTextString(m) }
func (*SingleMsgToUserPlatform) ProtoMessage() {}
func (*SingleMsgToUserPlatform) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{5}
return fileDescriptor_relay_335282936f1b89e7, []int{5}
}
func (m *SingleMsgToUserPlatform) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SingleMsgToUserPlatform.Unmarshal(m, b)
@ -329,7 +329,7 @@ func (m *GetUsersOnlineStatusReq) Reset() { *m = GetUsersOnlineStatusReq
func (m *GetUsersOnlineStatusReq) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusReq) ProtoMessage() {}
func (*GetUsersOnlineStatusReq) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{6}
return fileDescriptor_relay_335282936f1b89e7, []int{6}
}
func (m *GetUsersOnlineStatusReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusReq.Unmarshal(m, b)
@ -384,7 +384,7 @@ func (m *GetUsersOnlineStatusResp) Reset() { *m = GetUsersOnlineStatusRe
func (m *GetUsersOnlineStatusResp) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp) ProtoMessage() {}
func (*GetUsersOnlineStatusResp) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{7}
return fileDescriptor_relay_335282936f1b89e7, []int{7}
}
func (m *GetUsersOnlineStatusResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp.Unmarshal(m, b)
@ -446,7 +446,7 @@ func (m *GetUsersOnlineStatusResp_SuccessDetail) Reset() {
func (m *GetUsersOnlineStatusResp_SuccessDetail) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp_SuccessDetail) ProtoMessage() {}
func (*GetUsersOnlineStatusResp_SuccessDetail) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{7, 0}
return fileDescriptor_relay_335282936f1b89e7, []int{7, 0}
}
func (m *GetUsersOnlineStatusResp_SuccessDetail) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail.Unmarshal(m, b)
@ -493,7 +493,7 @@ func (m *GetUsersOnlineStatusResp_FailedDetail) Reset() { *m = GetUsersO
func (m *GetUsersOnlineStatusResp_FailedDetail) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp_FailedDetail) ProtoMessage() {}
func (*GetUsersOnlineStatusResp_FailedDetail) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{7, 1}
return fileDescriptor_relay_335282936f1b89e7, []int{7, 1}
}
func (m *GetUsersOnlineStatusResp_FailedDetail) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail.Unmarshal(m, b)
@ -549,7 +549,7 @@ func (m *GetUsersOnlineStatusResp_SuccessResult) Reset() {
func (m *GetUsersOnlineStatusResp_SuccessResult) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp_SuccessResult) ProtoMessage() {}
func (*GetUsersOnlineStatusResp_SuccessResult) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_77ab6a9fe292f32a, []int{7, 2}
return fileDescriptor_relay_335282936f1b89e7, []int{7, 2}
}
func (m *GetUsersOnlineStatusResp_SuccessResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult.Unmarshal(m, b)
@ -590,6 +590,82 @@ func (m *GetUsersOnlineStatusResp_SuccessResult) GetDetailPlatformStatus() []*Ge
return nil
}
type KickUserOfflineReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
KickUserIDList []string `protobuf:"bytes,3,rep,name=kickUserIDList" json:"kickUserIDList,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *KickUserOfflineReq) Reset() { *m = KickUserOfflineReq{} }
func (m *KickUserOfflineReq) String() string { return proto.CompactTextString(m) }
func (*KickUserOfflineReq) ProtoMessage() {}
func (*KickUserOfflineReq) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_335282936f1b89e7, []int{8}
}
func (m *KickUserOfflineReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KickUserOfflineReq.Unmarshal(m, b)
}
func (m *KickUserOfflineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KickUserOfflineReq.Marshal(b, m, deterministic)
}
func (dst *KickUserOfflineReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_KickUserOfflineReq.Merge(dst, src)
}
func (m *KickUserOfflineReq) XXX_Size() int {
return xxx_messageInfo_KickUserOfflineReq.Size(m)
}
func (m *KickUserOfflineReq) XXX_DiscardUnknown() {
xxx_messageInfo_KickUserOfflineReq.DiscardUnknown(m)
}
var xxx_messageInfo_KickUserOfflineReq proto.InternalMessageInfo
func (m *KickUserOfflineReq) GetOperationID() string {
if m != nil {
return m.OperationID
}
return ""
}
func (m *KickUserOfflineReq) GetKickUserIDList() []string {
if m != nil {
return m.KickUserIDList
}
return nil
}
type KickUserOfflineResp struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *KickUserOfflineResp) Reset() { *m = KickUserOfflineResp{} }
func (m *KickUserOfflineResp) String() string { return proto.CompactTextString(m) }
func (*KickUserOfflineResp) ProtoMessage() {}
func (*KickUserOfflineResp) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_335282936f1b89e7, []int{9}
}
func (m *KickUserOfflineResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KickUserOfflineResp.Unmarshal(m, b)
}
func (m *KickUserOfflineResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KickUserOfflineResp.Marshal(b, m, deterministic)
}
func (dst *KickUserOfflineResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_KickUserOfflineResp.Merge(dst, src)
}
func (m *KickUserOfflineResp) XXX_Size() int {
return xxx_messageInfo_KickUserOfflineResp.Size(m)
}
func (m *KickUserOfflineResp) XXX_DiscardUnknown() {
xxx_messageInfo_KickUserOfflineResp.DiscardUnknown(m)
}
var xxx_messageInfo_KickUserOfflineResp proto.InternalMessageInfo
func init() {
proto.RegisterType((*OnlinePushMsgReq)(nil), "relay.OnlinePushMsgReq")
proto.RegisterType((*OnlinePushMsgResp)(nil), "relay.OnlinePushMsgResp")
@ -602,6 +678,8 @@ func init() {
proto.RegisterType((*GetUsersOnlineStatusResp_SuccessDetail)(nil), "relay.GetUsersOnlineStatusResp.SuccessDetail")
proto.RegisterType((*GetUsersOnlineStatusResp_FailedDetail)(nil), "relay.GetUsersOnlineStatusResp.FailedDetail")
proto.RegisterType((*GetUsersOnlineStatusResp_SuccessResult)(nil), "relay.GetUsersOnlineStatusResp.SuccessResult")
proto.RegisterType((*KickUserOfflineReq)(nil), "relay.KickUserOfflineReq")
proto.RegisterType((*KickUserOfflineResp)(nil), "relay.KickUserOfflineResp")
}
// Reference imports to suppress errors if they are not otherwise used.
@ -618,6 +696,7 @@ type OnlineMessageRelayServiceClient interface {
OnlinePushMsg(ctx context.Context, in *OnlinePushMsgReq, opts ...grpc.CallOption) (*OnlinePushMsgResp, error)
GetUsersOnlineStatus(ctx context.Context, in *GetUsersOnlineStatusReq, opts ...grpc.CallOption) (*GetUsersOnlineStatusResp, error)
OnlineBatchPushOneMsg(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error)
KickUserOffline(ctx context.Context, in *KickUserOfflineReq, opts ...grpc.CallOption) (*KickUserOfflineResp, error)
}
type onlineMessageRelayServiceClient struct {
@ -655,12 +734,22 @@ func (c *onlineMessageRelayServiceClient) OnlineBatchPushOneMsg(ctx context.Cont
return out, nil
}
func (c *onlineMessageRelayServiceClient) KickUserOffline(ctx context.Context, in *KickUserOfflineReq, opts ...grpc.CallOption) (*KickUserOfflineResp, error) {
out := new(KickUserOfflineResp)
err := grpc.Invoke(ctx, "/relay.OnlineMessageRelayService/KickUserOffline", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for OnlineMessageRelayService service
type OnlineMessageRelayServiceServer interface {
OnlinePushMsg(context.Context, *OnlinePushMsgReq) (*OnlinePushMsgResp, error)
GetUsersOnlineStatus(context.Context, *GetUsersOnlineStatusReq) (*GetUsersOnlineStatusResp, error)
OnlineBatchPushOneMsg(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)
KickUserOffline(context.Context, *KickUserOfflineReq) (*KickUserOfflineResp, error)
}
func RegisterOnlineMessageRelayServiceServer(s *grpc.Server, srv OnlineMessageRelayServiceServer) {
@ -721,6 +810,24 @@ func _OnlineMessageRelayService_OnlineBatchPushOneMsg_Handler(srv interface{}, c
return interceptor(ctx, in, info, handler)
}
func _OnlineMessageRelayService_KickUserOffline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(KickUserOfflineReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OnlineMessageRelayServiceServer).KickUserOffline(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/relay.OnlineMessageRelayService/KickUserOffline",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OnlineMessageRelayServiceServer).KickUserOffline(ctx, req.(*KickUserOfflineReq))
}
return interceptor(ctx, in, info, handler)
}
var _OnlineMessageRelayService_serviceDesc = grpc.ServiceDesc{
ServiceName: "relay.OnlineMessageRelayService",
HandlerType: (*OnlineMessageRelayServiceServer)(nil),
@ -737,55 +844,63 @@ var _OnlineMessageRelayService_serviceDesc = grpc.ServiceDesc{
MethodName: "OnlineBatchPushOneMsg",
Handler: _OnlineMessageRelayService_OnlineBatchPushOneMsg_Handler,
},
{
MethodName: "KickUserOffline",
Handler: _OnlineMessageRelayService_KickUserOffline_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "relay/relay.proto",
}
func init() { proto.RegisterFile("relay/relay.proto", fileDescriptor_relay_77ab6a9fe292f32a) }
var fileDescriptor_relay_77ab6a9fe292f32a = []byte{
// 668 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0x4f, 0x4f, 0xdb, 0x4a,
0x10, 0x97, 0x31, 0x7f, 0x07, 0x78, 0x0f, 0x56, 0xbc, 0x87, 0xf1, 0x21, 0xb8, 0x3e, 0x54, 0x51,
0xd5, 0x26, 0x52, 0xda, 0x5b, 0x6f, 0x10, 0x81, 0x22, 0x11, 0x05, 0x6d, 0x5a, 0xb5, 0xe2, 0x12,
0x2d, 0xc9, 0x62, 0x2c, 0x9c, 0x78, 0xd9, 0xb1, 0x41, 0x7c, 0x82, 0xde, 0x7a, 0xea, 0xb9, 0x87,
0x7e, 0x89, 0x7e, 0xbd, 0x6a, 0xff, 0xc4, 0xb5, 0x21, 0x81, 0x72, 0xe8, 0x25, 0xca, 0xcc, 0xce,
0xce, 0xfc, 0xfe, 0xec, 0xae, 0x61, 0x5b, 0xf2, 0x84, 0xdd, 0x35, 0xf5, 0x6f, 0x43, 0xc8, 0x34,
0x4b, 0xc9, 0x92, 0x0e, 0xfc, 0x17, 0x3d, 0xc1, 0x27, 0x83, 0x4e, 0xb7, 0x29, 0xae, 0xa2, 0xa6,
0x5e, 0x69, 0xe2, 0xe8, 0x6a, 0x70, 0x8b, 0xcd, 0x5b, 0x34, 0x95, 0xe1, 0x57, 0x07, 0xb6, 0x7a,
0x93, 0x24, 0x9e, 0xf0, 0xd3, 0x1c, 0x2f, 0xbb, 0x18, 0x51, 0x7e, 0x4d, 0x02, 0x58, 0xef, 0x09,
0x2e, 0x59, 0x16, 0xa7, 0x93, 0x4e, 0xdb, 0x73, 0x02, 0xa7, 0xbe, 0x46, 0xcb, 0x29, 0xf2, 0x0e,
0x56, 0xc6, 0x18, 0xb5, 0x59, 0xc6, 0xbc, 0x85, 0xc0, 0xa9, 0xaf, 0xb7, 0xfc, 0x06, 0x72, 0x79,
0xc3, 0xe5, 0x80, 0x89, 0x78, 0x20, 0x98, 0x64, 0x63, 0x6c, 0x74, 0x4d, 0x05, 0x9d, 0x96, 0x92,
0x10, 0x36, 0x44, 0x8e, 0x97, 0x1f, 0xd2, 0x8f, 0xc8, 0x65, 0xa7, 0xed, 0xb9, 0xba, 0x71, 0x25,
0x17, 0x1e, 0xc3, 0xf6, 0x3d, 0x3c, 0x28, 0x48, 0x0b, 0x16, 0x25, 0x47, 0xe1, 0x39, 0x81, 0x5b,
0x5f, 0x6f, 0xd5, 0x1a, 0x86, 0x6b, 0x3f, 0x9e, 0x44, 0x09, 0xef, 0x62, 0x64, 0x36, 0x9f, 0x26,
0x2c, 0xbb, 0x48, 0xe5, 0x98, 0xea, 0xda, 0xf0, 0x8b, 0x03, 0x7b, 0xaa, 0x82, 0x27, 0x45, 0x05,
0xe5, 0x98, 0x27, 0xd9, 0x49, 0x8c, 0x19, 0xf9, 0x1f, 0x96, 0x73, 0x03, 0xc2, 0xb0, 0xb3, 0x51,
0x31, 0x69, 0xe1, 0xcf, 0x27, 0x91, 0x1a, 0x40, 0x5a, 0x40, 0xd6, 0xa4, 0x56, 0x69, 0x29, 0x13,
0x7e, 0x77, 0xc0, 0x33, 0x9c, 0x0e, 0x58, 0x36, 0xbc, 0x54, 0xb9, 0xde, 0x84, 0xff, 0x65, 0xad,
0x5f, 0xc1, 0x56, 0x59, 0x57, 0x45, 0xda, 0x73, 0x03, 0xb7, 0xbe, 0x46, 0x1f, 0xe4, 0xc3, 0x18,
0xf6, 0xe6, 0xe0, 0x43, 0x41, 0x4e, 0x60, 0x0b, 0x35, 0x7d, 0x95, 0x37, 0x0a, 0x5a, 0x1f, 0x82,
0x92, 0x3a, 0x33, 0x55, 0xa6, 0x0f, 0x76, 0x86, 0x77, 0xb0, 0x3b, 0x47, 0x4c, 0x25, 0xa3, 0x29,
0x3a, 0x4c, 0x47, 0x5c, 0x0b, 0xe1, 0xd2, 0x52, 0x46, 0x59, 0x46, 0xf9, 0xf0, 0xa6, 0xd3, 0xd6,
0x32, 0xac, 0x51, 0x1b, 0x91, 0x97, 0xf0, 0x8f, 0xfa, 0xa7, 0xfa, 0x1c, 0xa5, 0x72, 0x6c, 0xcf,
0xd5, 0x12, 0xbd, 0x97, 0x0d, 0x6f, 0x61, 0xf7, 0x98, 0x67, 0x6a, 0x24, 0x1a, 0xb6, 0xfd, 0x8c,
0x65, 0x39, 0x2a, 0x13, 0x6a, 0x00, 0xf9, 0x6f, 0x99, 0x1c, 0x2d, 0x53, 0x29, 0xa3, 0x4c, 0x4a,
0x4b, 0x26, 0x99, 0xf9, 0xe5, 0x14, 0xf1, 0x61, 0x35, 0x15, 0x95, 0x63, 0x5d, 0xc4, 0xe1, 0xcf,
0x45, 0xf0, 0x66, 0x4f, 0x46, 0x41, 0x3c, 0x58, 0xe1, 0x52, 0x16, 0x94, 0x97, 0xe8, 0x34, 0x54,
0x7c, 0xb9, 0x94, 0x5d, 0x8c, 0xa6, 0x7c, 0x4d, 0x44, 0xfa, 0xb0, 0x89, 0xf9, 0x70, 0xc8, 0x11,
0xad, 0x1b, 0xae, 0x76, 0xe3, 0x8d, 0x75, 0x63, 0xde, 0xa4, 0x46, 0xbf, 0xbc, 0x89, 0x56, 0x7b,
0x90, 0x53, 0xd8, 0xb8, 0x60, 0x71, 0xc2, 0x47, 0xb6, 0xe7, 0xa2, 0xee, 0xf9, 0xfa, 0xa9, 0x9e,
0x47, 0x7a, 0x4f, 0x9b, 0x67, 0x2c, 0x4e, 0x68, 0xa5, 0x83, 0x7f, 0x08, 0x9b, 0x76, 0xa2, 0x59,
0x56, 0x12, 0x09, 0xeb, 0xb5, 0x3d, 0xe6, 0x45, 0xac, 0xb8, 0xa2, 0xee, 0x3a, 0xe5, 0x6a, 0x22,
0xff, 0x33, 0x6c, 0x94, 0x47, 0x94, 0xae, 0xad, 0x5b, 0xb9, 0xb6, 0xcf, 0x56, 0xd1, 0xff, 0xe1,
0x14, 0xf8, 0xac, 0x04, 0xf3, 0x9e, 0x84, 0x39, 0xd8, 0x08, 0x83, 0x9d, 0x91, 0x46, 0x35, 0x3d,
0xc1, 0x46, 0x97, 0x67, 0xda, 0x61, 0xb5, 0x9b, 0xd9, 0xaa, 0xf5, 0x6d, 0x61, 0x7a, 0x33, 0xbb,
0x1c, 0x91, 0x45, 0x9c, 0xaa, 0x9e, 0x7d, 0x2e, 0x6f, 0xe2, 0x21, 0x27, 0x07, 0xb0, 0x59, 0x79,
0x2a, 0xc9, 0xae, 0x9d, 0x79, 0xff, 0x41, 0xf7, 0xbd, 0xd9, 0x0b, 0x28, 0xc8, 0x27, 0xd8, 0x99,
0x85, 0x90, 0xd4, 0x1e, 0x85, 0x7f, 0xed, 0xef, 0x3f, 0x41, 0x8f, 0x9c, 0xc1, 0x7f, 0x33, 0xdf,
0x14, 0xb2, 0x5f, 0xc1, 0xf2, 0xf0, 0x45, 0xf4, 0x83, 0xc7, 0x0b, 0x50, 0x1c, 0x6c, 0x9f, 0xfd,
0xdb, 0x30, 0xdf, 0xbb, 0xf7, 0xe2, 0x5c, 0x4b, 0x72, 0xbe, 0xac, 0x3f, 0x67, 0x6f, 0x7f, 0x05,
0x00, 0x00, 0xff, 0xff, 0x30, 0xa9, 0x4c, 0xde, 0x0d, 0x07, 0x00, 0x00,
func init() { proto.RegisterFile("relay/relay.proto", fileDescriptor_relay_335282936f1b89e7) }
var fileDescriptor_relay_335282936f1b89e7 = []byte{
// 725 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0xcb, 0x4e, 0x1b, 0x4b,
0x10, 0xd5, 0x60, 0x9e, 0xc5, 0xbb, 0x2f, 0x5c, 0x86, 0x59, 0x18, 0xdf, 0x59, 0x20, 0xeb, 0x2a,
0xb1, 0x25, 0x27, 0xbb, 0xec, 0xc0, 0x82, 0x58, 0xc1, 0x32, 0x6a, 0x27, 0x4a, 0xc4, 0x22, 0x56,
0x63, 0xb7, 0xcd, 0xc8, 0x63, 0x4f, 0xd3, 0x35, 0x06, 0xf1, 0x05, 0xd9, 0xe5, 0x13, 0xb2, 0xc8,
0x4f, 0xe4, 0x6f, 0xf2, 0x2d, 0x51, 0x3f, 0x3c, 0x99, 0xf1, 0x03, 0xc2, 0x22, 0x1b, 0xcb, 0x55,
0x5d, 0x75, 0xaa, 0xce, 0xa9, 0x9e, 0x6a, 0xd8, 0x95, 0x3c, 0x64, 0x0f, 0x65, 0xfd, 0x5b, 0x12,
0x32, 0x8a, 0x23, 0xb2, 0xa4, 0x0d, 0xef, 0xbf, 0x86, 0xe0, 0xc3, 0x56, 0xad, 0x5e, 0x16, 0xfd,
0x5e, 0x59, 0x9f, 0x94, 0xb1, 0xd3, 0x6f, 0xdd, 0x63, 0xf9, 0x1e, 0x4d, 0xa4, 0xff, 0xd5, 0x81,
0x9d, 0xc6, 0x30, 0x0c, 0x86, 0xfc, 0x72, 0x84, 0x37, 0x75, 0xec, 0x51, 0x7e, 0x4b, 0x0a, 0xb0,
0xde, 0x10, 0x5c, 0xb2, 0x38, 0x88, 0x86, 0xb5, 0xaa, 0xeb, 0x14, 0x9c, 0xe2, 0x1a, 0x4d, 0xbb,
0xc8, 0x6b, 0x58, 0x19, 0x60, 0xaf, 0xca, 0x62, 0xe6, 0x2e, 0x14, 0x9c, 0xe2, 0x7a, 0xc5, 0x2b,
0x21, 0x97, 0x77, 0x5c, 0xb6, 0x98, 0x08, 0x5a, 0x82, 0x49, 0x36, 0xc0, 0x52, 0xdd, 0x44, 0xd0,
0x71, 0x28, 0xf1, 0x61, 0x43, 0x8c, 0xf0, 0xe6, 0x7d, 0xf4, 0x01, 0xb9, 0xac, 0x55, 0xdd, 0x9c,
0x06, 0xce, 0xf8, 0xfc, 0x73, 0xd8, 0x9d, 0xe8, 0x07, 0x05, 0xa9, 0xc0, 0xa2, 0xe4, 0x28, 0x5c,
0xa7, 0x90, 0x2b, 0xae, 0x57, 0xf2, 0x25, 0xc3, 0xb5, 0x19, 0x0c, 0x7b, 0x21, 0xaf, 0x63, 0xcf,
0x24, 0x5f, 0x86, 0x2c, 0xee, 0x46, 0x72, 0x40, 0x75, 0xac, 0xff, 0xc5, 0x81, 0x43, 0x15, 0xc1,
0xc3, 0x24, 0x82, 0x72, 0x1c, 0x85, 0xf1, 0x45, 0x80, 0x31, 0xf9, 0x17, 0x96, 0x47, 0xa6, 0x09,
0xc3, 0xce, 0x5a, 0x49, 0xa5, 0x85, 0x3f, 0xaf, 0x44, 0xf2, 0x00, 0x51, 0xd2, 0xb2, 0x26, 0xb5,
0x4a, 0x53, 0x1e, 0xff, 0x9b, 0x03, 0xae, 0xe1, 0x74, 0xc2, 0xe2, 0xf6, 0x8d, 0xf2, 0x35, 0x86,
0xfc, 0x2f, 0x6b, 0xfd, 0x3f, 0xec, 0xa4, 0x75, 0x55, 0xa4, 0xdd, 0x5c, 0x21, 0x57, 0x5c, 0xa3,
0x53, 0x7e, 0x3f, 0x80, 0xc3, 0x39, 0xfd, 0xa1, 0x20, 0x17, 0xb0, 0x83, 0x9a, 0xbe, 0xf2, 0x1b,
0x05, 0xed, 0x1c, 0x0a, 0x29, 0x75, 0x66, 0xaa, 0x4c, 0xa7, 0x32, 0xfd, 0x07, 0x38, 0x98, 0x23,
0xa6, 0x92, 0xd1, 0x04, 0x9d, 0x46, 0x1d, 0xae, 0x85, 0xc8, 0xd1, 0x94, 0x47, 0x8d, 0x8c, 0xf2,
0xf6, 0x5d, 0xad, 0xaa, 0x65, 0x58, 0xa3, 0xd6, 0x22, 0xc7, 0xb0, 0xa5, 0xfe, 0x29, 0x9c, 0xb3,
0x48, 0x0e, 0xec, 0xbd, 0x5a, 0xa2, 0x13, 0x5e, 0xff, 0x1e, 0x0e, 0xce, 0x79, 0xac, 0x4a, 0xa2,
0x61, 0xdb, 0x8c, 0x59, 0x3c, 0x42, 0x35, 0x84, 0x3c, 0xc0, 0xe8, 0xb7, 0x4c, 0x8e, 0x96, 0x29,
0xe5, 0x51, 0x43, 0x8a, 0x52, 0x43, 0x32, 0xf5, 0xd3, 0x2e, 0xe2, 0xc1, 0x6a, 0x24, 0x32, 0xd7,
0x3a, 0xb1, 0xfd, 0x1f, 0x8b, 0xe0, 0xce, 0xae, 0x8c, 0x82, 0xb8, 0xb0, 0xc2, 0xa5, 0x4c, 0x28,
0x2f, 0xd1, 0xb1, 0xa9, 0xf8, 0x72, 0x29, 0xeb, 0xd8, 0x1b, 0xf3, 0x35, 0x16, 0x69, 0xc2, 0x26,
0x8e, 0xda, 0x6d, 0x8e, 0x68, 0xa7, 0x91, 0xd3, 0xd3, 0x78, 0x69, 0xa7, 0x31, 0xaf, 0x52, 0xa9,
0x99, 0x4e, 0xa2, 0x59, 0x0c, 0x72, 0x09, 0x1b, 0x5d, 0x16, 0x84, 0xbc, 0x63, 0x31, 0x17, 0x35,
0xe6, 0x8b, 0xa7, 0x30, 0xcf, 0x74, 0x4e, 0x95, 0xc7, 0x2c, 0x08, 0x69, 0x06, 0xc1, 0x3b, 0x85,
0x4d, 0x5b, 0xd1, 0x1c, 0x2b, 0x89, 0x84, 0x9d, 0xb5, 0xbd, 0xe6, 0x89, 0xad, 0xb8, 0xa2, 0x46,
0x1d, 0x73, 0x35, 0x96, 0xf7, 0x09, 0x36, 0xd2, 0x25, 0x52, 0x9f, 0x6d, 0x2e, 0xf3, 0xd9, 0x3e,
0x5b, 0x45, 0xef, 0xbb, 0x93, 0xf4, 0x67, 0x25, 0x98, 0xb7, 0x12, 0xe6, 0xf4, 0x46, 0x18, 0xec,
0x75, 0x74, 0x57, 0xe3, 0x1b, 0x6c, 0x74, 0x79, 0xe6, 0x38, 0xac, 0x76, 0x33, 0xa1, 0xfc, 0xcf,
0x40, 0xde, 0x05, 0xed, 0xbe, 0x02, 0x68, 0x74, 0xbb, 0x0a, 0xc0, 0xae, 0x8c, 0x68, 0x7a, 0x65,
0xa4, 0x6f, 0xe3, 0x31, 0x6c, 0xf5, 0x6d, 0x5e, 0xe6, 0xd3, 0x9f, 0xf0, 0xfa, 0xfb, 0xf0, 0xcf,
0x14, 0x3e, 0x8a, 0xca, 0xcf, 0x85, 0xf1, 0x42, 0xa8, 0x73, 0x44, 0xd6, 0xe3, 0x54, 0x51, 0x69,
0x72, 0x79, 0x17, 0xb4, 0x39, 0x39, 0x81, 0xcd, 0xcc, 0x86, 0x26, 0x07, 0x96, 0xea, 0xe4, 0x3b,
0xe2, 0xb9, 0xb3, 0x0f, 0x50, 0x90, 0x8f, 0xb0, 0x37, 0x4b, 0x18, 0x92, 0x7f, 0x54, 0xb5, 0x5b,
0xef, 0xe8, 0x09, 0x55, 0xc9, 0x15, 0xec, 0xcf, 0x5c, 0x65, 0xe4, 0x28, 0xd3, 0xcb, 0xf4, 0x22,
0xf6, 0x0a, 0x8f, 0x07, 0xa0, 0x20, 0x6f, 0x61, 0x7b, 0x42, 0x2d, 0x72, 0x68, 0x93, 0xa6, 0xa7,
0xe4, 0x79, 0xf3, 0x8e, 0x50, 0x9c, 0xec, 0x5e, 0x6d, 0x97, 0xcc, 0x83, 0xfd, 0x46, 0x5c, 0x6b,
0x71, 0xaf, 0x97, 0xf5, 0x7b, 0xfc, 0xea, 0x57, 0x00, 0x00, 0x00, 0xff, 0xff, 0x91, 0x04, 0x58,
0xb0, 0xce, 0x07, 0x00, 0x00,
}

8
pkg/proto/relay/relay.proto
Unescape View File

@ -67,11 +67,19 @@ message GetUsersOnlineStatusResp{
repeated SuccessDetail detailPlatformStatus = 3;
}
}
message KickUserOfflineReq{
string operationID = 1;
repeated string kickUserIDList = 3;
}
message KickUserOfflineResp{
}
service OnlineMessageRelayService {
rpc OnlinePushMsg(OnlinePushMsgReq) returns(OnlinePushMsgResp);
rpc GetUsersOnlineStatus(GetUsersOnlineStatusReq)returns(GetUsersOnlineStatusResp);
rpc OnlineBatchPushOneMsg(OnlineBatchPushOneMsgReq) returns(OnlineBatchPushOneMsgResp);
rpc KickUserOffline(KickUserOfflineReq) returns(KickUserOfflineResp);
// rpc SendMsgByWS(SendMsgByWSReq) returns(MsgToUserResp);
}

Write Preview
Loading…
Cancel
Save