services

Documentation

Index

• func BuildCommentReplyMessagePbWithMessageModel(rMessage *messageModels.Message) *messagePb.CommentReplyMessage
• func BuildCommentReplyMessagePbWithMessagePb(rMessage *messagePb.Message) *messagePb.CommentReplyMessage
• func BuildFollowMessagePbWithMessageModel(rMessage *messageModels.Message) *messagePb.FollowMessage
• func BuildFollowMessagePbWithMessagePb(rMessage *messagePb.Message) *messagePb.FollowMessage
• func BuildMessagePbModel(pMessage *messageModels.Message) *messagePb.Message
• func BuildVoteMessagePbWithMessageModel(rMessage *messageModels.Message) *messagePb.VoteMessage
• func BuildVoteMessagePbWithMessagePb(rMessage *messagePb.Message) *messagePb.VoteMessage
• func CloseMQConn()
• type MessageServiceImpl
  • func (m MessageServiceImpl) GetUserMessage(ctx context.Context, request *messagePb.GetUserMessageRequest) (response *messagePb.GetUserMessageResponse, err error)
  • func (m MessageServiceImpl) MarkMessageStatus(ctx context.Context, request *messagePb.MarkMessageStatusRequest) (response *messagePb.MarkMessageStatusResponse, err error)
  • func (m MessageServiceImpl) MessageAction(ctx context.Context, request *messagePb.MessageActionRequest) (response *messagePb.MessageActionResponse, err error)
  • func (m MessageServiceImpl) MessageChat(ctx context.Context, request *messagePb.MessageChatRequest) (response *messagePb.MessageChatResponse, err error)
  • func (m MessageServiceImpl) New()

Functions

func BuildCommentReplyMessagePbWithMessageModel

func BuildCommentReplyMessagePbWithMessageModel(rMessage *messageModels.Message) *messagePb.CommentReplyMessage

func BuildCommentReplyMessagePbWithMessagePb

func BuildCommentReplyMessagePbWithMessagePb(rMessage *messagePb.Message) *messagePb.CommentReplyMessage

func BuildFollowMessagePbWithMessageModel

func BuildFollowMessagePbWithMessageModel(rMessage *messageModels.Message) *messagePb.FollowMessage

func BuildFollowMessagePbWithMessagePb

func BuildFollowMessagePbWithMessagePb(rMessage *messagePb.Message) *messagePb.FollowMessage

func BuildMessagePbModel

func BuildMessagePbModel(pMessage *messageModels.Message) *messagePb.Message

func BuildVoteMessagePbWithMessageModel

func BuildVoteMessagePbWithMessageModel(rMessage *messageModels.Message) *messagePb.VoteMessage

func BuildVoteMessagePbWithMessagePb

func BuildVoteMessagePbWithMessagePb(rMessage *messagePb.Message) *messagePb.VoteMessage

func CloseMQConn

func CloseMQConn()

Types

type MessageServiceImpl

type MessageServiceImpl struct {
	messagePb.MessageServiceServer
}

func (MessageServiceImpl) GetUserMessage

func (m MessageServiceImpl) GetUserMessage(ctx context.Context, request *messagePb.GetUserMessageRequest) (response *messagePb.GetUserMessageResponse, err error)

func (MessageServiceImpl) MarkMessageStatus

func (m MessageServiceImpl) MarkMessageStatus(ctx context.Context, request *messagePb.MarkMessageStatusRequest) (response *messagePb.MarkMessageStatusResponse, err error)

func (MessageServiceImpl) MessageAction

func (m MessageServiceImpl) MessageAction(ctx context.Context, request *messagePb.MessageActionRequest) (response *messagePb.MessageActionResponse, err error)

func (MessageServiceImpl) MessageChat

func (m MessageServiceImpl) MessageChat(ctx context.Context, request *messagePb.MessageChatRequest) (response *messagePb.MessageChatResponse, err error)

func (MessageServiceImpl) New

func (m MessageServiceImpl) New()