store

Documentation

Index

• Variables
• func DecodeGroupKey(key []byte) (group int64, option int64, user int64)
• func GroupAdminKey(group, user int64) []byte
• func GroupApplyKey(group, user int64) []byte
• func GroupInviteKey(group, user int64) []byte
• func GroupMemberKey(group, user int64) []byte
• func UserFriendKey(user int64, friend int64) []byte
• func UserFriendRange(id int64) ([]byte, []byte)
• func UserGroupKey(user int64, group int64) []byte
• func UserGroupRange(id int64) ([]byte, []byte)
• func UserLastMessageKey(id int64) []byte
• func UserMessageKey(user int64, msg int64) []byte
• func UserRecentContactKey(user int64, contact int64) []byte
• func UserRecentContactRange(user int64) ([]byte, []byte)
• func UserUnionKey(id int64) []byte
• type Store
  • func NewStore(host, dbPath string) *Store
  • func (s *Store) Auth(_ context.Context, req *meta.StoreAuthRequest) (*meta.StoreAuthResponse, error)
  • func (s *Store) CheckFile(_ context.Context, req *meta.StoreCheckFileRequest) (*meta.StoreCheckFileResponse, error)
  • func (s *Store) DownloadFile(_ context.Context, req *meta.StoreDownloadFileRequest) (*meta.StoreDownloadFileResponse, error)
  • func (s *Store) FindUser(_ context.Context, req *meta.StoreFindUserRequest) (*meta.StoreFindUserResponse, error)
  • func (s *Store) Friend(_ context.Context, req *meta.StoreFriendRequest) (*meta.StoreFriendResponse, error)
  • func (s *Store) GetUserInfo(_ context.Context, req *meta.StoreGetUserInfoRequest) (*meta.StoreGetUserInfoResponse, error)
  • func (s *Store) Group(_ context.Context, req *meta.StoreGroupRequest) (*meta.StoreGroupResponse, error)
  • func (s *Store) GroupCreate(_ context.Context, req *meta.StoreGroupCreateRequest) (*meta.StoreGroupCreateResponse, error)
  • func (s *Store) GroupDelete(_ context.Context, req *meta.StoreGroupDeleteRequest) (*meta.StoreGroupDeleteResponse, error)
  • func (s *Store) LoadFriendList(_ context.Context, req *meta.StoreLoadFriendListRequest) (*meta.StoreLoadFriendListResponse, error)
  • func (s *Store) LoadGroupList(_ context.Context, req *meta.StoreLoadGroupListRequest) (*meta.StoreLoadGroupListResponse, error)
  • func (s *Store) LoadMessage(_ context.Context, req *meta.StoreLoadMessageRequest) (*meta.StoreLoadMessageResponse, error)
  • func (s *Store) LoadRecentContact(_ context.Context, req *meta.StoreRecentContactRequest) (*meta.StoreRecentContactResponse, error)
  • func (s *Store) NewMessage(_ context.Context, req *meta.StoreNewMessageRequest) (*meta.StoreNewMessageResponse, error)
  • func (s *Store) Register(_ context.Context, req *meta.StoreRegisterRequest) (*meta.StoreRegisterResponse, error)
  • func (s *Store) Start(notice, master string) error
  • func (s *Store) UpdateSignature(_ context.Context, req *meta.StoreUpdateSignatureRequest) (*meta.StoreUpdateSignatureResponse, error)
  • func (s *Store) UpdateUserInfo(_ context.Context, req *meta.StoreUpdateUserInfoRequest) (*meta.StoreUpdateUserInfoResponse, error)
  • func (s *Store) UpdateUserPassword(_ context.Context, req *meta.StoreUpdateUserPasswordRequest) (*meta.StoreUpdateUserPasswordResponse, error)
  • func (s *Store) UploadFile(_ context.Context, req *meta.StoreUploadFileRequest) (*meta.StoreUploadFileResponse, error)

Variables

var (
	// ErrInvalidOperator 当前用户没有权限进行这项操作.
	ErrInvalidOperator = errors.New("invalid operator")
)

var (
	// ErrInvalidSender invalid sender.
	ErrInvalidSender = errors.New("invalid sender")
)

Functions

func DecodeGroupKey

func DecodeGroupKey(key []byte) (group int64, option int64, user int64)

DecodeGroupKey 解析GroupKey.

func GroupAdminKey

func GroupAdminKey(group, user int64) []byte

GroupAdminKey 群管理员key

func GroupApplyKey

func GroupApplyKey(group, user int64) []byte

GroupApplyKey 申请入群key

func GroupInviteKey

func GroupInviteKey(group, user int64) []byte

GroupInviteKey 群邀请key

func GroupMemberKey

func GroupMemberKey(group, user int64) []byte

GroupMemberKey 群成员key

func UserFriendKey

func UserFriendKey(user int64, friend int64) []byte

UserFriendKey create user firend key.

func UserFriendRange

func UserFriendRange(id int64) ([]byte, []byte)

UserFriendRange create user friend key range.

func UserGroupKey

func UserGroupKey(user int64, group int64) []byte

UserGroupKey create group key by userid and groupid.

func UserGroupRange

func UserGroupRange(id int64) ([]byte, []byte)

UserGroupRange create user group key range.

func UserLastMessageKey

