Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

msggateway

package

Go to main page

Versions in this module

v0

v0.3.70

Sep 9, 2024

v0.3.69

Aug 19, 2024

v0.2.69

Aug 16, 2024

v0.1.63

Aug 16, 2024

v0.0.80

Aug 16, 2024

Changes in this version

+ var File_msggateway_msggateway_proto protoreflect.FileDescriptor

+ func RegisterMsgGatewayServer(s *grpc.Server, srv MsgGatewayServer)

+ type GetUsersOnlineStatusReq struct

+ UserIDs []string

+ func (*GetUsersOnlineStatusReq) Descriptor() ([]byte, []int)

+ func (*GetUsersOnlineStatusReq) ProtoMessage()

+ func (x *GetUsersOnlineStatusReq) Check() error

+ func (x *GetUsersOnlineStatusReq) GetUserIDs() []string

+ func (x *GetUsersOnlineStatusReq) ProtoReflect() protoreflect.Message

+ func (x *GetUsersOnlineStatusReq) Reset()

+ func (x *GetUsersOnlineStatusReq) String() string

+ type GetUsersOnlineStatusResp struct

+ FailedResult []*GetUsersOnlineStatusResp_FailedDetail

+ SuccessResult []*GetUsersOnlineStatusResp_SuccessResult

+ func (*GetUsersOnlineStatusResp) Descriptor() ([]byte, []int)

+ func (*GetUsersOnlineStatusResp) ProtoMessage()

+ func (x *GetUsersOnlineStatusResp) GetFailedResult() []*GetUsersOnlineStatusResp_FailedDetail

+ func (x *GetUsersOnlineStatusResp) GetSuccessResult() []*GetUsersOnlineStatusResp_SuccessResult

+ func (x *GetUsersOnlineStatusResp) ProtoReflect() protoreflect.Message

+ func (x *GetUsersOnlineStatusResp) Reset()

+ func (x *GetUsersOnlineStatusResp) String() string

+ type GetUsersOnlineStatusResp_FailedDetail struct

+ UserID string

+ func (*GetUsersOnlineStatusResp_FailedDetail) Descriptor() ([]byte, []int)

+ func (*GetUsersOnlineStatusResp_FailedDetail) ProtoMessage()

+ func (x *GetUsersOnlineStatusResp_FailedDetail) GetUserID() string

+ func (x *GetUsersOnlineStatusResp_FailedDetail) ProtoReflect() protoreflect.Message

+ func (x *GetUsersOnlineStatusResp_FailedDetail) Reset()

+ func (x *GetUsersOnlineStatusResp_FailedDetail) String() string

+ type GetUsersOnlineStatusResp_SuccessDetail struct

+ ConnID string

+ IsBackground bool

+ Platform string

+ Status string

+ Token string

+ func (*GetUsersOnlineStatusResp_SuccessDetail) Descriptor() ([]byte, []int)

+ func (*GetUsersOnlineStatusResp_SuccessDetail) ProtoMessage()

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) GetConnID() string

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) GetIsBackground() bool

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) GetPlatform() string

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) GetStatus() string

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) GetToken() string

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) ProtoReflect() protoreflect.Message

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) Reset()

+ func (x *GetUsersOnlineStatusResp_SuccessDetail) String() string

+ type GetUsersOnlineStatusResp_SuccessResult struct

+ DetailPlatformStatus []*GetUsersOnlineStatusResp_SuccessDetail

+ Status string

+ UserID string

+ func (*GetUsersOnlineStatusResp_SuccessResult) Descriptor() ([]byte, []int)

+ func (*GetUsersOnlineStatusResp_SuccessResult) ProtoMessage()

+ func (x *GetUsersOnlineStatusResp_SuccessResult) GetDetailPlatformStatus() []*GetUsersOnlineStatusResp_SuccessDetail

+ func (x *GetUsersOnlineStatusResp_SuccessResult) GetStatus() string

+ func (x *GetUsersOnlineStatusResp_SuccessResult) GetUserID() string

+ func (x *GetUsersOnlineStatusResp_SuccessResult) ProtoReflect() protoreflect.Message

+ func (x *GetUsersOnlineStatusResp_SuccessResult) Reset()

+ func (x *GetUsersOnlineStatusResp_SuccessResult) String() string

+ type KickUserOfflineReq struct

+ KickUserIDList []string

+ PlatformID int32

+ func (*KickUserOfflineReq) Descriptor() ([]byte, []int)

+ func (*KickUserOfflineReq) ProtoMessage()

+ func (x *KickUserOfflineReq) Check() error

+ func (x *KickUserOfflineReq) GetKickUserIDList() []string

+ func (x *KickUserOfflineReq) GetPlatformID() int32

+ func (x *KickUserOfflineReq) ProtoReflect() protoreflect.Message

+ func (x *KickUserOfflineReq) Reset()

+ func (x *KickUserOfflineReq) String() string

