msggateway

package
v0.0.0-...-0786c3e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_msggateway_msggateway_proto protoreflect.FileDescriptor

Functions

func RegisterMsgGatewayServer

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

Types

type GetUsersOnlineStatusReq

type GetUsersOnlineStatusReq struct {
	UserIDs []string `protobuf:"bytes,1,rep,name=userIDs,proto3" json:"userIDs"`
	// contains filtered or unexported fields
}

func (*GetUsersOnlineStatusReq) Check

func (x *GetUsersOnlineStatusReq) Check() error

func (*GetUsersOnlineStatusReq) Descriptor deprecated

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

Deprecated: Use GetUsersOnlineStatusReq.ProtoReflect.Descriptor instead.

func (*GetUsersOnlineStatusReq) GetUserIDs

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

func (*GetUsersOnlineStatusReq) ProtoMessage

func (*GetUsersOnlineStatusReq) ProtoMessage()

func (*GetUsersOnlineStatusReq) ProtoReflect

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

func (*GetUsersOnlineStatusReq) Reset

func (x *GetUsersOnlineStatusReq) Reset()

func (*GetUsersOnlineStatusReq) String

func (x *GetUsersOnlineStatusReq) String() string

type GetUsersOnlineStatusResp

type GetUsersOnlineStatusResp struct {
	SuccessResult []*GetUsersOnlineStatusResp_SuccessResult `protobuf:"bytes,1,rep,name=successResult,proto3" json:"successResult"`
	FailedResult  []*GetUsersOnlineStatusResp_FailedDetail  `protobuf:"bytes,2,rep,name=failedResult,proto3" json:"failedResult"`
	// contains filtered or unexported fields
}

func (*GetUsersOnlineStatusResp) Descriptor deprecated

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

Deprecated: Use GetUsersOnlineStatusResp.ProtoReflect.Descriptor instead.

func (*GetUsersOnlineStatusResp) GetFailedResult

func (*GetUsersOnlineStatusResp) GetSuccessResult

func (*GetUsersOnlineStatusResp) ProtoMessage

func (*GetUsersOnlineStatusResp) ProtoMessage()

func (*GetUsersOnlineStatusResp) ProtoReflect

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

func (*GetUsersOnlineStatusResp) Reset

func (x *GetUsersOnlineStatusResp) Reset()

func (*GetUsersOnlineStatusResp) String

func (x *GetUsersOnlineStatusResp) String() string

type GetUsersOnlineStatusResp_FailedDetail

type GetUsersOnlineStatusResp_FailedDetail struct {
	UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"`
	// contains filtered or unexported fields
}

func (*GetUsersOnlineStatusResp_FailedDetail) Descriptor deprecated

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

Deprecated: Use GetUsersOnlineStatusResp_FailedDetail.ProtoReflect.Descriptor instead.

func (*GetUsersOnlineStatusResp_FailedDetail) GetUserID

func (*GetUsersOnlineStatusResp_FailedDetail) ProtoMessage

func (*GetUsersOnlineStatusResp_FailedDetail) ProtoMessage()

func (*GetUsersOnlineStatusResp_FailedDetail) ProtoReflect

func (*GetUsersOnlineStatusResp_FailedDetail) Reset

func (*GetUsersOnlineStatusResp_FailedDetail) String

type GetUsersOnlineStatusResp_SuccessDetail

