You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Open-IM-Server/pkg/proto/msggateway/msg_gateway.pb.go

1024 lines
42 KiB

4 years ago
// Code generated by protoc-gen-go. DO NOT EDIT.
2 years ago
// source: msggateway/msg_gateway.proto
4 years ago
2 years ago
package msggateway // import "OpenIM/pkg/proto/msggateway"
2 years ago
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
2 years ago
import sdkws "OpenIM/pkg/proto/sdkws"
4 years ago
import (
2 years ago
context "golang.org/x/net/context"
4 years ago
grpc "google.golang.org/grpc"
)
2 years ago
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
4 years ago
2 years ago
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
4 years ago
2 years ago
type OnlinePushMsgReq struct {
2 years ago
MsgData *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData" json:"msgData,omitempty"`
PushToUserID string `protobuf:"bytes,2,opt,name=pushToUserID" json:"pushToUserID,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
4 years ago
}
2 years ago
2 years ago
func (m *OnlinePushMsgReq) Reset() { *m = OnlinePushMsgReq{} }
func (m *OnlinePushMsgReq) String() string { return proto.CompactTextString(m) }
func (*OnlinePushMsgReq) ProtoMessage() {}
func (*OnlinePushMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{0}
4 years ago
}
2 years ago
func (m *OnlinePushMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlinePushMsgReq.Unmarshal(m, b)
4 years ago
}
2 years ago
func (m *OnlinePushMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_OnlinePushMsgReq.Marshal(b, m, deterministic)
4 years ago
}
2 years ago
func (dst *OnlinePushMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_OnlinePushMsgReq.Merge(dst, src)
}
func (m *OnlinePushMsgReq) XXX_Size() int {
return xxx_messageInfo_OnlinePushMsgReq.Size(m)
2 years ago
}
2 years ago
func (m *OnlinePushMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_OnlinePushMsgReq.DiscardUnknown(m)
}
var xxx_messageInfo_OnlinePushMsgReq proto.InternalMessageInfo
4 years ago
2 years ago
func (m *OnlinePushMsgReq) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
4 years ago
}
3 years ago
return nil
4 years ago
}
2 years ago
func (m *OnlinePushMsgReq) GetPushToUserID() string {
if m != nil {
return m.PushToUserID
}
return ""
}
3 years ago
type OnlinePushMsgResp struct {
2 years ago
Resp []*SingleMsgToUserPlatform `protobuf:"bytes,1,rep,name=resp" json:"resp,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
4 years ago
}
2 years ago
2 years ago
func (m *OnlinePushMsgResp) Reset() { *m = OnlinePushMsgResp{} }
func (m *OnlinePushMsgResp) String() string { return proto.CompactTextString(m) }
func (*OnlinePushMsgResp) ProtoMessage() {}
func (*OnlinePushMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{1}
4 years ago
}
2 years ago
func (m *OnlinePushMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlinePushMsgResp.Unmarshal(m, b)
4 years ago
}
2 years ago
func (m *OnlinePushMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_OnlinePushMsgResp.Marshal(b, m, deterministic)
4 years ago
}
2 years ago
func (dst *OnlinePushMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_OnlinePushMsgResp.Merge(dst, src)
}
func (m *OnlinePushMsgResp) XXX_Size() int {
return xxx_messageInfo_OnlinePushMsgResp.Size(m)
2 years ago
}
2 years ago
func (m *OnlinePushMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_OnlinePushMsgResp.DiscardUnknown(m)
}
var xxx_messageInfo_OnlinePushMsgResp proto.InternalMessageInfo
4 years ago
2 years ago
func (m *OnlinePushMsgResp) GetResp() []*SingleMsgToUserPlatform {
if m != nil {
return m.Resp
4 years ago
}
return nil
}
2 years ago
type SingleMsgToUserResults struct {
2 years ago
UserID string `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
Resp []*SingleMsgToUserPlatform `protobuf:"bytes,2,rep,name=resp" json:"resp,omitempty"`
OnlinePush bool `protobuf:"varint,3,opt,name=onlinePush" json:"onlinePush,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
2 years ago
2 years ago
func (m *SingleMsgToUserResults) Reset() { *m = SingleMsgToUserResults{} }
func (m *SingleMsgToUserResults) String() string { return proto.CompactTextString(m) }
func (*SingleMsgToUserResults) ProtoMessage() {}
func (*SingleMsgToUserResults) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{2}
}
2 years ago
func (m *SingleMsgToUserResults) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SingleMsgToUserResults.Unmarshal(m, b)
}
2 years ago
func (m *SingleMsgToUserResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SingleMsgToUserResults.Marshal(b, m, deterministic)
}
2 years ago
func (dst *SingleMsgToUserResults) XXX_Merge(src proto.Message) {
xxx_messageInfo_SingleMsgToUserResults.Merge(dst, src)
2 years ago
}
2 years ago
func (m *SingleMsgToUserResults) XXX_Size() int {
return xxx_messageInfo_SingleMsgToUserResults.Size(m)
2 years ago
}
2 years ago
func (m *SingleMsgToUserResults) XXX_DiscardUnknown() {
xxx_messageInfo_SingleMsgToUserResults.DiscardUnknown(m)
2 years ago
}
2 years ago
var xxx_messageInfo_SingleMsgToUserResults proto.InternalMessageInfo
2 years ago
2 years ago
func (m *SingleMsgToUserResults) GetUserID() string {
2 years ago
if m != nil {
return m.UserID
}
return ""
}
2 years ago
func (m *SingleMsgToUserResults) GetResp() []*SingleMsgToUserPlatform {
2 years ago
if m != nil {
return m.Resp
}
return nil
}
2 years ago
func (m *SingleMsgToUserResults) GetOnlinePush() bool {
2 years ago
if m != nil {
return m.OnlinePush
}
return false
}
type OnlineBatchPushOneMsgReq struct {
2 years ago
MsgData *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData" json:"msgData,omitempty"`
PushToUserIDs []string `protobuf:"bytes,2,rep,name=pushToUserIDs" json:"pushToUserIDs,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
2 years ago
2 years ago
func (m *OnlineBatchPushOneMsgReq) Reset() { *m = OnlineBatchPushOneMsgReq{} }
func (m *OnlineBatchPushOneMsgReq) String() string { return proto.CompactTextString(m) }
func (*OnlineBatchPushOneMsgReq) ProtoMessage() {}
func (*OnlineBatchPushOneMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{3}
}
2 years ago
func (m *OnlineBatchPushOneMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlineBatchPushOneMsgReq.Unmarshal(m, b)
}
2 years ago
func (m *OnlineBatchPushOneMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_OnlineBatchPushOneMsgReq.Marshal(b, m, deterministic)
}
2 years ago
func (dst *OnlineBatchPushOneMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_OnlineBatchPushOneMsgReq.Merge(dst, src)
}
func (m *OnlineBatchPushOneMsgReq) XXX_Size() int {
return xxx_messageInfo_OnlineBatchPushOneMsgReq.Size(m)
2 years ago
}
2 years ago
func (m *OnlineBatchPushOneMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_OnlineBatchPushOneMsgReq.DiscardUnknown(m)
}
var xxx_messageInfo_OnlineBatchPushOneMsgReq proto.InternalMessageInfo
2 years ago
func (m *OnlineBatchPushOneMsgReq) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
}
return nil
}
2 years ago
func (m *OnlineBatchPushOneMsgReq) GetPushToUserIDs() []string {
2 years ago
if m != nil {
2 years ago
return m.PushToUserIDs
}
return nil
}
type OnlineBatchPushOneMsgResp struct {
2 years ago
SinglePushResult []*SingleMsgToUserResults `protobuf:"bytes,1,rep,name=singlePushResult" json:"singlePushResult,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
2 years ago
2 years ago
func (m *OnlineBatchPushOneMsgResp) Reset() { *m = OnlineBatchPushOneMsgResp{} }
func (m *OnlineBatchPushOneMsgResp) String() string { return proto.CompactTextString(m) }
func (*OnlineBatchPushOneMsgResp) ProtoMessage() {}
func (*OnlineBatchPushOneMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{4}
}
2 years ago
func (m *OnlineBatchPushOneMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OnlineBatchPushOneMsgResp.Unmarshal(m, b)
}
2 years ago
func (m *OnlineBatchPushOneMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_OnlineBatchPushOneMsgResp.Marshal(b, m, deterministic)
}
2 years ago
func (dst *OnlineBatchPushOneMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_OnlineBatchPushOneMsgResp.Merge(dst, src)
}
func (m *OnlineBatchPushOneMsgResp) XXX_Size() int {
return xxx_messageInfo_OnlineBatchPushOneMsgResp.Size(m)
}
func (m *OnlineBatchPushOneMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_OnlineBatchPushOneMsgResp.DiscardUnknown(m)
2 years ago
}
2 years ago
var xxx_messageInfo_OnlineBatchPushOneMsgResp proto.InternalMessageInfo
2 years ago
func (m *OnlineBatchPushOneMsgResp) GetSinglePushResult() []*SingleMsgToUserResults {
2 years ago
if m != nil {
return m.SinglePushResult
}
return nil
}
type SingleMsgToUserPlatform struct {
2 years ago
ResultCode int64 `protobuf:"varint,1,opt,name=ResultCode" json:"ResultCode,omitempty"`
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"`
RecvPlatFormID int32 `protobuf:"varint,3,opt,name=RecvPlatFormID" json:"RecvPlatFormID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
4 years ago
}
2 years ago
2 years ago
func (m *SingleMsgToUserPlatform) Reset() { *m = SingleMsgToUserPlatform{} }
func (m *SingleMsgToUserPlatform) String() string { return proto.CompactTextString(m) }
func (*SingleMsgToUserPlatform) ProtoMessage() {}
func (*SingleMsgToUserPlatform) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{5}
4 years ago
}
2 years ago
func (m *SingleMsgToUserPlatform) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SingleMsgToUserPlatform.Unmarshal(m, b)
4 years ago
}
2 years ago
func (m *SingleMsgToUserPlatform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SingleMsgToUserPlatform.Marshal(b, m, deterministic)
4 years ago
}
2 years ago
func (dst *SingleMsgToUserPlatform) XXX_Merge(src proto.Message) {
xxx_messageInfo_SingleMsgToUserPlatform.Merge(dst, src)
}
func (m *SingleMsgToUserPlatform) XXX_Size() int {
return xxx_messageInfo_SingleMsgToUserPlatform.Size(m)
2 years ago
}
2 years ago
func (m *SingleMsgToUserPlatform) XXX_DiscardUnknown() {
xxx_messageInfo_SingleMsgToUserPlatform.DiscardUnknown(m)
}
var xxx_messageInfo_SingleMsgToUserPlatform proto.InternalMessageInfo
4 years ago
2 years ago
func (m *SingleMsgToUserPlatform) GetResultCode() int64 {
if m != nil {
return m.ResultCode
4 years ago
}
return 0
}
2 years ago
func (m *SingleMsgToUserPlatform) GetRecvID() string {
if m != nil {
return m.RecvID
4 years ago
}
return ""
}
2 years ago
func (m *SingleMsgToUserPlatform) GetRecvPlatFormID() int32 {
if m != nil {
return m.RecvPlatFormID
4 years ago
}
return 0
}
3 years ago
type GetUsersOnlineStatusReq struct {
2 years ago
UserIDs []string `protobuf:"bytes,1,rep,name=userIDs" json:"userIDs,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
3 years ago
}
2 years ago
2 years ago
func (m *GetUsersOnlineStatusReq) Reset() { *m = GetUsersOnlineStatusReq{} }
func (m *GetUsersOnlineStatusReq) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusReq) ProtoMessage() {}
func (*GetUsersOnlineStatusReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{6}
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusReq.Unmarshal(m, b)
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetUsersOnlineStatusReq.Marshal(b, m, deterministic)
3 years ago
}
2 years ago
func (dst *GetUsersOnlineStatusReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetUsersOnlineStatusReq.Merge(dst, src)
}
func (m *GetUsersOnlineStatusReq) XXX_Size() int {
return xxx_messageInfo_GetUsersOnlineStatusReq.Size(m)
2 years ago
}
2 years ago
func (m *GetUsersOnlineStatusReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetUsersOnlineStatusReq.DiscardUnknown(m)
}
var xxx_messageInfo_GetUsersOnlineStatusReq proto.InternalMessageInfo
3 years ago
2 years ago
func (m *GetUsersOnlineStatusReq) GetUserIDs() []string {
2 years ago
if m != nil {
2 years ago
return m.UserIDs
3 years ago
}
return nil
}
type GetUsersOnlineStatusResp struct {
2 years ago
SuccessResult []*GetUsersOnlineStatusResp_SuccessResult `protobuf:"bytes,1,rep,name=successResult" json:"successResult,omitempty"`
FailedResult []*GetUsersOnlineStatusResp_FailedDetail `protobuf:"bytes,2,rep,name=failedResult" json:"failedResult,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetUsersOnlineStatusResp) Reset() { *m = GetUsersOnlineStatusResp{} }
func (m *GetUsersOnlineStatusResp) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp) ProtoMessage() {}
func (*GetUsersOnlineStatusResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{7}
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp.Unmarshal(m, b)
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetUsersOnlineStatusResp.Marshal(b, m, deterministic)
3 years ago
}
2 years ago
func (dst *GetUsersOnlineStatusResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetUsersOnlineStatusResp.Merge(dst, src)
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp) XXX_Size() int {
return xxx_messageInfo_GetUsersOnlineStatusResp.Size(m)
}
func (m *GetUsersOnlineStatusResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetUsersOnlineStatusResp.DiscardUnknown(m)
2 years ago
}
3 years ago
2 years ago
var xxx_messageInfo_GetUsersOnlineStatusResp proto.InternalMessageInfo
func (m *GetUsersOnlineStatusResp) GetSuccessResult() []*GetUsersOnlineStatusResp_SuccessResult {
if m != nil {
return m.SuccessResult
3 years ago
}
return nil
}
2 years ago
func (m *GetUsersOnlineStatusResp) GetFailedResult() []*GetUsersOnlineStatusResp_FailedDetail {
if m != nil {
return m.FailedResult
3 years ago
}
return nil
}
2 years ago
type GetUsersOnlineStatusResp_SuccessDetail struct {
Platform string `protobuf:"bytes,1,opt,name=platform" json:"platform,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
2 years ago
ConnID string `protobuf:"bytes,3,opt,name=connID" json:"connID,omitempty"`
IsBackground bool `protobuf:"varint,4,opt,name=isBackground" json:"isBackground,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
3 years ago
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessDetail) Reset() {
*m = GetUsersOnlineStatusResp_SuccessDetail{}
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessDetail) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp_SuccessDetail) ProtoMessage() {}
func (*GetUsersOnlineStatusResp_SuccessDetail) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{7, 0}
2 years ago
}
func (m *GetUsersOnlineStatusResp_SuccessDetail) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail.Unmarshal(m, b)
}
func (m *GetUsersOnlineStatusResp_SuccessDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail.Marshal(b, m, deterministic)
}
func (dst *GetUsersOnlineStatusResp_SuccessDetail) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail.Merge(dst, src)
}
func (m *GetUsersOnlineStatusResp_SuccessDetail) XXX_Size() int {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail.Size(m)
}
func (m *GetUsersOnlineStatusResp_SuccessDetail) XXX_DiscardUnknown() {
xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail.DiscardUnknown(m)
}
var xxx_messageInfo_GetUsersOnlineStatusResp_SuccessDetail proto.InternalMessageInfo
3 years ago
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessDetail) GetPlatform() string {
if m != nil {
return m.Platform
3 years ago
}
2 years ago
return ""
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessDetail) GetStatus() string {
if m != nil {
return m.Status
}
return ""
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessDetail) GetConnID() string {
if m != nil {
return m.ConnID
}
return ""
}
func (m *GetUsersOnlineStatusResp_SuccessDetail) GetIsBackground() bool {
if m != nil {
return m.IsBackground
}
return false
}
2 years ago
type GetUsersOnlineStatusResp_FailedDetail struct {
2 years ago
UserID string `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_FailedDetail) Reset() { *m = GetUsersOnlineStatusResp_FailedDetail{} }
func (m *GetUsersOnlineStatusResp_FailedDetail) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp_FailedDetail) ProtoMessage() {}
func (*GetUsersOnlineStatusResp_FailedDetail) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{7, 1}
2 years ago
}
func (m *GetUsersOnlineStatusResp_FailedDetail) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail.Unmarshal(m, b)
}
func (m *GetUsersOnlineStatusResp_FailedDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail.Marshal(b, m, deterministic)
}
func (dst *GetUsersOnlineStatusResp_FailedDetail) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail.Merge(dst, src)
}
func (m *GetUsersOnlineStatusResp_FailedDetail) XXX_Size() int {
return xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail.Size(m)
}
func (m *GetUsersOnlineStatusResp_FailedDetail) XXX_DiscardUnknown() {
xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail.DiscardUnknown(m)
2 years ago
}
3 years ago
2 years ago
var xxx_messageInfo_GetUsersOnlineStatusResp_FailedDetail proto.InternalMessageInfo
func (m *GetUsersOnlineStatusResp_FailedDetail) GetUserID() string {
if m != nil {
return m.UserID
3 years ago
}
return ""
}
2 years ago
type GetUsersOnlineStatusResp_SuccessResult struct {
UserID string `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
DetailPlatformStatus []*GetUsersOnlineStatusResp_SuccessDetail `protobuf:"bytes,3,rep,name=detailPlatformStatus" json:"detailPlatformStatus,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) Reset() {
*m = GetUsersOnlineStatusResp_SuccessResult{}
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) String() string { return proto.CompactTextString(m) }
func (*GetUsersOnlineStatusResp_SuccessResult) ProtoMessage() {}
func (*GetUsersOnlineStatusResp_SuccessResult) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{7, 2}
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult.Unmarshal(m, b)
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult.Marshal(b, m, deterministic)
3 years ago
}
2 years ago
func (dst *GetUsersOnlineStatusResp_SuccessResult) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult.Merge(dst, src)
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) XXX_Size() int {
return xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult.Size(m)
3 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) XXX_DiscardUnknown() {
xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult.DiscardUnknown(m)
3 years ago
}
2 years ago
var xxx_messageInfo_GetUsersOnlineStatusResp_SuccessResult proto.InternalMessageInfo
3 years ago
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) GetUserID() string {
if m != nil {
return m.UserID
3 years ago
}
2 years ago
return ""
2 years ago
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) GetStatus() string {
if m != nil {
return m.Status
3 years ago
}
return ""
}
2 years ago
func (m *GetUsersOnlineStatusResp_SuccessResult) GetDetailPlatformStatus() []*GetUsersOnlineStatusResp_SuccessDetail {
if m != nil {
return m.DetailPlatformStatus
3 years ago
}
2 years ago
return nil
3 years ago
}
2 years ago
type KickUserOfflineReq struct {
2 years ago
PlatformID int32 `protobuf:"varint,1,opt,name=platformID" json:"platformID,omitempty"`
KickUserIDList []string `protobuf:"bytes,2,rep,name=kickUserIDList" json:"kickUserIDList,omitempty"`
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
func (m *KickUserOfflineReq) Reset() { *m = KickUserOfflineReq{} }
func (m *KickUserOfflineReq) String() string { return proto.CompactTextString(m) }
func (*KickUserOfflineReq) ProtoMessage() {}
func (*KickUserOfflineReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{8}
2 years ago
}
2 years ago
func (m *KickUserOfflineReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KickUserOfflineReq.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *KickUserOfflineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KickUserOfflineReq.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
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)
2 years ago
}
2 years ago
var xxx_messageInfo_KickUserOfflineReq proto.InternalMessageInfo
2 years ago
2 years ago
func (m *KickUserOfflineReq) GetPlatformID() int32 {
if m != nil {
return m.PlatformID
2 years ago
}
return 0
}
2 years ago
func (m *KickUserOfflineReq) GetKickUserIDList() []string {
if m != nil {
return m.KickUserIDList
2 years ago
}
2 years ago
return nil
2 years ago
}
2 years ago
type KickUserOfflineResp struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
func (m *KickUserOfflineResp) Reset() { *m = KickUserOfflineResp{} }
func (m *KickUserOfflineResp) String() string { return proto.CompactTextString(m) }
func (*KickUserOfflineResp) ProtoMessage() {}
func (*KickUserOfflineResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{9}
2 years ago
}
2 years ago
func (m *KickUserOfflineResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KickUserOfflineResp.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *KickUserOfflineResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KickUserOfflineResp.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *KickUserOfflineResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_KickUserOfflineResp.Merge(dst, src)
2 years ago
}
2 years ago
func (m *KickUserOfflineResp) XXX_Size() int {
return xxx_messageInfo_KickUserOfflineResp.Size(m)
2 years ago
}
2 years ago
func (m *KickUserOfflineResp) XXX_DiscardUnknown() {
xxx_messageInfo_KickUserOfflineResp.DiscardUnknown(m)
2 years ago
}
2 years ago
var xxx_messageInfo_KickUserOfflineResp proto.InternalMessageInfo
2 years ago
2 years ago
type MultiTerminalLoginCheckReq struct {
UserID string `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
PlatformID int32 `protobuf:"varint,2,opt,name=platformID" json:"platformID,omitempty"`
Token string `protobuf:"bytes,3,opt,name=token" json:"token,omitempty"`
OperationID string `protobuf:"bytes,4,opt,name=operationID" json:"operationID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MultiTerminalLoginCheckReq) Reset() { *m = MultiTerminalLoginCheckReq{} }
func (m *MultiTerminalLoginCheckReq) String() string { return proto.CompactTextString(m) }
func (*MultiTerminalLoginCheckReq) ProtoMessage() {}
func (*MultiTerminalLoginCheckReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{10}
}
2 years ago
func (m *MultiTerminalLoginCheckReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MultiTerminalLoginCheckReq.Unmarshal(m, b)
}
2 years ago
func (m *MultiTerminalLoginCheckReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MultiTerminalLoginCheckReq.Marshal(b, m, deterministic)
}
2 years ago
func (dst *MultiTerminalLoginCheckReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_MultiTerminalLoginCheckReq.Merge(dst, src)
}
2 years ago
func (m *MultiTerminalLoginCheckReq) XXX_Size() int {
return xxx_messageInfo_MultiTerminalLoginCheckReq.Size(m)
2 years ago
}
2 years ago
func (m *MultiTerminalLoginCheckReq) XXX_DiscardUnknown() {
xxx_messageInfo_MultiTerminalLoginCheckReq.DiscardUnknown(m)
}
var xxx_messageInfo_MultiTerminalLoginCheckReq proto.InternalMessageInfo
2 years ago
func (m *MultiTerminalLoginCheckReq) GetUserID() string {
if m != nil {
return m.UserID
}
return ""
}
2 years ago
func (m *MultiTerminalLoginCheckReq) GetPlatformID() int32 {
if m != nil {
return m.PlatformID
}
return 0
}
2 years ago
func (m *MultiTerminalLoginCheckReq) GetToken() string {
if m != nil {
return m.Token
}
return ""
}
2 years ago
func (m *MultiTerminalLoginCheckReq) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
2 years ago
return ""
}
2 years ago
2 years ago
type MultiTerminalLoginCheckResp struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
2 years ago
2 years ago
func (m *MultiTerminalLoginCheckResp) Reset() { *m = MultiTerminalLoginCheckResp{} }
func (m *MultiTerminalLoginCheckResp) String() string { return proto.CompactTextString(m) }
func (*MultiTerminalLoginCheckResp) ProtoMessage() {}
func (*MultiTerminalLoginCheckResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_gateway_608f885807bb70a0, []int{11}
}
2 years ago
func (m *MultiTerminalLoginCheckResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MultiTerminalLoginCheckResp.Unmarshal(m, b)
}
func (m *MultiTerminalLoginCheckResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MultiTerminalLoginCheckResp.Marshal(b, m, deterministic)
}
func (dst *MultiTerminalLoginCheckResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_MultiTerminalLoginCheckResp.Merge(dst, src)
}
func (m *MultiTerminalLoginCheckResp) XXX_Size() int {
return xxx_messageInfo_MultiTerminalLoginCheckResp.Size(m)
}
func (m *MultiTerminalLoginCheckResp) XXX_DiscardUnknown() {
xxx_messageInfo_MultiTerminalLoginCheckResp.DiscardUnknown(m)
2 years ago
}
2 years ago
var xxx_messageInfo_MultiTerminalLoginCheckResp proto.InternalMessageInfo
func init() {
2 years ago
proto.RegisterType((*OnlinePushMsgReq)(nil), "msggateway.OnlinePushMsgReq")
proto.RegisterType((*OnlinePushMsgResp)(nil), "msggateway.OnlinePushMsgResp")
2 years ago
proto.RegisterType((*SingleMsgToUserResults)(nil), "msggateway.SingleMsgToUserResults")
2 years ago
proto.RegisterType((*OnlineBatchPushOneMsgReq)(nil), "msggateway.OnlineBatchPushOneMsgReq")
proto.RegisterType((*OnlineBatchPushOneMsgResp)(nil), "msggateway.OnlineBatchPushOneMsgResp")
proto.RegisterType((*SingleMsgToUserPlatform)(nil), "msggateway.SingleMsgToUserPlatform")
proto.RegisterType((*GetUsersOnlineStatusReq)(nil), "msggateway.GetUsersOnlineStatusReq")
proto.RegisterType((*GetUsersOnlineStatusResp)(nil), "msggateway.GetUsersOnlineStatusResp")
proto.RegisterType((*GetUsersOnlineStatusResp_SuccessDetail)(nil), "msggateway.GetUsersOnlineStatusResp.SuccessDetail")
proto.RegisterType((*GetUsersOnlineStatusResp_FailedDetail)(nil), "msggateway.GetUsersOnlineStatusResp.FailedDetail")
proto.RegisterType((*GetUsersOnlineStatusResp_SuccessResult)(nil), "msggateway.GetUsersOnlineStatusResp.SuccessResult")
proto.RegisterType((*KickUserOfflineReq)(nil), "msggateway.KickUserOfflineReq")
proto.RegisterType((*KickUserOfflineResp)(nil), "msggateway.KickUserOfflineResp")
proto.RegisterType((*MultiTerminalLoginCheckReq)(nil), "msggateway.MultiTerminalLoginCheckReq")
proto.RegisterType((*MultiTerminalLoginCheckResp)(nil), "msggateway.MultiTerminalLoginCheckResp")
4 years ago
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
2 years ago
var _ grpc.ClientConn
4 years ago
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
2 years ago
const _ = grpc.SupportPackageIsVersion4
2 years ago
// Client API for MsgGateway service
4 years ago
2 years ago
type MsgGatewayClient interface {
3 years ago
OnlinePushMsg(ctx context.Context, in *OnlinePushMsgReq, opts ...grpc.CallOption) (*OnlinePushMsgResp, error)
3 years ago
GetUsersOnlineStatus(ctx context.Context, in *GetUsersOnlineStatusReq, opts ...grpc.CallOption) (*GetUsersOnlineStatusResp, error)
OnlineBatchPushOneMsg(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error)
2 years ago
SuperGroupOnlineBatchPushOneMsg(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error)
2 years ago
KickUserOffline(ctx context.Context, in *KickUserOfflineReq, opts ...grpc.CallOption) (*KickUserOfflineResp, error)
MultiTerminalLoginCheck(ctx context.Context, in *MultiTerminalLoginCheckReq, opts ...grpc.CallOption) (*MultiTerminalLoginCheckResp, error)
4 years ago
}
2 years ago
type msgGatewayClient struct {
2 years ago
cc *grpc.ClientConn
4 years ago
}
2 years ago
func NewMsgGatewayClient(cc *grpc.ClientConn) MsgGatewayClient {
return &msgGatewayClient{cc}
4 years ago
}
2 years ago
func (c *msgGatewayClient) OnlinePushMsg(ctx context.Context, in *OnlinePushMsgReq, opts ...grpc.CallOption) (*OnlinePushMsgResp, error) {
3 years ago
out := new(OnlinePushMsgResp)
2 years ago
err := grpc.Invoke(ctx, "/msggateway.msgGateway/OnlinePushMsg", in, out, c.cc, opts...)
4 years ago
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgGatewayClient) GetUsersOnlineStatus(ctx context.Context, in *GetUsersOnlineStatusReq, opts ...grpc.CallOption) (*GetUsersOnlineStatusResp, error) {
3 years ago
out := new(GetUsersOnlineStatusResp)
2 years ago
err := grpc.Invoke(ctx, "/msggateway.msgGateway/GetUsersOnlineStatus", in, out, c.cc, opts...)
3 years ago
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgGatewayClient) OnlineBatchPushOneMsg(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error) {
out := new(OnlineBatchPushOneMsgResp)
2 years ago
err := grpc.Invoke(ctx, "/msggateway.msgGateway/OnlineBatchPushOneMsg", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgGatewayClient) SuperGroupOnlineBatchPushOneMsg(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error) {
2 years ago
out := new(OnlineBatchPushOneMsgResp)
2 years ago
err := grpc.Invoke(ctx, "/msggateway.msgGateway/SuperGroupOnlineBatchPushOneMsg", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgGatewayClient) KickUserOffline(ctx context.Context, in *KickUserOfflineReq, opts ...grpc.CallOption) (*KickUserOfflineResp, error) {
2 years ago
out := new(KickUserOfflineResp)
2 years ago
err := grpc.Invoke(ctx, "/msggateway.msgGateway/KickUserOffline", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgGatewayClient) MultiTerminalLoginCheck(ctx context.Context, in *MultiTerminalLoginCheckReq, opts ...grpc.CallOption) (*MultiTerminalLoginCheckResp, error) {
out := new(MultiTerminalLoginCheckResp)
2 years ago
err := grpc.Invoke(ctx, "/msggateway.msgGateway/MultiTerminalLoginCheck", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
// Server API for MsgGateway service
2 years ago
2 years ago
type MsgGatewayServer interface {
3 years ago
OnlinePushMsg(context.Context, *OnlinePushMsgReq) (*OnlinePushMsgResp, error)
3 years ago
GetUsersOnlineStatus(context.Context, *GetUsersOnlineStatusReq) (*GetUsersOnlineStatusResp, error)
OnlineBatchPushOneMsg(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)
2 years ago
SuperGroupOnlineBatchPushOneMsg(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)
2 years ago
KickUserOffline(context.Context, *KickUserOfflineReq) (*KickUserOfflineResp, error)
MultiTerminalLoginCheck(context.Context, *MultiTerminalLoginCheckReq) (*MultiTerminalLoginCheckResp, error)
4 years ago
}
2 years ago
func RegisterMsgGatewayServer(s *grpc.Server, srv MsgGatewayServer) {
s.RegisterService(&_MsgGateway_serviceDesc, srv)
4 years ago
}
2 years ago
func _MsgGateway_OnlinePushMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3 years ago
in := new(OnlinePushMsgReq)
4 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgGatewayServer).OnlinePushMsg(ctx, in)
4 years ago
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msggateway.msgGateway/OnlinePushMsg",
4 years ago
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgGatewayServer).OnlinePushMsg(ctx, req.(*OnlinePushMsgReq))
4 years ago
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _MsgGateway_GetUsersOnlineStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3 years ago
in := new(GetUsersOnlineStatusReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgGatewayServer).GetUsersOnlineStatus(ctx, in)
3 years ago
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msggateway.msgGateway/GetUsersOnlineStatus",
3 years ago
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgGatewayServer).GetUsersOnlineStatus(ctx, req.(*GetUsersOnlineStatusReq))
3 years ago
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _MsgGateway_OnlineBatchPushOneMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(OnlineBatchPushOneMsgReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgGatewayServer).OnlineBatchPushOneMsg(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msggateway.msgGateway/OnlineBatchPushOneMsg",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgGatewayServer).OnlineBatchPushOneMsg(ctx, req.(*OnlineBatchPushOneMsgReq))
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _MsgGateway_SuperGroupOnlineBatchPushOneMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2 years ago
in := new(OnlineBatchPushOneMsgReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgGatewayServer).SuperGroupOnlineBatchPushOneMsg(ctx, in)
2 years ago
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msggateway.msgGateway/SuperGroupOnlineBatchPushOneMsg",
2 years ago
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgGatewayServer).SuperGroupOnlineBatchPushOneMsg(ctx, req.(*OnlineBatchPushOneMsgReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _MsgGateway_KickUserOffline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2 years ago
in := new(KickUserOfflineReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgGatewayServer).KickUserOffline(ctx, in)
2 years ago
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msggateway.msgGateway/KickUserOffline",
2 years ago
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgGatewayServer).KickUserOffline(ctx, req.(*KickUserOfflineReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _MsgGateway_MultiTerminalLoginCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(MultiTerminalLoginCheckReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgGatewayServer).MultiTerminalLoginCheck(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msggateway.msgGateway/MultiTerminalLoginCheck",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgGatewayServer).MultiTerminalLoginCheck(ctx, req.(*MultiTerminalLoginCheckReq))
}
return interceptor(ctx, in, info, handler)
}
2 years ago
var _MsgGateway_serviceDesc = grpc.ServiceDesc{
ServiceName: "msggateway.msgGateway",
HandlerType: (*MsgGatewayServer)(nil),
4 years ago
Methods: []grpc.MethodDesc{
{
3 years ago
MethodName: "OnlinePushMsg",
2 years ago
Handler: _MsgGateway_OnlinePushMsg_Handler,
4 years ago
},
3 years ago
{
MethodName: "GetUsersOnlineStatus",
2 years ago
Handler: _MsgGateway_GetUsersOnlineStatus_Handler,
3 years ago
},
{
MethodName: "OnlineBatchPushOneMsg",
2 years ago
Handler: _MsgGateway_OnlineBatchPushOneMsg_Handler,
},
2 years ago
{
MethodName: "SuperGroupOnlineBatchPushOneMsg",
2 years ago
Handler: _MsgGateway_SuperGroupOnlineBatchPushOneMsg_Handler,
2 years ago
},
2 years ago
{
MethodName: "KickUserOffline",
2 years ago
Handler: _MsgGateway_KickUserOffline_Handler,
2 years ago
},
{
MethodName: "MultiTerminalLoginCheck",
2 years ago
Handler: _MsgGateway_MultiTerminalLoginCheck_Handler,
},
4 years ago
},
Streams: []grpc.StreamDesc{},
2 years ago
Metadata: "msggateway/msg_gateway.proto",
}
func init() {
2 years ago
proto.RegisterFile("msggateway/msg_gateway.proto", fileDescriptor_msg_gateway_608f885807bb70a0)
}
var fileDescriptor_msg_gateway_608f885807bb70a0 = []byte{
// 782 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x56, 0x4d, 0x4f, 0xf3, 0x46,
0x10, 0x96, 0x49, 0xf8, 0x1a, 0x08, 0xa5, 0x5b, 0x3e, 0x5c, 0x97, 0x8f, 0xc8, 0xd0, 0x90, 0x0b,
0x89, 0x1a, 0x0e, 0x3d, 0xf4, 0x06, 0x11, 0x28, 0x6a, 0xd2, 0xa0, 0x0d, 0x48, 0x55, 0x55, 0xa9,
0x75, 0x9d, 0x8d, 0x63, 0xec, 0xd8, 0x8b, 0xc7, 0x06, 0x71, 0xea, 0xb9, 0x52, 0x7f, 0x43, 0xaf,
0xfd, 0x41, 0xfd, 0x43, 0xd5, 0xda, 0x9b, 0xc4, 0x4e, 0x62, 0xde, 0x70, 0x79, 0x6f, 0x3b, 0xcf,
0xec, 0xcc, 0x3c, 0xfb, 0xcc, 0xec, 0xda, 0x70, 0x34, 0x42, 0xcb, 0x32, 0x42, 0xf6, 0x6a, 0xbc,
0xd5, 0x47, 0x68, 0xfd, 0x26, 0xd7, 0x35, 0x1e, 0xf8, 0xa1, 0x4f, 0x60, 0xea, 0xd5, 0x2e, 0xba,
0x9c, 0x79, 0x97, 0xad, 0xce, 0x65, 0x8f, 0x05, 0x2f, 0x2c, 0xa8, 0x73, 0xc7, 0xaa, 0xc7, 0xbb,
0xea, 0xd8, 0x77, 0x5e, 0xb1, 0xfe, 0x8a, 0x49, 0x90, 0xfe, 0x3b, 0xec, 0x76, 0x3d, 0xd7, 0xf6,
0xd8, 0x7d, 0x84, 0xc3, 0x0e, 0x5a, 0x94, 0x3d, 0x93, 0x2a, 0xac, 0x8f, 0xd0, 0x6a, 0x1a, 0xa1,
0xa1, 0x2a, 0x65, 0xa5, 0xba, 0xd5, 0xd8, 0xa9, 0xc5, 0x51, 0xb5, 0x4e, 0x82, 0xd2, 0xb1, 0x9b,
0xe8, 0xb0, 0xcd, 0x23, 0x1c, 0x3e, 0xf8, 0x8f, 0xc8, 0x82, 0x56, 0x53, 0x5d, 0x29, 0x2b, 0xd5,
0x4d, 0x9a, 0xc1, 0xf4, 0x36, 0x7c, 0x39, 0x53, 0x01, 0x39, 0xf9, 0x1e, 0x8a, 0x01, 0x43, 0xae,
0x2a, 0xe5, 0x42, 0x75, 0xab, 0x71, 0x56, 0x9b, 0x52, 0xaf, 0xf5, 0x6c, 0xcf, 0x72, 0x59, 0x07,
0xad, 0x24, 0xc3, 0xbd, 0x6b, 0x84, 0x03, 0x3f, 0x18, 0xd1, 0x38, 0x40, 0xff, 0x4b, 0x81, 0x83,
0x99, 0x1d, 0x94, 0x61, 0xe4, 0x86, 0x48, 0x0e, 0x60, 0x2d, 0x4a, 0x68, 0x28, 0x31, 0x0d, 0x69,
0x4d, 0x6a, 0xad, 0x7c, 0xb0, 0x16, 0x39, 0x01, 0xf0, 0x27, 0xcc, 0xd5, 0x42, 0x59, 0xa9, 0x6e,
0xd0, 0x14, 0xa2, 0x3f, 0x81, 0x9a, 0x9c, 0xec, 0xda, 0x08, 0xcd, 0xa1, 0x80, 0xba, 0x1e, 0xfb,
0xb0, 0x86, 0xe7, 0x50, 0x4a, 0xeb, 0x85, 0x31, 0xcf, 0x4d, 0x9a, 0x05, 0x75, 0x07, 0xbe, 0xce,
0xa9, 0x85, 0x9c, 0xfc, 0x04, 0xbb, 0x18, 0x9f, 0x44, 0xe0, 0x89, 0x1c, 0x52, 0x59, 0xfd, 0x9d,
0xd3, 0x4a, 0xdd, 0xe8, 0x5c, 0xac, 0xfe, 0x06, 0x87, 0x39, 0xca, 0x08, 0x4d, 0x92, 0x4d, 0x37,
0x7e, 0x9f, 0xc5, 0x47, 0x2b, 0xd0, 0x14, 0x22, 0x9a, 0x40, 0x99, 0xf9, 0x32, 0x99, 0x05, 0x69,
0x91, 0x0a, 0xec, 0x88, 0x95, 0xc8, 0x73, 0xeb, 0x07, 0xa3, 0x56, 0x33, 0xd6, 0x73, 0x95, 0xce,
0xa0, 0xfa, 0x15, 0x1c, 0xde, 0xb1, 0x50, 0x94, 0xc4, 0xe4, 0xbc, 0xbd, 0xd0, 0x08, 0x23, 0x14,
0x92, 0xaa, 0xb0, 0x1e, 0x49, 0x89, 0x94, 0x58, 0xa2, 0xb1, 0xa9, 0xff, 0x53, 0x04, 0x75, 0x71,
0x14, 0x72, 0xf2, 0x33, 0x94, 0x30, 0x32, 0x4d, 0x86, 0x98, 0x51, 0xa6, 0x91, 0x56, 0x26, 0x2f,
0xb8, 0xd6, 0x4b, 0x47, 0xd2, 0x6c, 0x22, 0xf2, 0x08, 0xdb, 0x03, 0xc3, 0x76, 0x59, 0x5f, 0x26,
0x4e, 0x06, 0xec, 0xbb, 0xa5, 0x12, 0xdf, 0xc6, 0x81, 0x4d, 0x16, 0x1a, 0xb6, 0x4b, 0x33, 0x69,
0xb4, 0x3f, 0xa1, 0x24, 0xcb, 0x26, 0x6e, 0xa2, 0xc1, 0x06, 0x97, 0xfa, 0xcb, 0xd1, 0x9e, 0xd8,
0x42, 0x6f, 0x8c, 0xb3, 0x8e, 0xf5, 0x4e, 0x2c, 0x81, 0x9b, 0xbe, 0xe7, 0x49, 0x9d, 0x37, 0xa9,
0xb4, 0xc4, 0x8d, 0xb5, 0xf1, 0xda, 0x30, 0x1d, 0x2b, 0xf0, 0x23, 0xaf, 0xaf, 0x16, 0xe3, 0xa9,
0xce, 0x60, 0x5a, 0x05, 0xb6, 0xd3, 0xf4, 0xf2, 0x2e, 0x96, 0xf6, 0xaf, 0x32, 0x61, 0x2a, 0x15,
0xc9, 0xbb, 0x82, 0x79, 0x2c, 0x07, 0xb0, 0xd7, 0x8f, 0x6b, 0x8c, 0xe7, 0x2b, 0x51, 0x48, 0x2d,
0x7c, 0xbc, 0x45, 0x52, 0xca, 0x85, 0xf9, 0xf4, 0x5f, 0x81, 0xfc, 0x68, 0x9b, 0x8e, 0x48, 0xd0,
0x1d, 0x0c, 0x44, 0x02, 0x31, 0x50, 0x27, 0x00, 0x63, 0x1d, 0x25, 0xe3, 0x55, 0x9a, 0x42, 0xc4,
0xcc, 0x3a, 0x32, 0xaa, 0xd5, 0x6c, 0xdb, 0x18, 0xca, 0xab, 0x39, 0x83, 0xea, 0xfb, 0xf0, 0xd5,
0x5c, 0x76, 0xe4, 0xfa, 0xdf, 0x0a, 0x68, 0x9d, 0xc8, 0x0d, 0xed, 0x07, 0x16, 0x8c, 0x6c, 0xcf,
0x70, 0xdb, 0xbe, 0x65, 0x7b, 0x37, 0x43, 0x66, 0x3a, 0xa2, 0x7a, 0x9e, 0x56, 0x59, 0x56, 0x2b,
0x73, 0xac, 0xf6, 0x60, 0x35, 0xf4, 0x1d, 0xe6, 0xc9, 0xc6, 0x26, 0x06, 0x29, 0xc3, 0x96, 0xcf,
0x59, 0x60, 0x84, 0xb6, 0x2f, 0x9a, 0x5e, 0x8c, 0x7d, 0x69, 0x48, 0x3f, 0x86, 0x6f, 0x72, 0xd9,
0x20, 0x6f, 0xfc, 0x57, 0x04, 0xf1, 0x01, 0xb9, 0x4b, 0xe4, 0x26, 0x6d, 0x28, 0x65, 0x5e, 0x6d,
0x72, 0x94, 0x6e, 0xc6, 0xec, 0x27, 0x43, 0x3b, 0x7e, 0xc7, 0x8b, 0x9c, 0x18, 0xb0, 0xb7, 0xa8,
0x7f, 0xe4, 0xec, 0xd3, 0x1d, 0x7e, 0xd6, 0xce, 0x97, 0x19, 0x03, 0xd2, 0x87, 0xfd, 0x85, 0x0f,
0x24, 0x39, 0x9f, 0xa7, 0x36, 0xff, 0x5e, 0x6b, 0xdf, 0x2e, 0xb1, 0x0b, 0x39, 0xf1, 0xe0, 0xb4,
0x17, 0x71, 0x16, 0xdc, 0x05, 0x7e, 0xc4, 0x3f, 0x43, 0x3d, 0x0a, 0x5f, 0xcc, 0x8c, 0x16, 0x39,
0x49, 0x47, 0xce, 0x4f, 0xb5, 0x76, 0xfa, 0xae, 0x1f, 0x39, 0x79, 0x82, 0xc3, 0x9c, 0x41, 0x20,
0x95, 0x74, 0x6c, 0xfe, 0xec, 0x6a, 0x17, 0x4b, 0xed, 0x43, 0x7e, 0x5d, 0xfd, 0xa5, 0x22, 0xfe,
0x44, 0x5a, 0x9d, 0xd4, 0x1f, 0xc8, 0x34, 0xf4, 0x87, 0xe9, 0xf2, 0x8f, 0xb5, 0xd8, 0x79, 0xf5,
0x7f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x23, 0x19, 0x93, 0xb2, 0xe4, 0x08, 0x00, 0x00,
2 years ago
}