+ type KickUserOfflineResp struct

+ func (*KickUserOfflineResp) Descriptor() ([]byte, []int)

+ func (*KickUserOfflineResp) ProtoMessage()

+ func (x *KickUserOfflineResp) ProtoReflect() protoreflect.Message

+ func (x *KickUserOfflineResp) Reset()

+ func (x *KickUserOfflineResp) String() string

+ type MsgGatewayClient interface

+ GetUsersOnlineStatus func(ctx context.Context, in *GetUsersOnlineStatusReq, opts ...grpc.CallOption) (*GetUsersOnlineStatusResp, error)

+ KickUserOffline func(ctx context.Context, in *KickUserOfflineReq, opts ...grpc.CallOption) (*KickUserOfflineResp, error)

+ MultiTerminalLoginCheck func(ctx context.Context, in *MultiTerminalLoginCheckReq, opts ...grpc.CallOption) (*MultiTerminalLoginCheckResp, error)

+ OnlineBatchPushOneMsg func(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error)

+ OnlinePushMsg func(ctx context.Context, in *OnlinePushMsgReq, opts ...grpc.CallOption) (*OnlinePushMsgResp, error)

+ SuperGroupOnlineBatchPushOneMsg func(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error)

+ func NewMsgGatewayClient(cc grpc.ClientConnInterface) MsgGatewayClient

+ type MsgGatewayServer interface

+ GetUsersOnlineStatus func(context.Context, *GetUsersOnlineStatusReq) (*GetUsersOnlineStatusResp, error)

+ KickUserOffline func(context.Context, *KickUserOfflineReq) (*KickUserOfflineResp, error)

+ MultiTerminalLoginCheck func(context.Context, *MultiTerminalLoginCheckReq) (*MultiTerminalLoginCheckResp, error)

+ OnlineBatchPushOneMsg func(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)

+ OnlinePushMsg func(context.Context, *OnlinePushMsgReq) (*OnlinePushMsgResp, error)

+ SuperGroupOnlineBatchPushOneMsg func(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)

+ type MultiTerminalLoginCheckReq struct

+ PlatformID int32

+ Token string

+ UserID string

+ func (*MultiTerminalLoginCheckReq) Descriptor() ([]byte, []int)

+ func (*MultiTerminalLoginCheckReq) ProtoMessage()

+ func (x *MultiTerminalLoginCheckReq) Check() error

+ func (x *MultiTerminalLoginCheckReq) GetPlatformID() int32

+ func (x *MultiTerminalLoginCheckReq) GetToken() string

+ func (x *MultiTerminalLoginCheckReq) GetUserID() string

+ func (x *MultiTerminalLoginCheckReq) ProtoReflect() protoreflect.Message

+ func (x *MultiTerminalLoginCheckReq) Reset()

+ func (x *MultiTerminalLoginCheckReq) String() string

+ type MultiTerminalLoginCheckResp struct

+ func (*MultiTerminalLoginCheckResp) Descriptor() ([]byte, []int)

+ func (*MultiTerminalLoginCheckResp) ProtoMessage()

+ func (x *MultiTerminalLoginCheckResp) ProtoReflect() protoreflect.Message

+ func (x *MultiTerminalLoginCheckResp) Reset()

+ func (x *MultiTerminalLoginCheckResp) String() string

+ type OnlineBatchPushOneMsgReq struct

+ MsgData *sdkws.MsgData

+ PushToUserIDs []string

+ func (*OnlineBatchPushOneMsgReq) Descriptor() ([]byte, []int)

+ func (*OnlineBatchPushOneMsgReq) ProtoMessage()

+ func (x *OnlineBatchPushOneMsgReq) Check() error

+ func (x *OnlineBatchPushOneMsgReq) GetMsgData() *sdkws.MsgData

+ func (x *OnlineBatchPushOneMsgReq) GetPushToUserIDs() []string

+ func (x *OnlineBatchPushOneMsgReq) ProtoReflect() protoreflect.Message

+ func (x *OnlineBatchPushOneMsgReq) Reset()

+ func (x *OnlineBatchPushOneMsgReq) String() string

+ type OnlineBatchPushOneMsgResp struct

+ SinglePushResult []*SingleMsgToUserResults

+ func (*OnlineBatchPushOneMsgResp) Descriptor() ([]byte, []int)

+ func (*OnlineBatchPushOneMsgResp) ProtoMessage()

+ func (x *OnlineBatchPushOneMsgResp) GetSinglePushResult() []*SingleMsgToUserResults

+ func (x *OnlineBatchPushOneMsgResp) ProtoReflect() protoreflect.Message

+ func (x *OnlineBatchPushOneMsgResp) Reset()

+ func (x *OnlineBatchPushOneMsgResp) String() string

+ type OnlinePushMsgReq struct

+ MsgData *sdkws.MsgData

+ PushToUserID string

