dao

Documentation

Index

• type FriendDao
  • func GetUserRelationDao() *FriendDao
  • func (d *FriendDao) CheckIsFriend(ctx context.Context, uid, friendUID types.ID) (bool, error)
  • func (d *FriendDao) CountFriends(ctx context.Context, uid types.ID) (int64, error)
  • func (d *FriendDao) CreateFriend(ctx context.Context, friend *data.Friend) error
  • func (d *FriendDao) DeleteFriendStatusFromCache(ctx context.Context, uid, friendUID types.ID) error
  • func (d *FriendDao) GetFriend(ctx context.Context, uid, friendUID types.ID) (*data.Friend, error)
  • func (d *FriendDao) GetFriendByStatus(ctx context.Context, uid, friendUID types.ID, status int) (*data.Friend, error)
  • func (d *FriendDao) GetFriendStatusFromCache(ctx context.Context, uid, friendUID types.ID) (bool, error)
  • func (d *FriendDao) GetFriends(ctx context.Context, uid types.ID) ([]*data.Friend, error)
  • func (d *FriendDao) SetFriendStatusToCache(ctx context.Context, uid, friendUID types.ID) error
  • func (d *FriendDao) UpdateFriendStatus(ctx context.Context, userRelation *data.Friend) error
• type FriendRequestDao
  • func GetFriendRequestDao() *FriendRequestDao
  • func (d *FriendRequestDao) CreateFriendRequest(ctx context.Context, fr *data.FriendRequest) error
  • func (d *FriendRequestDao) GetFriendRequest(ctx context.Context, uid, friendUID types.ID) (*data.FriendRequest, error)
  • func (d *FriendRequestDao) GetFriendRequestByID(ctx context.Context, id uint64) (*data.FriendRequest, error)
  • func (d *FriendRequestDao) GetFriendRequests(ctx context.Context, uid types.ID, status int) ([]*data.FriendRequest, error)
  • func (d *FriendRequestDao) UpdateFriendRequest(ctx context.Context, fr *data.FriendRequest) error
• type GroupDao
  • func GetGroupDao() *GroupDao
  • func (d *GroupDao) CreateGroup(ctx context.Context, group *data.Group) error
  • func (d *GroupDao) DecrGroupMemberCount(ctx context.Context, g *data.Group, decrease uint) (bool, error)
  • func (d *GroupDao) DeleteGroup(ctx context.Context, group *data.Group) error
  • func (d *GroupDao) GetGroup(ctx context.Context, id uint64) (*data.Group, error)
  • func (d *GroupDao) GetGroupByGID(ctx context.Context, gid types.ID) (*data.Group, error)
  • func (d *GroupDao) IncrGroupMemberCount(ctx context.Context, g *data.Group, increase uint) (bool, error)
  • func (d *GroupDao) ListGroups(ctx context.Context, gids []types.ID) ([]*data.Group, error)
  • func (d *GroupDao) UpdateGroup(ctx context.Context, group *data.Group) error
• type GroupMemberDao
  • func GetGroupMemberDao() *GroupMemberDao
  • func (d *GroupMemberDao) CreateGroupMember(ctx context.Context, groupMember ...*data.GroupMember) error
  • func (d *GroupMemberDao) DeleteGroupMember(ctx context.Context, groupMember *data.GroupMember) error
  • func (d *GroupMemberDao) DeleteGroupMembers(ctx context.Context, gid types.ID, uids []types.ID) error
  • func (d *GroupMemberDao) GetGroupMember(ctx context.Context, id uint64) (*data.GroupMember, error)
  • func (d *GroupMemberDao) GetGroupMemberByGIDUID(ctx context.Context, gid, uid types.ID) (*data.GroupMember, error)
  • func (d *GroupMemberDao) IsMemberOfGroup(ctx context.Context, gid, uid types.ID) (*data.GroupMember, error)
  • func (d *GroupMemberDao) IsMemberOfGroupFromCache(ctx context.Context, gid, uid types.ID) (int, error)
  • func (d *GroupMemberDao) ListGroupByUID(ctx context.Context, uid types.ID) ([]*data.GroupMember, error)
  • func (d *GroupMemberDao) ListGroupMembersByGID(ctx context.Context, gid types.ID) ([]*data.GroupMember, error)
  • func (d *GroupMemberDao) ListInGroupUIDs(ctx context.Context, gid types.ID, uids []types.ID) ([]types.ID, error)
  • func (d *GroupMemberDao) SetMemberStatusToCache(ctx context.Context, gid, uid types.ID, status int) error
