cache

package
v0.0.0-...-9835270 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ROOM_STATE_PREFIX     = "room_state"
	ROOM_STATE_EXT_PREFIX = "room_state_ext"
	EXT_DOMAIN_PROFIX     = "domain:"
)
View Source 
const (
	TXN_DURATION = 30
)

Variables

This section is empty.

Functions

func Bool 

func Bool(reply interface{}, err error) (bool, error)

func Int64 

func Int64(reply interface{}, err error) (int64, error)

func String 

func String(reply interface{}, err error) (string, error)

Types

type DeviceInfo 

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

type LocalCacheRepo 

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

func (*LocalCacheRepo) Get 

func (lc *LocalCacheRepo) Get(repoName int, key interface{}) (interface{}, bool)

func (*LocalCacheRepo) GetRegister 

func (lc *LocalCacheRepo) GetRegister(repoName string) int

func (*LocalCacheRepo) GetRegisterReverse 

func (lc *LocalCacheRepo) GetRegisterReverse(repoName int) string

func (*LocalCacheRepo) Put 

func (lc *LocalCacheRepo) Put(repoName int, key, val interface{}) *service.CacheItem

func (*LocalCacheRepo) Register 

func (lc *LocalCacheRepo) Register(repoName string) int

func (*LocalCacheRepo) Start 

func (lc *LocalCacheRepo) Start(cap, duration int)

func (*LocalCacheRepo) Tie 

func (lc *LocalCacheRepo) Tie(repoName int, key interface{}, ref *service.CacheItem)

type RedisCache 

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

func (*RedisCache) AddDomain 

func (rc *RedisCache) AddDomain(domain string) error

func (*RedisCache) AddFedBackfillRooms 

func (rc *RedisCache) AddFedBackfillRooms(keys []string) error

func (*RedisCache) AddFedPendingRooms 

func (rc *RedisCache) AddFedPendingRooms(keys []string) error

func (*RedisCache) AddTokenUtl 

func (rc *RedisCache) AddTokenUtl(userID, device string, utl int64) error

func (*RedisCache) AliasExists 

func (rc *RedisCache) AliasExists(key string) (bool, error)

func (*RedisCache) AssignFedBackfillRecPartition 

func (rc *RedisCache) AssignFedBackfillRecPartition(roomID string, partition int32) error

func (*RedisCache) AssignFedSendRecPartition 

func (rc *RedisCache) AssignFedSendRecPartition(roomID, domain string, partition int32) error

func (*RedisCache) CheckPwdChangeDevice 

func (rc *RedisCache) CheckPwdChangeDevice(deviceID, userID string) bool

func (*RedisCache) CheckUserRoomMemberShipExists 

func (rc *RedisCache) CheckUserRoomMemberShipExists(userID string) (bool, error)

func (*RedisCache) Del 

func (rc *RedisCache) Del(key string) error

common

func (*RedisCache) DelAlias 

func (rc *RedisCache) DelAlias(key string) error

func (*RedisCache) DelAvatar 

func (rc *RedisCache) DelAvatar(userID string) error

func (*RedisCache) DelDisplayName 

func (rc *RedisCache) DelDisplayName(userID string) error

func (*RedisCache) DelFedBackfillRooms 

func (rc *RedisCache) DelFedBackfillRooms(roomIDs []string) error

func (*RedisCache) DelFedPendingRooms 

func (rc *RedisCache) DelFedPendingRooms(keys []string) error

func (*RedisCache) DelProfile 

func (rc *RedisCache) DelProfile(userID string) error

func (*RedisCache) DelPwdChangeDevice 

func (rc *RedisCache) DelPwdChangeDevice(deviceID, userID string) error

func (*RedisCache) DelTokens 

func (rc *RedisCache) DelTokens(userID, device string, utls []int64) error

func (*RedisCache) DeleteDeviceKey 

func (rc *RedisCache) DeleteDeviceKey(userID, deviceID string) error

func (*RedisCache) DeleteDeviceOneTimeKey 

func (rc *RedisCache) DeleteDeviceOneTimeKey(userID, deviceID string) error

func (*RedisCache) DeleteOneTimeKey 

func (rc *RedisCache) DeleteOneTimeKey(deviceID, userID, keyID, algorithm string) error

func (*RedisCache) DeleteUserInfo 

func (rc *RedisCache) DeleteUserInfo(userID string) error

func (*RedisCache) Exists 

func (rc *RedisCache) Exists(key string) (bool, error)

func (*RedisCache) Expire 

func (c *RedisCache) Expire(key string, expire int64) error

func (*RedisCache) ExpireFedBackfillRecPartition 

func (rc *RedisCache) ExpireFedBackfillRecPartition(roomID string) error

func (*RedisCache) ExpireFedSendRecPartition 

