service

Documentation

Index

• type Cache
• type CacheItem
• type LocalCache

Types

type Cache

type Cache interface {
	Prepare(cfg []string) (err error)

	GetMigTokenByToken(token string) (string, error)

	GetDeviceByDeviceID(deviceID string, userID string) *authtypes.Device

	GetDevicesByUserID(userID string) *[]authtypes.Device

	GetPushRuleEnabled(userID, ruleID string) (string, bool)

	GetUserPusherIds(userID string) ([]string, bool)

	GetUserPushRuleIds(userID string) ([]string, bool)

	GetPusherCacheData(pusherKey string) (*pushapitypes.PusherCacheData, bool)

	GetPushRuleCacheData(ruleKey string) (*pushapitypes.PushRuleCacheData, bool)

	GetPushRuleCacheDataByID(userID, ruleID string) (*pushapitypes.PushRuleCacheData, bool)

	GetAccountFilterById(userID, filterID string) (string, bool)

	GetUserRoomTagIds(userID string) ([]string, bool)

	GetRoomTagCacheData(tagKey string) (*authtypes.RoomTagCacheData, bool)

	GetUserAccountDataIds(userID string) ([]string, bool)

	GetAccountDataCacheData(accountDataKey string) (*authtypes.AccountDataCacheData, bool)

	GetUserRoomAccountDataIds(userID string) ([]string, bool)

	GetRoomAccountDataCacheData(roomAccountDataKey string) (*authtypes.RoomAccountDataCacheData, bool)

	GetProfileLessByUserID(userID string) (string, string, bool)
	GetProfileByUserID(userID string) *authtypes.Profile
	GetDisplayNameByUser(userID string) (string, bool)
	GetAvatarURLByUser(userID string) (string, bool)

	GetRoomTagIds(userID, roomID string) ([]string, bool)

	GetDeviceKeyIDs(userID, deviceID string) ([]string, bool)

	GetDeviceKey(keyID string) (*types.KeyHolder, bool)

	GetOneTimeKeyIDs(userID, deviceID string) ([]string, bool)

	GetOneTimeKey(keyID string) (*types.KeyHolder, bool)

	GetDeviceAlgorithm(userID, deviceID string) (*types.AlHolder, bool)

	DeleteDeviceOneTimeKey(userID, deviceID string) error

	DeleteDeviceKey(userID, deviceID string) error

	DeleteOneTimeKey(deviceID, userID, keyID, algorithm string) error

	SetDeviceAlgorithm(userID, deviceID, algorithm string) error

	SetDeviceKey(userID, deviceID, keyInfo, algorithm, signature string) error

	SetOneTimeKey(userID, deviceID, keyID, keyInfo, algorithm, signature string) error

	GetRoomUnreadCount(userID, roomID string) (int64, int64, error)

	GetPresences(userID string) (*authtypes.Presences, bool)
	SetPresences(userID, status, statusMsg, extStatusMsg string) error
	SetPresencesServerStatus(userID, serverStatus string) error

	SetAccountData(userID, roomID, acctType, content string) error

	GetRoomOffsets(roomNID int64) (map[string]int64, error)

	SetRoomUnreadCount(userID, roomID string, notifyCount, hlCount int64) error

	SetProfile(userID, displayName, avatar string) error
	ExpireProfile(userID string) error
	SetDisplayName(userID, displayName string) error
	SetAvatar(userID, avatar string) error

	DelProfile(userID string) error
	DelAvatar(userID string) error
	DelDisplayName(userID string) error

	SetPwdChangeDevcie(deviceID, userID string) error
	CheckPwdChangeDevice(deviceID, userID string) bool
	DelPwdChangeDevice(deviceID, userID string) error
	ExpirePwdChangeDevice(userID string) error

	GetSetting(settingKey string) (int64, error)
	GetSettingRaw(settingKey string) (string, error)
	SetSetting(settingKey string, val string) error

	GetDomains() ([]string, error)
	AddDomain(domain string) error

	GetUserInfoByUserID(userID string) (result *authtypes.UserInfo)
	SetUserInfo(userID, userName, jobNumber, mobile, landline, email string, state int) error
	DeleteUserInfo(userID string) error

	//direct call base
	HScan(key, match string, cursor uint64, count int) (result map[string]interface{}, next uint64, err error)
	HDelMulti(key string, fields []interface{}) error

	//alias
	AliasExists(key string) (bool, error)
	SetAlias(key, val string, expire int64) error
	GetAlias(key string) (string, error)
	DelAlias(key string) error

	//txn
	GetTxnID(roomID, msgID string) (string, bool)
	PutTxnID(roomID, txnID, eventID string) error
	ScanTxnID(cursor uint64, count int) ([]string, uint64, error)

	//roomusermembership
	SetUserRoomMemberShip(roomID, userID string, mType int64) error
	GetUserRoomMemberShip(userID string) (map[string]int64, error)
	CheckUserRoomMemberShipExists(userID string) (bool, error)
	SetUserRoomMemberShipMulti(userID string, memberships map[string]int64) error

	//roomstate
	SetRoomState(roomID string, state []byte, token string) error
	GetRoomState(roomID string) ([]byte, string, error)
	GetRoomStateExt(roomID string) (*types.RoomStateExt, error)
	UpdateRoomStateExt(roomID string, ext map[string]interface{}) error
	SetRoomStateExt(roomID string, roomstateExt *types.RoomStateExt) error

	//distlock
	Lock(lockKey string, expire, wait int) (lockToken string, err error)
	UnLock(lockKey, token string, force bool) (err error)

	//fed
	GetFakePartition(key string) (int32, error)
	AssignFedSendRecPartition(roomID, domain string, partition int32) error
	UnassignFedSendRecPartition(roomID, domain string) error
	ExpireFedSendRecPartition(roomID, domain string) error
	AddFedPendingRooms(roomIDs []string) error
	DelFedPendingRooms(roomIDs []string) error
	QryFedPendingRooms() ([]string, error)

	IncrFedRoomPending(roomID, domain string, amt int) error
	StoreFedSendRec(roomID, domain, eventID string, sendTimes, pendingSize int32, domainOffset int64) error
	GetFedSendRec(roomID, domain string) (eventID string, sendTimes, pendingSize int32, domainOffset int64, err error)
	IncrFedRoomDomainOffset(roomID, domain, eventID string, domainOffset int64, penddingDecr int32) error
	FreeFedSendRec(roomID, domain string) error

	AssignFedBackfillRecPartition(roomID string, partition int32) error
	UnassignFedBackfillRecPartition(roomID string) error
	ExpireFedBackfillRecPartition(roomID string) error
	QryFedBackfillRooms() ([]string, error)
	StoreFedBackfillRec(roomID string, depth int64, finished bool, finishedDomains string, states string) (loaded bool, err error)
	UpdateFedBackfillRec(roomID string, depth int64, finished bool, finishedDomains string, states string) (updated bool, err error)
	GetFedBackfillRec(roomID string) (depth int64, finished bool, finishedDomains string, states string, err error)

	SetRoomLatestOffset(roomId string, offset int64) error
	GetRoomLatestOffset(roomId string) (int64, error)

	SetToken(userID, device string, utl int64, roomoffsets map[string]int64) error
	GetToken(userID, device string, utl int64) (map[string]int64, error)
	DelTokens(userID, device string, utls []int64) error
	AddTokenUtl(userID, device string, utl int64) error
	GetTokenUtls(userID, device string) (utls []int64, err error)
	GetLastValidToken(userID, device string) (int64, map[string]int64, error)
}

type CacheItem

type CacheItem struct {
	Key    interface{}
	Val    interface{}
	Offset int32
	Repo   int
	Mux    sync.Mutex
	Ref    *CacheItem
}

type LocalCache

type LocalCache interface {
	Register(repoName string) int
	GetRegister(repoName string) int
	GetRegisterReverse(repoName int) string
	Put(repoName int, key, val interface{}) *CacheItem
	Tie(repoName int, key interface{}, ref *CacheItem)
	Get(repoName int, key interface{}) (interface{}, bool)
	Start(cap, duration int)
}