Documentation ¶
Index ¶
- Variables
- func GetMongoDateClient() mongoPb.MongoBindServiceClient
- func GetMySQLDateClient() mysqlPb.MySQLBindServiceClient
- func StartMongoDataRPCServer()
- func StartMySQLDataRPCServer()
- type MongoData
- func (obj *MongoData) GetAllGroupChatHistory(ctx context.Context, param *mongoPb.Id) (*mongoPb.GroupChatHistory, error)
- func (obj *MongoData) GetAllSubscriptionHistory(ctx context.Context, param *mongoPb.Id) (*mongoPb.SubscriptionHistory, error)
- func (obj *MongoData) GetAllUserChatHistory(ctx context.Context, param *mongoPb.JoinId) (*mongoPb.UserChatHistory, error)
- func (obj *MongoData) GetDelayMessage(ctx context.Context, param *mongoPb.Id) (*mongoPb.DelayMessage, error)
- func (obj *MongoData) GetGroupChatHistoryByDate(ctx context.Context, param *mongoPb.IdAndDate) (*mongoPb.GroupChatHistory, error)
- func (obj *MongoData) GetGroupChatHistoryByDateRange(ctx context.Context, param *mongoPb.IdAndDateRange) (*mongoPb.GroupChatHistory, error)
- func (obj *MongoData) GetGroupChatUsers(ctx context.Context, param *mongoPb.Id) (*mongoPb.GroupChatUsers, error)
- func (obj *MongoData) GetSubscriptionHistoryByDate(ctx context.Context, param *mongoPb.IdAndDate) (*mongoPb.SubscriptionHistory, error)
- func (obj *MongoData) GetSubscriptionHistoryByDateRange(ctx context.Context, param *mongoPb.IdAndDateRange) (*mongoPb.SubscriptionHistory, error)
- func (obj *MongoData) GetSubscriptionUsers(ctx context.Context, param *mongoPb.Id) (*mongoPb.SubscriptionUsers, error)
- func (obj *MongoData) GetUserChatHistoryByDate(ctx context.Context, param *mongoPb.JoinIdAndDate) (*mongoPb.UserChatHistory, error)
- func (obj *MongoData) GetUserChatHistoryByDateRange(ctx context.Context, param *mongoPb.JoinIdAndDateRange) (*mongoPb.UserChatHistory, error)
- func (obj *MongoData) GetUserFriendsAndBlacklist(ctx context.Context, param *mongoPb.Id) (*mongoPb.UserFriendsAndBlacklist, error)
- func (obj *MongoData) GetUserGroupChats(ctx context.Context, param *mongoPb.Id) (*mongoPb.UserGroupChats, error)
- func (obj *MongoData) GetUserSubscriptions(ctx context.Context, param *mongoPb.Id) (*mongoPb.UserSubscriptions, error)
- func (obj *MongoData) PutGroupChatUsersAdd(ctx context.Context, param *mongoPb.XAndManagerAndUserId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutGroupChatUsersDel(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutMoveFriendIntoBlacklistPlus(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutMoveFriendOutFromBlacklistPlus(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutSaveDelayMessage(ctx context.Context, param *mongoPb.IdAndMessage) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutSaveGroupChatHistory(ctx context.Context, param *mongoPb.IdAndMessage) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutSaveSubscriptionHistory(ctx context.Context, param *mongoPb.IdAndMessage) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutSaveUserChatHistory(ctx context.Context, param *mongoPb.JoinIdAndMessage) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutSubscriptionUsersAdd(ctx context.Context, param *mongoPb.XAndManagerAndUserId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutSubscriptionUsersDel(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserBlacklistAdd(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserBlacklistDel(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserFollowSubscriptionPlus(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserFriendsAdd(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserFriendsDel(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserGroupChatsAdd(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserGroupChatsDel(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserJoinGroupChatPlus(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserQuitGroupChatPlus(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserSubscriptionsAdd(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserSubscriptionsDel(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- func (obj *MongoData) PutUserUnFollowSubscriptionPlus(ctx context.Context, param *mongoPb.DoubleId) (*mongoPb.EmptyResult, error)
- type MySQLData
- func (obj *MySQLData) DeleteOneFriendshipReal(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) DeleteOneGroupChatReal(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.Id, error)
- func (obj *MySQLData) DeleteOneSubscriptionReal(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.Id, error)
- func (obj *MySQLData) DeleteOneUserGroupChatReal(ctx context.Context, param *mysqlPb.UserAndGroupId) (*mysqlPb.UserAndGroupId, error)
- func (obj *MySQLData) DeleteOneUserReal(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.Id, error)
- func (obj *MySQLData) DeleteOneUserSubscriptionReal(ctx context.Context, param *mysqlPb.UserAndSubsId) (*mysqlPb.UserAndSubsId, error)
- func (obj *MySQLData) GetAllFriendsInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.FriendsInfoListPlus, error)
- func (obj *MySQLData) GetAllFriendshipList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.FriendshipBasicList, error)
- func (obj *MySQLData) GetAllGroupChatList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.GroupChatList, error)
- func (obj *MySQLData) GetAllUserGroupChatList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.UserGroupChatRelateList, error)
- func (obj *MySQLData) GetAllUserList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.UserBasicList, error)
- func (obj *MySQLData) GetBlacklistFriendsIdListByIdPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetBlacklistFriendsInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.FriendsInfoListPlus, error)
- func (obj *MySQLData) GetEffectiveFriendsIdListByIdPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetEffectiveFriendsInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.FriendsInfoListPlus, error)
- func (obj *MySQLData) GetFriendsIdListByOptions(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetGroupChatIdListOfUser(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetGroupChatListByManagerId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.GroupChatList, error)
- func (obj *MySQLData) GetGroupChatListByName(ctx context.Context, param *mysqlPb.NameAndIsDelete) (*mysqlPb.GroupChatList, error)
- func (obj *MySQLData) GetGroupChatUsersInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.UserInfoInGroupChatListPlus, error)
- func (obj *MySQLData) GetOneFriendship(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) GetOneGroupChatById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.GroupChatBasic, error)
- func (obj *MySQLData) GetOneGroupChatByNameAndManager(ctx context.Context, param *mysqlPb.IdAndName) (*mysqlPb.GroupChatBasic, error)
- func (obj *MySQLData) GetOneSubscriptionById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.SubscriptionBasic, error)
- func (obj *MySQLData) GetOneSubscriptionByName(ctx context.Context, param *mysqlPb.NameAndIsDelete) (*mysqlPb.SubscriptionBasic, error)
- func (obj *MySQLData) GetOneUserByEmail(ctx context.Context, param *mysqlPb.EmailAndIsDelete) (*mysqlPb.UserBasic, error)
- func (obj *MySQLData) GetOneUserById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserBasic, error)
- func (obj *MySQLData) GetOneUserGroupChat(ctx context.Context, param *mysqlPb.UserAndGroupId) (*mysqlPb.UserGroupChatRelate, error)
- func (obj *MySQLData) GetOneUserPasswordByEmail(ctx context.Context, param *mysqlPb.Email) (*mysqlPb.Password, error)
- func (obj *MySQLData) GetOneUserPasswordById(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.Password, error)
- func (obj *MySQLData) GetOneUserSubscription(ctx context.Context, param *mysqlPb.UserAndSubsId) (*mysqlPb.UserSubscriptionRelate, error)
- func (obj *MySQLData) GetSubscriptionIdListOfUser(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetSubscriptionListByManagerId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.SubscriptionBasicList, error)
- func (obj *MySQLData) GetSubscriptionUsersInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.UserInfoOfSubscriptionList, error)
- func (obj *MySQLData) GetUserGroupChatListByGroupId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserGroupChatRelateList, error)
- func (obj *MySQLData) GetUserGroupChatListByUserId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserGroupChatRelateList, error)
- func (obj *MySQLData) GetUserGroupChatsInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.GroupChatInfoListOfUserPlus, error)
- func (obj *MySQLData) GetUserIdListOfGroupChat(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetUserIdListOfSubscription(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdList, error)
- func (obj *MySQLData) GetUserListByName(ctx context.Context, param *mysqlPb.NameAndIsDelete) (*mysqlPb.UserBasicList, error)
- func (obj *MySQLData) GetUserSubscriptionListBySubsId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserSubscriptionRelateList, error)
- func (obj *MySQLData) GetUserSubscriptionListByUserId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserSubscriptionRelateList, error)
- func (obj *MySQLData) GetUserSubscriptionsInfoPlus(ctx context.Context, param *mysqlPb.Id) (*mysqlPb.SubscriptionInfoOfUserList, error)
- func (obj *MySQLData) PostSaveOneNewFriendPlus(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PostSaveOneNewFriendship(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PostSaveOneNewGroupChat(ctx context.Context, param *mysqlPb.GroupChatBasic) (*mysqlPb.GroupChatBasic, error)
- func (obj *MySQLData) PostSaveOneNewGroupChatPlus(ctx context.Context, param *mysqlPb.GroupChatBasic) (*mysqlPb.GroupChatBasic, error)
- func (obj *MySQLData) PostSaveOneNewSubscription(ctx context.Context, param *mysqlPb.SubscriptionBasic) (*mysqlPb.SubscriptionBasic, error)
- func (obj *MySQLData) PostSaveOneNewSubscriptionPlus(ctx context.Context, param *mysqlPb.SubscriptionBasic) (*mysqlPb.SubscriptionBasic, error)
- func (obj *MySQLData) PostSaveOneNewUser(ctx context.Context, param *mysqlPb.UserBasic) (*mysqlPb.UserBasic, error)
- func (obj *MySQLData) PostSaveOneNewUserGroupChat(ctx context.Context, param *mysqlPb.UserGroupChatRelate) (*mysqlPb.UserGroupChatRelate, error)
- func (obj *MySQLData) PostSaveOneNewUserSubscription(ctx context.Context, param *mysqlPb.UserSubscriptionRelate) (*mysqlPb.UserSubscriptionRelate, error)
- func (obj *MySQLData) PutAcceptOneNewFriendPlus(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PutDeleteOneFriendPlus(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PutOneFriendIsAccept(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PutOneFriendIsBlack(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PutOneFriendIsDelete(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PutOneFriendNote(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
- func (obj *MySQLData) PutOneGroupChatAvatarById(ctx context.Context, param *mysqlPb.IdAndAvatar) (*mysqlPb.IdAndAvatar, error)
- func (obj *MySQLData) PutOneGroupChatIsDeleteById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdAndIsDelete, error)
- func (obj *MySQLData) PutOneGroupChatManagerById(ctx context.Context, param *mysqlPb.GroupAndManagerId) (*mysqlPb.GroupAndManagerId, error)
- func (obj *MySQLData) PutOneGroupChatNameById(ctx context.Context, param *mysqlPb.IdAndName) (*mysqlPb.IdAndName, error)
- func (obj *MySQLData) PutOneGroupChatQrCodeById(ctx context.Context, param *mysqlPb.IdAndQrCode) (*mysqlPb.IdAndQrCode, error)
- func (obj *MySQLData) PutOneSubscriptionAvatarById(ctx context.Context, param *mysqlPb.IdAndAvatar) (*mysqlPb.IdAndAvatar, error)
- func (obj *MySQLData) PutOneSubscriptionIntroById(ctx context.Context, param *mysqlPb.IdAndIntro) (*mysqlPb.IdAndIntro, error)
- func (obj *MySQLData) PutOneSubscriptionIsDeleteById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdAndIsDelete, error)
- func (obj *MySQLData) PutOneSubscriptionManagerById(ctx context.Context, param *mysqlPb.SubsAndManagerId) (*mysqlPb.SubsAndManagerId, error)
- func (obj *MySQLData) PutOneSubscriptionNameById(ctx context.Context, param *mysqlPb.IdAndName) (*mysqlPb.IdAndName, error)
- func (obj *MySQLData) PutOneSubscriptionQrCodeById(ctx context.Context, param *mysqlPb.IdAndQrCode) (*mysqlPb.IdAndQrCode, error)
- func (obj *MySQLData) PutOneUserGroupChatIsDelete(ctx context.Context, param *mysqlPb.UserGroupChatRelate) (*mysqlPb.UserGroupChatRelate, error)
- func (obj *MySQLData) PutOneUserGroupChatNote(ctx context.Context, param *mysqlPb.UserGroupChatRelate) (*mysqlPb.UserGroupChatRelate, error)
- func (obj *MySQLData) PutOneUserSubscriptionIsDelete(ctx context.Context, param *mysqlPb.UserSubscriptionRelate) (*mysqlPb.UserSubscriptionRelate, error)
- func (obj *MySQLData) PutUserAvatarById(ctx context.Context, param *mysqlPb.IdAndAvatar) (*mysqlPb.IdAndAvatar, error)
- func (obj *MySQLData) PutUserIsDeleteById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdAndIsDelete, error)
- func (obj *MySQLData) PutUserPasswordById(ctx context.Context, param *mysqlPb.IdAndPassword) (*mysqlPb.IdAndPassword, error)
- func (obj *MySQLData) PutUserProfileByIdPlus(ctx context.Context, param *mysqlPb.UserProfilePlus) (*mysqlPb.UserProfilePlus, error)
- func (obj *MySQLData) PutUserQrCodeById(ctx context.Context, param *mysqlPb.IdAndQrCode) (*mysqlPb.IdAndQrCode, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var CtxCanceledErr = errors.New("the client canceled or connection time out")
Functions ¶
func GetMongoDateClient ¶
func GetMongoDateClient() mongoPb.MongoBindServiceClient
Return the client for mongo data rpc sever. The type of client is pointer.
func GetMySQLDateClient ¶
func GetMySQLDateClient() mysqlPb.MySQLBindServiceClient
Return the client for mysql data rpc sever. The type of client is pointer.
func StartMongoDataRPCServer ¶
func StartMongoDataRPCServer()
func StartMySQLDataRPCServer ¶
func StartMySQLDataRPCServer()
Start the gRPC server for MySQL data operation.
Types ¶
type MongoData ¶
type MongoData struct{}
func (*MongoData) GetAllGroupChatHistory ¶
func (*MongoData) GetAllSubscriptionHistory ¶
func (*MongoData) GetAllUserChatHistory ¶
func (*MongoData) GetDelayMessage ¶
func (*MongoData) GetGroupChatHistoryByDate ¶
func (*MongoData) GetGroupChatHistoryByDateRange ¶
func (obj *MongoData) GetGroupChatHistoryByDateRange(ctx context.Context, param *mongoPb.IdAndDateRange) (*mongoPb.GroupChatHistory, error)
func (*MongoData) GetGroupChatUsers ¶
func (*MongoData) GetSubscriptionHistoryByDate ¶
func (*MongoData) GetSubscriptionHistoryByDateRange ¶
func (obj *MongoData) GetSubscriptionHistoryByDateRange(ctx context.Context, param *mongoPb.IdAndDateRange) (*mongoPb.SubscriptionHistory, error)
func (*MongoData) GetSubscriptionUsers ¶
func (*MongoData) GetUserChatHistoryByDate ¶
func (obj *MongoData) GetUserChatHistoryByDate(ctx context.Context, param *mongoPb.JoinIdAndDate) (*mongoPb.UserChatHistory, error)
func (*MongoData) GetUserChatHistoryByDateRange ¶
func (obj *MongoData) GetUserChatHistoryByDateRange(ctx context.Context, param *mongoPb.JoinIdAndDateRange) (*mongoPb.UserChatHistory, error)
func (*MongoData) GetUserFriendsAndBlacklist ¶
func (*MongoData) GetUserGroupChats ¶
func (*MongoData) GetUserSubscriptions ¶
func (*MongoData) PutGroupChatUsersAdd ¶
func (obj *MongoData) PutGroupChatUsersAdd(ctx context.Context, param *mongoPb.XAndManagerAndUserId) (*mongoPb.EmptyResult, error)
func (*MongoData) PutGroupChatUsersDel ¶
func (*MongoData) PutMoveFriendIntoBlacklistPlus ¶
func (*MongoData) PutMoveFriendOutFromBlacklistPlus ¶
func (*MongoData) PutSaveDelayMessage ¶
func (obj *MongoData) PutSaveDelayMessage(ctx context.Context, param *mongoPb.IdAndMessage) (*mongoPb.EmptyResult, error)
func (*MongoData) PutSaveGroupChatHistory ¶
func (obj *MongoData) PutSaveGroupChatHistory(ctx context.Context, param *mongoPb.IdAndMessage) (*mongoPb.EmptyResult, error)
func (*MongoData) PutSaveSubscriptionHistory ¶
func (obj *MongoData) PutSaveSubscriptionHistory(ctx context.Context, param *mongoPb.IdAndMessage) (*mongoPb.EmptyResult, error)
func (*MongoData) PutSaveUserChatHistory ¶
func (obj *MongoData) PutSaveUserChatHistory(ctx context.Context, param *mongoPb.JoinIdAndMessage) (*mongoPb.EmptyResult, error)
func (*MongoData) PutSubscriptionUsersAdd ¶
func (obj *MongoData) PutSubscriptionUsersAdd(ctx context.Context, param *mongoPb.XAndManagerAndUserId) (*mongoPb.EmptyResult, error)
func (*MongoData) PutSubscriptionUsersDel ¶
func (*MongoData) PutUserBlacklistAdd ¶
func (*MongoData) PutUserBlacklistDel ¶
func (*MongoData) PutUserFollowSubscriptionPlus ¶
func (*MongoData) PutUserFriendsAdd ¶
func (*MongoData) PutUserFriendsDel ¶
func (*MongoData) PutUserGroupChatsAdd ¶
func (*MongoData) PutUserGroupChatsDel ¶
func (*MongoData) PutUserJoinGroupChatPlus ¶
func (*MongoData) PutUserQuitGroupChatPlus ¶
func (*MongoData) PutUserSubscriptionsAdd ¶
func (*MongoData) PutUserSubscriptionsDel ¶
func (*MongoData) PutUserUnFollowSubscriptionPlus ¶
type MySQLData ¶
type MySQLData struct{}
func (*MySQLData) DeleteOneFriendshipReal ¶
func (obj *MySQLData) DeleteOneFriendshipReal(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) DeleteOneGroupChatReal ¶
func (*MySQLData) DeleteOneSubscriptionReal ¶
func (*MySQLData) DeleteOneUserGroupChatReal ¶
func (obj *MySQLData) DeleteOneUserGroupChatReal(ctx context.Context, param *mysqlPb.UserAndGroupId) (*mysqlPb.UserAndGroupId, error)
func (*MySQLData) DeleteOneUserReal ¶
func (*MySQLData) DeleteOneUserSubscriptionReal ¶
func (obj *MySQLData) DeleteOneUserSubscriptionReal(ctx context.Context, param *mysqlPb.UserAndSubsId) (*mysqlPb.UserAndSubsId, error)
func (*MySQLData) GetAllFriendsInfoPlus ¶
func (*MySQLData) GetAllFriendshipList ¶
func (obj *MySQLData) GetAllFriendshipList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.FriendshipBasicList, error)
func (*MySQLData) GetAllGroupChatList ¶
func (obj *MySQLData) GetAllGroupChatList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.GroupChatList, error)
func (*MySQLData) GetAllUserGroupChatList ¶
func (obj *MySQLData) GetAllUserGroupChatList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.UserGroupChatRelateList, error)
func (*MySQLData) GetAllUserList ¶
func (obj *MySQLData) GetAllUserList(ctx context.Context, param *mysqlPb.EmptyParam) (*mysqlPb.UserBasicList, error)
func (*MySQLData) GetBlacklistFriendsIdListByIdPlus ¶
func (*MySQLData) GetBlacklistFriendsInfoPlus ¶
func (*MySQLData) GetEffectiveFriendsIdListByIdPlus ¶
func (*MySQLData) GetEffectiveFriendsInfoPlus ¶
func (*MySQLData) GetFriendsIdListByOptions ¶
func (*MySQLData) GetGroupChatIdListOfUser ¶
func (*MySQLData) GetGroupChatListByManagerId ¶
func (obj *MySQLData) GetGroupChatListByManagerId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.GroupChatList, error)
func (*MySQLData) GetGroupChatListByName ¶
func (obj *MySQLData) GetGroupChatListByName(ctx context.Context, param *mysqlPb.NameAndIsDelete) (*mysqlPb.GroupChatList, error)
func (*MySQLData) GetGroupChatUsersInfoPlus ¶
func (*MySQLData) GetOneFriendship ¶
func (obj *MySQLData) GetOneFriendship(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) GetOneGroupChatById ¶
func (obj *MySQLData) GetOneGroupChatById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.GroupChatBasic, error)
func (*MySQLData) GetOneGroupChatByNameAndManager ¶
func (*MySQLData) GetOneSubscriptionById ¶
func (obj *MySQLData) GetOneSubscriptionById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.SubscriptionBasic, error)
func (*MySQLData) GetOneSubscriptionByName ¶
func (obj *MySQLData) GetOneSubscriptionByName(ctx context.Context, param *mysqlPb.NameAndIsDelete) (*mysqlPb.SubscriptionBasic, error)
func (*MySQLData) GetOneUserByEmail ¶
func (*MySQLData) GetOneUserById ¶
func (*MySQLData) GetOneUserGroupChat ¶
func (obj *MySQLData) GetOneUserGroupChat(ctx context.Context, param *mysqlPb.UserAndGroupId) (*mysqlPb.UserGroupChatRelate, error)
func (*MySQLData) GetOneUserPasswordByEmail ¶
func (*MySQLData) GetOneUserPasswordById ¶
func (*MySQLData) GetOneUserSubscription ¶
func (obj *MySQLData) GetOneUserSubscription(ctx context.Context, param *mysqlPb.UserAndSubsId) (*mysqlPb.UserSubscriptionRelate, error)
func (*MySQLData) GetSubscriptionIdListOfUser ¶
func (*MySQLData) GetSubscriptionListByManagerId ¶
func (obj *MySQLData) GetSubscriptionListByManagerId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.SubscriptionBasicList, error)
func (*MySQLData) GetSubscriptionUsersInfoPlus ¶
func (*MySQLData) GetUserGroupChatListByGroupId ¶
func (obj *MySQLData) GetUserGroupChatListByGroupId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserGroupChatRelateList, error)
func (*MySQLData) GetUserGroupChatListByUserId ¶
func (obj *MySQLData) GetUserGroupChatListByUserId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserGroupChatRelateList, error)
func (*MySQLData) GetUserGroupChatsInfoPlus ¶
func (*MySQLData) GetUserIdListOfGroupChat ¶
func (*MySQLData) GetUserIdListOfSubscription ¶
func (*MySQLData) GetUserListByName ¶
func (obj *MySQLData) GetUserListByName(ctx context.Context, param *mysqlPb.NameAndIsDelete) (*mysqlPb.UserBasicList, error)
func (*MySQLData) GetUserSubscriptionListBySubsId ¶
func (obj *MySQLData) GetUserSubscriptionListBySubsId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserSubscriptionRelateList, error)
func (*MySQLData) GetUserSubscriptionListByUserId ¶
func (obj *MySQLData) GetUserSubscriptionListByUserId(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.UserSubscriptionRelateList, error)
func (*MySQLData) GetUserSubscriptionsInfoPlus ¶
func (*MySQLData) PostSaveOneNewFriendPlus ¶
func (obj *MySQLData) PostSaveOneNewFriendPlus(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PostSaveOneNewFriendship ¶
func (obj *MySQLData) PostSaveOneNewFriendship(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PostSaveOneNewGroupChat ¶
func (obj *MySQLData) PostSaveOneNewGroupChat(ctx context.Context, param *mysqlPb.GroupChatBasic) (*mysqlPb.GroupChatBasic, error)
func (*MySQLData) PostSaveOneNewGroupChatPlus ¶
func (obj *MySQLData) PostSaveOneNewGroupChatPlus(ctx context.Context, param *mysqlPb.GroupChatBasic) (*mysqlPb.GroupChatBasic, error)
func (*MySQLData) PostSaveOneNewSubscription ¶
func (obj *MySQLData) PostSaveOneNewSubscription(ctx context.Context, param *mysqlPb.SubscriptionBasic) (*mysqlPb.SubscriptionBasic, error)
func (*MySQLData) PostSaveOneNewSubscriptionPlus ¶
func (obj *MySQLData) PostSaveOneNewSubscriptionPlus(ctx context.Context, param *mysqlPb.SubscriptionBasic) (*mysqlPb.SubscriptionBasic, error)
func (*MySQLData) PostSaveOneNewUser ¶
func (*MySQLData) PostSaveOneNewUserGroupChat ¶
func (obj *MySQLData) PostSaveOneNewUserGroupChat(ctx context.Context, param *mysqlPb.UserGroupChatRelate) (*mysqlPb.UserGroupChatRelate, error)
func (*MySQLData) PostSaveOneNewUserSubscription ¶
func (obj *MySQLData) PostSaveOneNewUserSubscription(ctx context.Context, param *mysqlPb.UserSubscriptionRelate) (*mysqlPb.UserSubscriptionRelate, error)
func (*MySQLData) PutAcceptOneNewFriendPlus ¶
func (obj *MySQLData) PutAcceptOneNewFriendPlus(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PutDeleteOneFriendPlus ¶
func (obj *MySQLData) PutDeleteOneFriendPlus(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PutOneFriendIsAccept ¶
func (obj *MySQLData) PutOneFriendIsAccept(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PutOneFriendIsBlack ¶
func (obj *MySQLData) PutOneFriendIsBlack(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PutOneFriendIsDelete ¶
func (obj *MySQLData) PutOneFriendIsDelete(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PutOneFriendNote ¶
func (obj *MySQLData) PutOneFriendNote(ctx context.Context, param *mysqlPb.FriendshipBasic) (*mysqlPb.FriendshipBasic, error)
func (*MySQLData) PutOneGroupChatAvatarById ¶
func (obj *MySQLData) PutOneGroupChatAvatarById(ctx context.Context, param *mysqlPb.IdAndAvatar) (*mysqlPb.IdAndAvatar, error)
func (*MySQLData) PutOneGroupChatIsDeleteById ¶
func (obj *MySQLData) PutOneGroupChatIsDeleteById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdAndIsDelete, error)
func (*MySQLData) PutOneGroupChatManagerById ¶
func (obj *MySQLData) PutOneGroupChatManagerById(ctx context.Context, param *mysqlPb.GroupAndManagerId) (*mysqlPb.GroupAndManagerId, error)
func (*MySQLData) PutOneGroupChatNameById ¶
func (*MySQLData) PutOneGroupChatQrCodeById ¶
func (obj *MySQLData) PutOneGroupChatQrCodeById(ctx context.Context, param *mysqlPb.IdAndQrCode) (*mysqlPb.IdAndQrCode, error)
func (*MySQLData) PutOneSubscriptionAvatarById ¶
func (obj *MySQLData) PutOneSubscriptionAvatarById(ctx context.Context, param *mysqlPb.IdAndAvatar) (*mysqlPb.IdAndAvatar, error)
func (*MySQLData) PutOneSubscriptionIntroById ¶
func (obj *MySQLData) PutOneSubscriptionIntroById(ctx context.Context, param *mysqlPb.IdAndIntro) (*mysqlPb.IdAndIntro, error)
func (*MySQLData) PutOneSubscriptionIsDeleteById ¶
func (obj *MySQLData) PutOneSubscriptionIsDeleteById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdAndIsDelete, error)
func (*MySQLData) PutOneSubscriptionManagerById ¶
func (obj *MySQLData) PutOneSubscriptionManagerById(ctx context.Context, param *mysqlPb.SubsAndManagerId) (*mysqlPb.SubsAndManagerId, error)
func (*MySQLData) PutOneSubscriptionNameById ¶
func (*MySQLData) PutOneSubscriptionQrCodeById ¶
func (obj *MySQLData) PutOneSubscriptionQrCodeById(ctx context.Context, param *mysqlPb.IdAndQrCode) (*mysqlPb.IdAndQrCode, error)
func (*MySQLData) PutOneUserGroupChatIsDelete ¶
func (obj *MySQLData) PutOneUserGroupChatIsDelete(ctx context.Context, param *mysqlPb.UserGroupChatRelate) (*mysqlPb.UserGroupChatRelate, error)
func (*MySQLData) PutOneUserGroupChatNote ¶
func (obj *MySQLData) PutOneUserGroupChatNote(ctx context.Context, param *mysqlPb.UserGroupChatRelate) (*mysqlPb.UserGroupChatRelate, error)
func (*MySQLData) PutOneUserSubscriptionIsDelete ¶
func (obj *MySQLData) PutOneUserSubscriptionIsDelete(ctx context.Context, param *mysqlPb.UserSubscriptionRelate) (*mysqlPb.UserSubscriptionRelate, error)
func (*MySQLData) PutUserAvatarById ¶
func (obj *MySQLData) PutUserAvatarById(ctx context.Context, param *mysqlPb.IdAndAvatar) (*mysqlPb.IdAndAvatar, error)
func (*MySQLData) PutUserIsDeleteById ¶
func (obj *MySQLData) PutUserIsDeleteById(ctx context.Context, param *mysqlPb.IdAndIsDelete) (*mysqlPb.IdAndIsDelete, error)
func (*MySQLData) PutUserPasswordById ¶
func (obj *MySQLData) PutUserPasswordById(ctx context.Context, param *mysqlPb.IdAndPassword) (*mysqlPb.IdAndPassword, error)
func (*MySQLData) PutUserProfileByIdPlus ¶
func (obj *MySQLData) PutUserProfileByIdPlus(ctx context.Context, param *mysqlPb.UserProfilePlus) (*mysqlPb.UserProfilePlus, error)
func (*MySQLData) PutUserQrCodeById ¶
func (obj *MySQLData) PutUserQrCodeById(ctx context.Context, param *mysqlPb.IdAndQrCode) (*mysqlPb.IdAndQrCode, error)
Click to show internal directories.
Click to hide internal directories.