func UserLastMessageKey(id int64) []byte

UserLastMessageKey create max user message key.

func UserMessageKey

func UserMessageKey(user int64, msg int64) []byte

UserMessageKey create msg key by userid and msgid.

func UserRecentContactKey

func UserRecentContactKey(user int64, contact int64) []byte

UserRecentContactKey create user recent contact key.

func UserRecentContactRange

func UserRecentContactRange(user int64) ([]byte, []byte)

UserRecentContactRange create user recent contact key range.

func UserUnionKey

func UserUnionKey(id int64) []byte

UserUnionKey create user union key by userid

Types

type Store

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

Store save user, message.

func NewStore

func NewStore(host, dbPath string) *Store

NewStore new Store server.

func (*Store) Auth

func (s *Store) Auth(_ context.Context, req *meta.StoreAuthRequest) (*meta.StoreAuthResponse, error)

Auth check password.

func (*Store) CheckFile

func (s *Store) CheckFile(_ context.Context, req *meta.StoreCheckFileRequest) (*meta.StoreCheckFileResponse, error)

CheckFile 检测文件是否存在，文件的MD5, 服务器返回不存在的文件MD5.

func (*Store) DownloadFile

func (s *Store) DownloadFile(_ context.Context, req *meta.StoreDownloadFileRequest) (*meta.StoreDownloadFileResponse, error)

DownloadFile 下载文件，传入文件MD5，返回具体文件内容.

func (*Store) FindUser

func (s *Store) FindUser(_ context.Context, req *meta.StoreFindUserRequest) (*meta.StoreFindUserResponse, error)

FindUser 根据字符串的用户名模糊查询用户信息.

func (*Store) Friend

func (s *Store) Friend(_ context.Context, req *meta.StoreFriendRequest) (*meta.StoreFriendResponse, error)

Friend 添加好友添加完后会返回当前好友关系状态.

func (*Store) GetUserInfo

func (s *Store) GetUserInfo(_ context.Context, req *meta.StoreGetUserInfoRequest) (*meta.StoreGetUserInfoResponse, error)

GetUserInfo get user base info

func (*Store) Group

func (s *Store) Group(_ context.Context, req *meta.StoreGroupRequest) (*meta.StoreGroupResponse, error)

Group 加群，退出，邀请，踢人

func (*Store) GroupCreate

func (s *Store) GroupCreate(_ context.Context, req *meta.StoreGroupCreateRequest) (*meta.StoreGroupCreateResponse, error)

GroupCreate 创建群组

func (*Store) GroupDelete

func (s *Store) GroupDelete(_ context.Context, req *meta.StoreGroupDeleteRequest) (*meta.StoreGroupDeleteResponse, error)

GroupDelete 解散群组, 先发通知，再删除群，如果先删除就发不了消息了

func (*Store) LoadFriendList

func (s *Store) LoadFriendList(_ context.Context, req *meta.StoreLoadFriendListRequest) (*meta.StoreLoadFriendListResponse, error)

LoadFriendList load user's friend list

func (*Store) LoadGroupList

func (s *Store) LoadGroupList(_ context.Context, req *meta.StoreLoadGroupListRequest) (*meta.StoreLoadGroupListResponse, error)

LoadGroupList 加载群组列表

func (*Store) LoadMessage

func (s *Store) LoadMessage(_ context.Context, req *meta.StoreLoadMessageRequest) (*meta.StoreLoadMessageResponse, error)

LoadMessage 收取用户消息，每次可逆序(旧消息)或正序(新消息)接收100条 如果ID为0，就逆序返回旧的100条消息

func (*Store) LoadRecentContact

func (s *Store) LoadRecentContact(_ context.Context, req *meta.StoreRecentContactRequest) (*meta.StoreRecentContactResponse, error)

LoadRecentContact 最近联系人列表

func (*Store) NewMessage

func (s *Store) NewMessage(_ context.Context, req *meta.StoreNewMessageRequest) (*meta.StoreNewMessageResponse, error)

NewMessage save message to leveldb,

func (*Store) Register

func (s *Store) Register(_ context.Context, req *meta.StoreRegisterRequest) (*meta.StoreRegisterResponse, error)

Register add user.

func (*Store) Start

func (s *Store) Start(notice, master string) error

Start Store service.

func (*Store) UpdateSignature

func (s *Store) UpdateSignature(_ context.Context, req *meta.StoreUpdateSignatureRequest) (*meta.StoreUpdateSignatureResponse, error)

UpdateSignature update user Signature info

func (*Store) UpdateUserInfo

func (s *Store) UpdateUserInfo(_ context.Context, req *meta.StoreUpdateUserInfoRequest) (*meta.StoreUpdateUserInfoResponse, error)

UpdateUserInfo update user base info, ex: nickname, picurl and so on

func (*Store) UpdateUserPassword

func (s *Store) UpdateUserPassword(_ context.Context, req *meta.StoreUpdateUserPasswordRequest) (*meta.StoreUpdateUserPasswordResponse, error)

UpdateUserPassword update user password

func (*Store) UploadFile

func (s *Store) UploadFile(_ context.Context, req *meta.StoreUploadFileRequest) (*meta.StoreUploadFileResponse, error)

UploadFile 上传文件接口，一次一个文件.