• type UserDao
  • func GetUserDao() *UserDao
  • func (u *UserDao) CreateUser(ctx context.Context, user *data.User) error
  • func (u *UserDao) GetUser(ctx context.Context, id uint64) (*data.User, error)
  • func (u *UserDao) GetUserByEmail(ctx context.Context, email string) (*data.User, error)
  • func (u *UserDao) GetUserByPhone(ctx context.Context, phone string) (*data.User, error)
  • func (u *UserDao) GetUserByUID(ctx context.Context, uid types.ID) (*data.User, error)
  • func (u *UserDao) GetUserOnlineAgent(ctx context.Context, uid types.ID) (string, error)
  • func (u *UserDao) ListUsers(ctx context.Context, uids ...types.ID) ([]*data.User, error)
  • func (u *UserDao) UndoDelete(ctx context.Context, user *data.User) error
  • func (u *UserDao) UpdateUser(ctx context.Context, user *data.User) error

Types

type FriendDao

type FriendDao struct{}

func GetUserRelationDao

func GetUserRelationDao() *FriendDao

func (*FriendDao) CheckIsFriend

func (d *FriendDao) CheckIsFriend(ctx context.Context, uid, friendUID types.ID) (bool, error)

func (*FriendDao) CountFriends

func (d *FriendDao) CountFriends(ctx context.Context, uid types.ID) (int64, error)

func (*FriendDao) CreateFriend

func (d *FriendDao) CreateFriend(ctx context.Context, friend *data.Friend) error

func (*FriendDao) DeleteFriendStatusFromCache

func (d *FriendDao) DeleteFriendStatusFromCache(ctx context.Context, uid, friendUID types.ID) error

func (*FriendDao) GetFriend

func (d *FriendDao) GetFriend(ctx context.Context, uid, friendUID types.ID) (*data.Friend, error)

func (*FriendDao) GetFriendByStatus

func (d *FriendDao) GetFriendByStatus(ctx context.Context, uid, friendUID types.ID, status int) (*data.Friend, error)

func (*FriendDao) GetFriendStatusFromCache

func (d *FriendDao) GetFriendStatusFromCache(ctx context.Context, uid, friendUID types.ID) (bool, error)

GetFriendStatusFromCache get friend status from cache. cache key: sort(uid, friend_uid), so that there is no duplicated key, only one record between two users. cache value: 1 as constant.

func (*FriendDao) GetFriends

func (d *FriendDao) GetFriends(ctx context.Context, uid types.ID) ([]*data.Friend, error)

func (*FriendDao) SetFriendStatusToCache

func (d *FriendDao) SetFriendStatusToCache(ctx context.Context, uid, friendUID types.ID) error

SetFriendStatusToCache set friend status to cache.

func (*FriendDao) UpdateFriendStatus

func (d *FriendDao) UpdateFriendStatus(ctx context.Context, userRelation *data.Friend) error

type FriendRequestDao

type FriendRequestDao struct {
}

func GetFriendRequestDao

func GetFriendRequestDao() *FriendRequestDao

func (*FriendRequestDao) CreateFriendRequest

func (d *FriendRequestDao) CreateFriendRequest(ctx context.Context, fr *data.FriendRequest) error

func (*FriendRequestDao) GetFriendRequest

func (d *FriendRequestDao) GetFriendRequest(ctx context.Context, uid, friendUID types.ID) (*data.FriendRequest, error)

func (*FriendRequestDao) GetFriendRequestByID

func (d *FriendRequestDao) GetFriendRequestByID(ctx context.Context, id uint64) (*data.FriendRequest, error)

func (*FriendRequestDao) GetFriendRequests

func (d *FriendRequestDao) GetFriendRequests(ctx context.Context, uid types.ID, status int) ([]*data.FriendRequest, error)

func (*FriendRequestDao) UpdateFriendRequest

func (d *FriendRequestDao) UpdateFriendRequest(ctx context.Context, fr *data.FriendRequest) error

type GroupDao

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

func GetGroupDao

func GetGroupDao() *GroupDao

func (*GroupDao) CreateGroup

func (d *GroupDao) CreateGroup(ctx context.Context, group *data.Group) error

func (*GroupDao) DecrGroupMemberCount

func (d *GroupDao) DecrGroupMemberCount(ctx context.Context, g *data.Group, decrease uint) (bool, error)

DecrGroupMemberCount decr group member count by given decrease. It will check if after decreased group member count is less than 0, if so, it will return false.

func (*GroupDao) DeleteGroup

func (d *GroupDao) DeleteGroup(ctx context.Context, group *data.Group) error

func (*GroupDao) GetGroup

func (d *GroupDao) GetGroup(ctx context.Context, id uint64) (*data.Group, error)