func (rc *RedisCache) ExpireFedSendRecPartition(roomID, domain string) error

func (*RedisCache) ExpireProfile 

func (rc *RedisCache) ExpireProfile(userID string) error

func (*RedisCache) ExpirePwdChangeDevice 

func (rc *RedisCache) ExpirePwdChangeDevice(userID string) error

func (*RedisCache) FreeFedBackfill 

func (rc *RedisCache) FreeFedBackfill(roomID string) error

func (*RedisCache) FreeFedSendRec 

func (rc *RedisCache) FreeFedSendRec(roomID, domain string) error

func (*RedisCache) Get 

func (rc *RedisCache) Get(key string) (interface{}, error)

string

func (*RedisCache) GetAccountDataCacheData 

func (rc *RedisCache) GetAccountDataCacheData(accountDataKey string) (result *authtypes.AccountDataCacheData, ok bool)

func (*RedisCache) GetAccountFilterById 

func (rc *RedisCache) GetAccountFilterById(userID, filterID string) (string, bool)

func (*RedisCache) GetAlias 

func (rc *RedisCache) GetAlias(key string) (string, error)

func (*RedisCache) GetAvatarURLByUser 

func (rc *RedisCache) GetAvatarURLByUser(userID string) (string, bool)

func (*RedisCache) GetDeviceAlgorithm 

func (rc *RedisCache) GetDeviceAlgorithm(userID, deviceID string) (*e2e.AlHolder, bool)

func (*RedisCache) GetDeviceByDeviceID 

func (rc *RedisCache) GetDeviceByDeviceID(deviceID string, userID string) *authtypes.Device

func (*RedisCache) GetDeviceKey 

func (rc *RedisCache) GetDeviceKey(keyID string) (*e2e.KeyHolder, bool)

func (*RedisCache) GetDeviceKeyIDs 

func (rc *RedisCache) GetDeviceKeyIDs(userID, deviceID string) ([]string, bool)

func (*RedisCache) GetDevicesByUserID 

func (rc *RedisCache) GetDevicesByUserID(userID string) *[]authtypes.Device

func (*RedisCache) GetDisplayNameByUser 

func (rc *RedisCache) GetDisplayNameByUser(userID string) (string, bool)

func (*RedisCache) GetDomains 

func (rc *RedisCache) GetDomains() ([]string, error)

func (*RedisCache) GetFakePartition 

func (rc *RedisCache) GetFakePartition(key string) (int32, error)

func (*RedisCache) GetFedBackfillRec 

func (rc *RedisCache) GetFedBackfillRec(roomID string) (depth int64, finished bool, finishedDomains string, states string, err error)

func (*RedisCache) GetFedSendRec 

func (rc *RedisCache) GetFedSendRec(roomID, domain string) (eventID string, sendTimes, pendingSize int32, domainOffset int64, err error)

func (*RedisCache) GetLastValidToken 

func (rc *RedisCache) GetLastValidToken(userID, device string) (int64, map[string]int64, error)

func (*RedisCache) GetMigTokenByToken 

func (rc *RedisCache) GetMigTokenByToken(token string) (string, error)

func (*RedisCache) GetOneTimeKey 

func (rc *RedisCache) GetOneTimeKey(keyID string) (*e2e.KeyHolder, bool)

func (*RedisCache) GetOneTimeKeyIDs 

func (rc *RedisCache) GetOneTimeKeyIDs(userID, deviceID string) ([]string, bool)

func (*RedisCache) GetPresences 

func (rc *RedisCache) GetPresences(userID string) (*authtypes.Presences, bool)

func (*RedisCache) GetProfileByUserID 

func (rc *RedisCache) GetProfileByUserID(userID string) (result *authtypes.Profile)

func (*RedisCache) GetProfileLessByUserID 

func (rc *RedisCache) GetProfileLessByUserID(userID string) (string, string, bool)

func (*RedisCache) GetPushRuleCacheData 

func (rc *RedisCache) GetPushRuleCacheData(ruleKey string) (pushRule *push.PushRuleCacheData, ok bool)

func (*RedisCache) GetPushRuleCacheDataByID 

func (rc *RedisCache) GetPushRuleCacheDataByID(userID, ruleID string) (*push.PushRuleCacheData, bool)

func (*RedisCache) GetPushRuleEnabled 

func (rc *RedisCache) GetPushRuleEnabled(userID, ruleID string) (string, bool)

func (*RedisCache) GetPusherCacheData 

func (rc *RedisCache) GetPusherCacheData(pusherKey string) (pusher *push.PusherCacheData, ok bool)

func (*RedisCache) GetRoomAccountDataCacheData 

func (rc *RedisCache) GetRoomAccountDataCacheData(roomAccountDataKey string) (result *authtypes.RoomAccountDataCacheData, ok bool)