type GetUsersOnlineStatusResp_SuccessDetail struct {
	Platform     string `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform"`
	Status       string `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	ConnID       string `protobuf:"bytes,3,opt,name=connID,proto3" json:"connID"`
	IsBackground bool   `protobuf:"varint,4,opt,name=isBackground,proto3" json:"isBackground"`
	Token        string `protobuf:"bytes,5,opt,name=token,proto3" json:"token"`
	// contains filtered or unexported fields
}

func (*GetUsersOnlineStatusResp_SuccessDetail) Descriptor deprecated

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

Deprecated: Use GetUsersOnlineStatusResp_SuccessDetail.ProtoReflect.Descriptor instead.

func (*GetUsersOnlineStatusResp_SuccessDetail) GetConnID

func (*GetUsersOnlineStatusResp_SuccessDetail) GetIsBackground

func (x *GetUsersOnlineStatusResp_SuccessDetail) GetIsBackground() bool

func (*GetUsersOnlineStatusResp_SuccessDetail) GetPlatform

func (*GetUsersOnlineStatusResp_SuccessDetail) GetStatus

func (*GetUsersOnlineStatusResp_SuccessDetail) GetToken

func (*GetUsersOnlineStatusResp_SuccessDetail) ProtoMessage

func (*GetUsersOnlineStatusResp_SuccessDetail) ProtoReflect

func (*GetUsersOnlineStatusResp_SuccessDetail) Reset

func (*GetUsersOnlineStatusResp_SuccessDetail) String

type GetUsersOnlineStatusResp_SuccessResult

type GetUsersOnlineStatusResp_SuccessResult struct {
	UserID               string                                    `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"`
	Status               string                                    `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	DetailPlatformStatus []*GetUsersOnlineStatusResp_SuccessDetail `protobuf:"bytes,3,rep,name=detailPlatformStatus,proto3" json:"detailPlatformStatus"`
	// contains filtered or unexported fields
}

func (*GetUsersOnlineStatusResp_SuccessResult) Descriptor deprecated

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

Deprecated: Use GetUsersOnlineStatusResp_SuccessResult.ProtoReflect.Descriptor instead.

func (*GetUsersOnlineStatusResp_SuccessResult) GetDetailPlatformStatus

func (*GetUsersOnlineStatusResp_SuccessResult) GetStatus

func (*GetUsersOnlineStatusResp_SuccessResult) GetUserID

func (*GetUsersOnlineStatusResp_SuccessResult) ProtoMessage

func (*GetUsersOnlineStatusResp_SuccessResult) ProtoReflect

func (*GetUsersOnlineStatusResp_SuccessResult) Reset

func (*GetUsersOnlineStatusResp_SuccessResult) String

type KickUserOfflineReq

type KickUserOfflineReq struct {
	PlatformID     int32    `protobuf:"varint,1,opt,name=platformID,proto3" json:"platformID"`
	KickUserIDList []string `protobuf:"bytes,2,rep,name=kickUserIDList,proto3" json:"kickUserIDList"`
	// contains filtered or unexported fields
}

func (*KickUserOfflineReq) Check

func (x *KickUserOfflineReq) Check() error

func (*KickUserOfflineReq) Descriptor deprecated

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

Deprecated: Use KickUserOfflineReq.ProtoReflect.Descriptor instead.

func (*KickUserOfflineReq) GetKickUserIDList

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

func (*KickUserOfflineReq) GetPlatformID

func (x *KickUserOfflineReq) GetPlatformID() int32

func (*KickUserOfflineReq) ProtoMessage

func (*KickUserOfflineReq) ProtoMessage()

func (*KickUserOfflineReq) ProtoReflect

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

func (*KickUserOfflineReq) Reset

func (x *KickUserOfflineReq) Reset()

func (*KickUserOfflineReq) String

func (x *KickUserOfflineReq) String() string

type KickUserOfflineResp

type KickUserOfflineResp struct {
	// contains filtered or unexported fields
}

func (*KickUserOfflineResp) Descriptor deprecated

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

Deprecated: Use KickUserOfflineResp.ProtoReflect.Descriptor instead.

func (*KickUserOfflineResp) ProtoMessage

func (*KickUserOfflineResp) ProtoMessage()

func (*KickUserOfflineResp) ProtoReflect

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

func (*KickUserOfflineResp) Reset

func (x *KickUserOfflineResp) Reset()

func (*KickUserOfflineResp) String

func (x *KickUserOfflineResp) String() string

type MsgGatewayClient

type MsgGatewayClient 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)
	SuperGroupOnlineBatchPushOneMsg(ctx context.Context, in *OnlineBatchPushOneMsgReq, opts ...grpc.CallOption) (*OnlineBatchPushOneMsgResp, error)
	KickUserOffline(ctx context.Context, in *KickUserOfflineReq, opts ...grpc.CallOption) (*KickUserOfflineResp, error)
	MultiTerminalLoginCheck(ctx context.Context, in *MultiTerminalLoginCheckReq, opts ...grpc.CallOption) (*MultiTerminalLoginCheckResp, error)
}

MsgGatewayClient is the client API for MsgGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgGatewayClient

func NewMsgGatewayClient(cc grpc.ClientConnInterface) MsgGatewayClient

type MsgGatewayServer

MsgGatewayServer is the server API for MsgGateway service.

type MultiTerminalLoginCheckReq

type MultiTerminalLoginCheckReq struct {
	UserID     string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"`
	PlatformID int32  `protobuf:"varint,2,opt,name=platformID,proto3" json:"platformID"`
	Token      string `protobuf:"bytes,3,opt,name=token,proto3" json:"token"`
	// contains filtered or unexported fields
}