func (*GroupDao) GetGroupByGID

func (d *GroupDao) GetGroupByGID(ctx context.Context, gid types.ID) (*data.Group, error)

func (*GroupDao) IncrGroupMemberCount

func (d *GroupDao) IncrGroupMemberCount(ctx context.Context, g *data.Group, increase uint) (bool, error)

IncrGroupMemberCount incr group member count by given increase. It will check if after increased group member count is greater than max group member count, if so, it will return false.

func (*GroupDao) ListGroups

func (d *GroupDao) ListGroups(ctx context.Context, gids []types.ID) ([]*data.Group, error)

func (*GroupDao) UpdateGroup

func (d *GroupDao) UpdateGroup(ctx context.Context, group *data.Group) error

type GroupMemberDao

type GroupMemberDao struct{}

func GetGroupMemberDao

func GetGroupMemberDao() *GroupMemberDao

func (*GroupMemberDao) CreateGroupMember

func (d *GroupMemberDao) CreateGroupMember(ctx context.Context, groupMember ...*data.GroupMember) error

func (*GroupMemberDao) DeleteGroupMember

func (d *GroupMemberDao) DeleteGroupMember(ctx context.Context, groupMember *data.GroupMember) error

func (*GroupMemberDao) DeleteGroupMembers

func (d *GroupMemberDao) DeleteGroupMembers(ctx context.Context, gid types.ID, uids []types.ID) error

func (*GroupMemberDao) GetGroupMember

func (d *GroupMemberDao) GetGroupMember(ctx context.Context, id uint64) (*data.GroupMember, error)

func (*GroupMemberDao) GetGroupMemberByGIDUID

func (d *GroupMemberDao) GetGroupMemberByGIDUID(ctx context.Context, gid, uid types.ID) (*data.GroupMember, error)

func (*GroupMemberDao) IsMemberOfGroup

func (d *GroupMemberDao) IsMemberOfGroup(ctx context.Context, gid, uid types.ID) (*data.GroupMember, error)

func (*GroupMemberDao) IsMemberOfGroupFromCache

func (d *GroupMemberDao) IsMemberOfGroupFromCache(ctx context.Context, gid, uid types.ID) (int, error)

IsMemberOfGroupFromCache return member status in group of given uid. 0: active , 1: silent

func (*GroupMemberDao) ListGroupByUID

func (d *GroupMemberDao) ListGroupByUID(ctx context.Context, uid types.ID) ([]*data.GroupMember, error)

func (*GroupMemberDao) ListGroupMembersByGID

func (d *GroupMemberDao) ListGroupMembersByGID(ctx context.Context, gid types.ID) ([]*data.GroupMember, error)

func (*GroupMemberDao) ListInGroupUIDs

func (d *GroupMemberDao) ListInGroupUIDs(ctx context.Context, gid types.ID, uids []types.ID) ([]types.ID, error)

ListInGroupUIDs returns uid list in group of given uids,

func (*GroupMemberDao) SetMemberStatusToCache

func (d *GroupMemberDao) SetMemberStatusToCache(ctx context.Context, gid, uid types.ID, status int) error

type UserDao

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

func GetUserDao

func GetUserDao() *UserDao

func (*UserDao) CreateUser

func (u *UserDao) CreateUser(ctx context.Context, user *data.User) error

func (*UserDao) GetUser

func (u *UserDao) GetUser(ctx context.Context, id uint64) (*data.User, error)

func (*UserDao) GetUserByEmail

func (u *UserDao) GetUserByEmail(ctx context.Context, email string) (*data.User, error)

GetUserByEmail get user by email directly from db

func (*UserDao) GetUserByPhone

func (u *UserDao) GetUserByPhone(ctx context.Context, phone string) (*data.User, error)

GetUserByPhone get user by phone directly from db

func (*UserDao) GetUserByUID

func (u *UserDao) GetUserByUID(ctx context.Context, uid types.ID) (*data.User, error)

GetUserByUID get user by uid

func (*UserDao) GetUserOnlineAgent

func (u *UserDao) GetUserOnlineAgent(ctx context.Context, uid types.ID) (string, error)

GetUserOnlineAgent get user online agent from redis

func (*UserDao) ListUsers

func (u *UserDao) ListUsers(ctx context.Context, uids ...types.ID) ([]*data.User, error)

func (*UserDao) UndoDelete

func (u *UserDao) UndoDelete(ctx context.Context, user *data.User) error

UndoDelete undo delete user with new password

func (*UserDao) UpdateUser

func (u *UserDao) UpdateUser(ctx context.Context, user *data.User) error