func (*RedisCache) GetRoomLatestOffset 

func (rc *RedisCache) GetRoomLatestOffset(roomId string) (int64, error)

func (*RedisCache) GetRoomOffsets 

func (rc *RedisCache) GetRoomOffsets(roomNID int64) (map[string]int64, error)

func (*RedisCache) GetRoomState 

func (rc *RedisCache) GetRoomState(roomID string) ([]byte, string, error)

func (*RedisCache) GetRoomStateExt 

func (rc *RedisCache) GetRoomStateExt(roomID string) (*types.RoomStateExt, error)

func (*RedisCache) GetRoomTagCacheData 

func (rc *RedisCache) GetRoomTagCacheData(tagKey string) (result *authtypes.RoomTagCacheData, ok bool)

func (*RedisCache) GetRoomTagIds 

func (rc *RedisCache) GetRoomTagIds(userName, roomID string) ([]string, bool)

func (*RedisCache) GetRoomUnreadCount 

func (rc *RedisCache) GetRoomUnreadCount(userID, roomID string) (int64, int64, error)

func (*RedisCache) GetSetting 

func (rc *RedisCache) GetSetting(settingKey string) (int64, error)

func (*RedisCache) GetSettingRaw 

func (rc *RedisCache) GetSettingRaw(settingKey string) (string, error)

func (*RedisCache) GetString 

func (rc *RedisCache) GetString(key string) (string, error)

func (*RedisCache) GetToken 

func (rc *RedisCache) GetToken(userID, device string, utl int64) (map[string]int64, error)

func (*RedisCache) GetTokenUtls 

func (rc *RedisCache) GetTokenUtls(userID, device string) (utls []int64, err error)

func (*RedisCache) GetTxnID 

func (rc *RedisCache) GetTxnID(roomID, msgID string) (string, bool)

func (*RedisCache) GetUserAccountDataIds 

func (rc *RedisCache) GetUserAccountDataIds(userName string) ([]string, bool)

func (*RedisCache) GetUserInfoByUserID 

func (rc *RedisCache) GetUserInfoByUserID(userID string) (result *authtypes.UserInfo)

func (*RedisCache) GetUserPushRuleIds 

func (rc *RedisCache) GetUserPushRuleIds(userID string) ([]string, bool)

func (*RedisCache) GetUserPusherIds 

func (rc *RedisCache) GetUserPusherIds(userID string) ([]string, bool)

func (*RedisCache) GetUserRoomAccountDataIds 

func (rc *RedisCache) GetUserRoomAccountDataIds(userName string) ([]string, bool)

func (*RedisCache) GetUserRoomMemberShip 

func (rc *RedisCache) GetUserRoomMemberShip(userID string) (map[string]int64, error)

func (*RedisCache) GetUserRoomTagIds 

func (rc *RedisCache) GetUserRoomTagIds(userName string) ([]string, bool)

func (*RedisCache) HDel 

func (rc *RedisCache) HDel(key, field string) error

func (*RedisCache) HDelMulti 

func (rc *RedisCache) HDelMulti(key string, fields []interface{}) error

func (*RedisCache) HGet 

func (rc *RedisCache) HGet(key, field string) (interface{}, error)

hset

func (*RedisCache) HGetAll 

func (rc *RedisCache) HGetAll(key string) (map[string]interface{}, error)

func (*RedisCache) HGetString 

func (rc *RedisCache) HGetString(key, field string) (string, error)

func (*RedisCache) HMGet 

func (rc *RedisCache) HMGet(key string, fields []string) ([]interface{}, error)

func (*RedisCache) HMSet 

func (rc *RedisCache) HMSet(key string, val interface{}) (err error)

func (*RedisCache) HScan 

func (rc *RedisCache) HScan(key, match string, cursor uint64, count int) (result map[string]interface{}, next uint64, err error)

func (*RedisCache) HSet 

func (rc *RedisCache) HSet(key, field string, val interface{}) error

func (*RedisCache) IncrFedRoomDomainOffset 

func (rc *RedisCache) IncrFedRoomDomainOffset(roomID, domain, eventID string, domainOffset int64, penddingDecr int32) error

func (*RedisCache) IncrFedRoomPending 

func (rc *RedisCache) IncrFedRoomPending(roomID, domain string, amt int) error

func (*RedisCache) Lock 

func (rc *RedisCache) Lock(lockKey string, expire, wait int) (lockToken string, err error)

func (*RedisCache) Prepare 

func (rc *RedisCache) Prepare(cfg []string) (err error)

func (*RedisCache) PutTxnID 

func (rc *RedisCache) PutTxnID(roomID, txnID, eventID string) error

func (*RedisCache) QryFedBackfillRooms 

func (rc *RedisCache) QryFedBackfillRooms() ([]string, error)

func (*RedisCache) QryFedPendingRooms 