func (*MultiTerminalLoginCheckReq) Check

func (x *MultiTerminalLoginCheckReq) Check() error

func (*MultiTerminalLoginCheckReq) Descriptor deprecated

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

Deprecated: Use MultiTerminalLoginCheckReq.ProtoReflect.Descriptor instead.

func (*MultiTerminalLoginCheckReq) GetPlatformID

func (x *MultiTerminalLoginCheckReq) GetPlatformID() int32

func (*MultiTerminalLoginCheckReq) GetToken

func (x *MultiTerminalLoginCheckReq) GetToken() string

func (*MultiTerminalLoginCheckReq) GetUserID

func (x *MultiTerminalLoginCheckReq) GetUserID() string

func (*MultiTerminalLoginCheckReq) ProtoMessage

func (*MultiTerminalLoginCheckReq) ProtoMessage()

func (*MultiTerminalLoginCheckReq) ProtoReflect

func (*MultiTerminalLoginCheckReq) Reset

func (x *MultiTerminalLoginCheckReq) Reset()

func (*MultiTerminalLoginCheckReq) String

func (x *MultiTerminalLoginCheckReq) String() string

type MultiTerminalLoginCheckResp

type MultiTerminalLoginCheckResp struct {
	// contains filtered or unexported fields
}

func (*MultiTerminalLoginCheckResp) Descriptor deprecated

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

Deprecated: Use MultiTerminalLoginCheckResp.ProtoReflect.Descriptor instead.

func (*MultiTerminalLoginCheckResp) ProtoMessage

func (*MultiTerminalLoginCheckResp) ProtoMessage()

func (*MultiTerminalLoginCheckResp) ProtoReflect

func (*MultiTerminalLoginCheckResp) Reset

func (x *MultiTerminalLoginCheckResp) Reset()

func (*MultiTerminalLoginCheckResp) String

func (x *MultiTerminalLoginCheckResp) String() string

type OnlineBatchPushOneMsgReq

type OnlineBatchPushOneMsgReq struct {
	MsgData       *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData,proto3" json:"msgData"`
	PushToUserIDs []string       `protobuf:"bytes,2,rep,name=pushToUserIDs,proto3" json:"pushToUserIDs"`
	// contains filtered or unexported fields
}

func (*OnlineBatchPushOneMsgReq) Check

func (x *OnlineBatchPushOneMsgReq) Check() error

func (*OnlineBatchPushOneMsgReq) Descriptor deprecated

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

Deprecated: Use OnlineBatchPushOneMsgReq.ProtoReflect.Descriptor instead.

func (*OnlineBatchPushOneMsgReq) GetMsgData

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

func (*OnlineBatchPushOneMsgReq) GetPushToUserIDs

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

func (*OnlineBatchPushOneMsgReq) ProtoMessage

func (*OnlineBatchPushOneMsgReq) ProtoMessage()

func (*OnlineBatchPushOneMsgReq) ProtoReflect

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

func (*OnlineBatchPushOneMsgReq) Reset

func (x *OnlineBatchPushOneMsgReq) Reset()

func (*OnlineBatchPushOneMsgReq) String

func (x *OnlineBatchPushOneMsgReq) String() string

type OnlineBatchPushOneMsgResp