+ func (*OnlinePushMsgReq) Descriptor() ([]byte, []int)

+ func (*OnlinePushMsgReq) ProtoMessage()

+ func (x *OnlinePushMsgReq) Check() error

+ func (x *OnlinePushMsgReq) GetMsgData() *sdkws.MsgData

+ func (x *OnlinePushMsgReq) GetPushToUserID() string

+ func (x *OnlinePushMsgReq) ProtoReflect() protoreflect.Message

+ func (x *OnlinePushMsgReq) Reset()

+ func (x *OnlinePushMsgReq) String() string

+ type OnlinePushMsgResp struct

+ Resp []*SingleMsgToUserPlatform

+ func (*OnlinePushMsgResp) Descriptor() ([]byte, []int)

+ func (*OnlinePushMsgResp) ProtoMessage()

+ func (x *OnlinePushMsgResp) GetResp() []*SingleMsgToUserPlatform

+ func (x *OnlinePushMsgResp) ProtoReflect() protoreflect.Message

+ func (x *OnlinePushMsgResp) Reset()

+ func (x *OnlinePushMsgResp) String() string

+ type SingleDetail struct

+ SinglePlatformToken []*SinglePlatformToken

+ Status string

+ UserID string

+ func (*SingleDetail) Descriptor() ([]byte, []int)

+ func (*SingleDetail) ProtoMessage()

+ func (x *SingleDetail) GetSinglePlatformToken() []*SinglePlatformToken

+ func (x *SingleDetail) GetStatus() string

+ func (x *SingleDetail) GetUserID() string

+ func (x *SingleDetail) ProtoReflect() protoreflect.Message

+ func (x *SingleDetail) Reset()

+ func (x *SingleDetail) String() string

+ type SingleMsgToUserPlatform struct

+ RecvID string

+ RecvPlatFormID int32

+ ResultCode int64

+ func (*SingleMsgToUserPlatform) Descriptor() ([]byte, []int)

+ func (*SingleMsgToUserPlatform) ProtoMessage()

+ func (x *SingleMsgToUserPlatform) GetRecvID() string

+ func (x *SingleMsgToUserPlatform) GetRecvPlatFormID() int32

+ func (x *SingleMsgToUserPlatform) GetResultCode() int64

+ func (x *SingleMsgToUserPlatform) ProtoReflect() protoreflect.Message

+ func (x *SingleMsgToUserPlatform) Reset()

+ func (x *SingleMsgToUserPlatform) String() string

+ type SingleMsgToUserResults struct

+ OnlinePush bool

+ Resp []*SingleMsgToUserPlatform

+ UserID string

+ func (*SingleMsgToUserResults) Descriptor() ([]byte, []int)

+ func (*SingleMsgToUserResults) ProtoMessage()

+ func (x *SingleMsgToUserResults) GetOnlinePush() bool

+ func (x *SingleMsgToUserResults) GetResp() []*SingleMsgToUserPlatform

+ func (x *SingleMsgToUserResults) GetUserID() string

+ func (x *SingleMsgToUserResults) ProtoReflect() protoreflect.Message

+ func (x *SingleMsgToUserResults) Reset()

+ func (x *SingleMsgToUserResults) String() string

+ type SinglePlatformToken struct

+ Platform string

+ Token []string

+ Total int32

+ func (*SinglePlatformToken) Descriptor() ([]byte, []int)

+ func (*SinglePlatformToken) ProtoMessage()

+ func (x *SinglePlatformToken) GetPlatform() string

+ func (x *SinglePlatformToken) GetToken() []string

+ func (x *SinglePlatformToken) GetTotal() int32

+ func (x *SinglePlatformToken) ProtoReflect() protoreflect.Message

+ func (x *SinglePlatformToken) Reset()

+ func (x *SinglePlatformToken) String() string

+ type UnimplementedMsgGatewayServer struct

+ func (*UnimplementedMsgGatewayServer) GetUsersOnlineStatus(context.Context, *GetUsersOnlineStatusReq) (*GetUsersOnlineStatusResp, error)

+ func (*UnimplementedMsgGatewayServer) KickUserOffline(context.Context, *KickUserOfflineReq) (*KickUserOfflineResp, error)

+ func (*UnimplementedMsgGatewayServer) MultiTerminalLoginCheck(context.Context, *MultiTerminalLoginCheckReq) (*MultiTerminalLoginCheckResp, error)

+ func (*UnimplementedMsgGatewayServer) OnlineBatchPushOneMsg(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)

+ func (*UnimplementedMsgGatewayServer) OnlinePushMsg(context.Context, *OnlinePushMsgReq) (*OnlinePushMsgResp, error)

+ func (*UnimplementedMsgGatewayServer) SuperGroupOnlineBatchPushOneMsg(context.Context, *OnlineBatchPushOneMsgReq) (*OnlineBatchPushOneMsgResp, error)