func (rc *RedisCache) QryFedPendingRooms() ([]string, error)

func (*RedisCache) SafeDo 

func (rc *RedisCache) SafeDo(commandName string, args ...interface{}) (reply interface{}, err error)

func (*RedisCache) Scan 

func (rc *RedisCache) Scan(cursor uint64, match string, count int) (result []interface{}, next uint64, err error)

func (*RedisCache) ScanTxnID 

func (rc *RedisCache) ScanTxnID(cursor uint64, count int) ([]string, uint64, error)

func (*RedisCache) Set 

func (rc *RedisCache) Set(key string, val interface{}, expire int64) error

func (*RedisCache) SetAccountData 

func (rc *RedisCache) SetAccountData(userID, roomID, acctType, content string) error

func (*RedisCache) SetAlias 

func (rc *RedisCache) SetAlias(key, val string, expire int64) error

func (*RedisCache) SetAvatar 

func (rc *RedisCache) SetAvatar(userID, avatar string) error

func (*RedisCache) SetDeviceAlgorithm 

func (rc *RedisCache) SetDeviceAlgorithm(userID, deviceID, algorithm string) error

func (*RedisCache) SetDeviceKey 

func (rc *RedisCache) SetDeviceKey(userID, deviceID, keyInfo, algorithm, signature string) error

func (*RedisCache) SetDisplayName 

func (rc *RedisCache) SetDisplayName(userID, displayName string) error

func (*RedisCache) SetOneTimeKey 

func (rc *RedisCache) SetOneTimeKey(userID, deviceID, keyID, keyInfo, algorithm, signature string) error

func (*RedisCache) SetPresences 

func (rc *RedisCache) SetPresences(userID, status, statusMsg, extStatusMsg string) error

func (*RedisCache) SetPresencesServerStatus 

func (rc *RedisCache) SetPresencesServerStatus(userID, serverStatus string) error

func (*RedisCache) SetProfile 

func (rc *RedisCache) SetProfile(userID, displayName, avatar string) error

func (*RedisCache) SetPwdChangeDevcie 

func (rc *RedisCache) SetPwdChangeDevcie(deviceID, userID string) error

func (*RedisCache) SetRoomLatestOffset 

func (rc *RedisCache) SetRoomLatestOffset(roomId string, offset int64) error

func (*RedisCache) SetRoomState 

func (rc *RedisCache) SetRoomState(roomID string, state []byte, token string) error

func (*RedisCache) SetRoomStateExt 

func (rc *RedisCache) SetRoomStateExt(roomID string, roomstateExt *types.RoomStateExt) error

func (*RedisCache) SetRoomUnreadCount 

func (rc *RedisCache) SetRoomUnreadCount(userID, roomID string, notifyCount, hlCount int64) error

func (*RedisCache) SetSetting 

func (rc *RedisCache) SetSetting(settingKey string, val string) error

func (*RedisCache) SetToken 

func (rc *RedisCache) SetToken(userID, device string, utl int64, roomoffsets map[string]int64) error

func (*RedisCache) SetUserInfo 

func (rc *RedisCache) SetUserInfo(userID, userName, jobNumber, mobile, landline, email string, state int) error

func (*RedisCache) SetUserRoomMemberShip 

func (rc *RedisCache) SetUserRoomMemberShip(roomID, userID string, mType int64) error

func (*RedisCache) SetUserRoomMemberShipMulti 

func (rc *RedisCache) SetUserRoomMemberShipMulti(userID string, memberships map[string]int64) error

func (*RedisCache) StoreFedBackfillRec 

func (rc *RedisCache) StoreFedBackfillRec(roomID string, depth int64, finished bool, finishedDomains string, states string) (loaded bool, err error)

func (*RedisCache) StoreFedSendRec 

func (rc *RedisCache) StoreFedSendRec(roomID, domain, eventID string, sendTimes, pendingSize int32, domainOffset int64) error

func (*RedisCache) TTL 

func (rc *RedisCache) TTL(key string) (ttl int64, err error)

func (*RedisCache) UnLock 

func (rc *RedisCache) UnLock(lockKey, token string, force bool) (err error)

func (*RedisCache) UnassignFedBackfillRecPartition 

func (rc *RedisCache) UnassignFedBackfillRecPartition(roomID string) error

func (*RedisCache) UnassignFedSendRecPartition 

func (rc *RedisCache) UnassignFedSendRecPartition(roomID, domain string) error

func (*RedisCache) UpdateFedBackfillRec 

func (rc *RedisCache) UpdateFedBackfillRec(roomID string, depth int64, finished bool, finishedDomains string, states string) (updated bool, err error)

func (*RedisCache) UpdateRoomStateExt 

func (rc *RedisCache) UpdateRoomStateExt(roomID string, ext map[string]interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.