type OnlineBatchPushOneMsgResp struct {
	SinglePushResult []*SingleMsgToUserResults `protobuf:"bytes,1,rep,name=singlePushResult,proto3" json:"singlePushResult"`
	// contains filtered or unexported fields
}

func (*OnlineBatchPushOneMsgResp) Descriptor deprecated

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

Deprecated: Use OnlineBatchPushOneMsgResp.ProtoReflect.Descriptor instead.

func (*OnlineBatchPushOneMsgResp) GetSinglePushResult

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

func (*OnlineBatchPushOneMsgResp) ProtoMessage

func (*OnlineBatchPushOneMsgResp) ProtoMessage()

func (*OnlineBatchPushOneMsgResp) ProtoReflect

func (*OnlineBatchPushOneMsgResp) Reset

func (x *OnlineBatchPushOneMsgResp) Reset()

func (*OnlineBatchPushOneMsgResp) String

func (x *OnlineBatchPushOneMsgResp) String() string

type OnlinePushMsgReq

type OnlinePushMsgReq struct {
	MsgData      *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData,proto3" json:"msgData"`
	PushToUserID string         `protobuf:"bytes,2,opt,name=pushToUserID,proto3" json:"pushToUserID"`
	// contains filtered or unexported fields
}

func (*OnlinePushMsgReq) Check

func (x *OnlinePushMsgReq) Check() error

func (*OnlinePushMsgReq) Descriptor deprecated

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

Deprecated: Use OnlinePushMsgReq.ProtoReflect.Descriptor instead.

func (*OnlinePushMsgReq) GetMsgData

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

func (*OnlinePushMsgReq) GetPushToUserID

func (x *OnlinePushMsgReq) GetPushToUserID() string

func (*OnlinePushMsgReq) ProtoMessage

func (*OnlinePushMsgReq) ProtoMessage()

func (*OnlinePushMsgReq) ProtoReflect

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

func (*OnlinePushMsgReq) Reset

func (x *OnlinePushMsgReq) Reset()

func (*OnlinePushMsgReq) String

func (x *OnlinePushMsgReq) String() string

type OnlinePushMsgResp

type OnlinePushMsgResp struct {
	Resp []*SingleMsgToUserPlatform `protobuf:"bytes,1,rep,name=resp,proto3" json:"resp"`
	// contains filtered or unexported fields
}

func (*OnlinePushMsgResp) Descriptor deprecated

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

Deprecated: Use OnlinePushMsgResp.ProtoReflect.Descriptor instead.

func (*OnlinePushMsgResp) GetResp

func (*OnlinePushMsgResp) ProtoMessage

func (*OnlinePushMsgResp) ProtoMessage()

func (*OnlinePushMsgResp) ProtoReflect

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

func (*OnlinePushMsgResp) Reset

func (x *OnlinePushMsgResp) Reset()

func (*OnlinePushMsgResp) String

func (x *OnlinePushMsgResp) String() string

type SingleDetail

type SingleDetail struct {
	UserID              string                 `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"`
	Status              string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	SinglePlatformToken []*SinglePlatformToken `protobuf:"bytes,3,rep,name=singlePlatformToken,proto3" json:"singlePlatformToken"`
	// contains filtered or unexported fields
}

func (*SingleDetail) Descriptor deprecated

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

Deprecated: Use SingleDetail.ProtoReflect.Descriptor instead.

func (*SingleDetail) GetSinglePlatformToken

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

func (*SingleDetail) GetStatus

func (x *SingleDetail) GetStatus() string

func (*SingleDetail) GetUserID

func (x *SingleDetail) GetUserID() string

func (*SingleDetail) ProtoMessage

func (*SingleDetail) ProtoMessage()

func (*SingleDetail) ProtoReflect

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

func (*SingleDetail) Reset

func (x *SingleDetail) Reset()

func (*SingleDetail) String

func (x *SingleDetail) String() string

type SingleMsgToUserPlatform

type SingleMsgToUserPlatform struct {
	ResultCode     int64  `protobuf:"varint,1,opt,name=ResultCode,proto3" json:"ResultCode"`
	RecvID         string `protobuf:"bytes,2,opt,name=RecvID,proto3" json:"RecvID"`
	RecvPlatFormID int32  `protobuf:"varint,3,opt,name=RecvPlatFormID,proto3" json:"RecvPlatFormID"`
	// contains filtered or unexported fields
}

func (*SingleMsgToUserPlatform) Descriptor deprecated

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

Deprecated: Use SingleMsgToUserPlatform.ProtoReflect.Descriptor instead.

func (*SingleMsgToUserPlatform) GetRecvID

func (x *SingleMsgToUserPlatform) GetRecvID() string

func (*SingleMsgToUserPlatform) GetRecvPlatFormID

func (x *SingleMsgToUserPlatform) GetRecvPlatFormID() int32

func (*SingleMsgToUserPlatform) GetResultCode

func (x *SingleMsgToUserPlatform) GetResultCode() int64

func (*SingleMsgToUserPlatform) ProtoMessage

func (*SingleMsgToUserPlatform) ProtoMessage()

func (*SingleMsgToUserPlatform) ProtoReflect

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

func (*SingleMsgToUserPlatform) Reset

func (x *SingleMsgToUserPlatform) Reset()

func (*SingleMsgToUserPlatform) String

func (x *SingleMsgToUserPlatform) String() string

type SingleMsgToUserResults

type SingleMsgToUserResults struct {
	UserID     string                     `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"`
	Resp       []*SingleMsgToUserPlatform `protobuf:"bytes,2,rep,name=resp,proto3" json:"resp"`
	OnlinePush bool                       `protobuf:"varint,3,opt,name=onlinePush,proto3" json:"onlinePush"`
	// contains filtered or unexported fields
}

func (*SingleMsgToUserResults) Descriptor deprecated

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

Deprecated: Use SingleMsgToUserResults.ProtoReflect.Descriptor instead.

func (*SingleMsgToUserResults) GetOnlinePush

func (x *SingleMsgToUserResults) GetOnlinePush() bool

func (*SingleMsgToUserResults) GetResp

func (*SingleMsgToUserResults) GetUserID

func (x *SingleMsgToUserResults) GetUserID() string

func (*SingleMsgToUserResults) ProtoMessage

func (*SingleMsgToUserResults) ProtoMessage()

func (*SingleMsgToUserResults) ProtoReflect

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

func (*SingleMsgToUserResults) Reset

func (x *SingleMsgToUserResults) Reset()

func (*SingleMsgToUserResults) String

func (x *SingleMsgToUserResults) String() string

type SinglePlatformToken

type SinglePlatformToken struct {
	Platform string   `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform"`
	Total    int32    `protobuf:"varint,2,opt,name=total,proto3" json:"total"`
	Token    []string `protobuf:"bytes,3,rep,name=token,proto3" json:"token"`
	// contains filtered or unexported fields
}

func (*SinglePlatformToken) Descriptor deprecated

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

Deprecated: Use SinglePlatformToken.ProtoReflect.Descriptor instead.

func (*SinglePlatformToken) GetPlatform

func (x *SinglePlatformToken) GetPlatform() string

func (*SinglePlatformToken) GetToken

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

func (*SinglePlatformToken) GetTotal

func (x *SinglePlatformToken) GetTotal() int32

func (*SinglePlatformToken) ProtoMessage

func (*SinglePlatformToken) ProtoMessage()

func (*SinglePlatformToken) ProtoReflect

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

func (*SinglePlatformToken) Reset

func (x *SinglePlatformToken) Reset()

func (*SinglePlatformToken) String

func (x *SinglePlatformToken) String() string

type UnimplementedMsgGatewayServer

type UnimplementedMsgGatewayServer struct {
}

UnimplementedMsgGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgGatewayServer) GetUsersOnlineStatus

func (*UnimplementedMsgGatewayServer) KickUserOffline

func (*UnimplementedMsgGatewayServer) MultiTerminalLoginCheck

func (*UnimplementedMsgGatewayServer) OnlineBatchPushOneMsg

func (*UnimplementedMsgGatewayServer) OnlinePushMsg

func (*UnimplementedMsgGatewayServer) SuperGroupOnlineBatchPushOneMsg

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL