Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redis

package

Go to main page

Versions in this module

v3

v3.8.1-rc.3

Sep 23, 2024

v3.8.1-rc.2

Sep 19, 2024

v3.8.1-rc.1

Sep 5, 2024

v3.8.0

Aug 2, 2024

Changes in this version

+ func DeleteCacheBySlot(ctx context.Context, rcClient *rockscache.Client, keys []string) error

+ func GetRocksCacheOptions() *rockscache.Options

+ func LuaDeleteBatch(ctx context.Context, rdb redis.Scripter, keys []string) error

+ func LuaGetBatch(ctx context.Context, rdb redis.Scripter, keys []string) ([]any, error)

+ func LuaSetBatchWithCommonExpire(ctx context.Context, rdb redis.Scripter, keys []string, values []string, ...) error

+ func LuaSetBatchWithIndividualExpire(ctx context.Context, rdb redis.Scripter, keys []string, values []string, ...) error

+ func NewBlackCacheRedis(rdb redis.UniversalClient, localCache *config.LocalCache, ...) cache.BlackCache

+ func NewConversationRedis(rdb redis.UniversalClient, localCache *config.LocalCache, ...) cache.ConversationCache

+ func NewFriendCacheRedis(rdb redis.UniversalClient, localCache *config.LocalCache, ...) cache.FriendCache

+ func NewGroupCacheRedis(rdb redis.UniversalClient, localCache *config.LocalCache, ...) cache.GroupCache

+ func NewMinioCache(rdb redis.UniversalClient) minio.Cache

+ func NewMsgCache(client redis.UniversalClient) cache.MsgCache

+ func NewObjectCacheRedis(rdb redis.UniversalClient, objDB database.ObjectInfo) cache.ObjectCache

+ func NewS3Cache(rdb redis.UniversalClient, s3 s3.Interface) cont.S3Cache

+ func NewSeqConversationCacheRedis(rdb redis.UniversalClient, mgo database.SeqConversation) cache.SeqConversationCache

+ func NewSeqUserCacheRedis(rdb redis.UniversalClient, mgo database.SeqUser) cache.SeqUser

+ func NewThirdCache(rdb redis.UniversalClient) cache.ThirdCache

+ func NewTokenCacheModel(rdb redis.UniversalClient, accessExpire int64) cache.TokenModel

+ func NewUserCacheRedis(rdb redis.UniversalClient, localCache *config.LocalCache, userDB database.User, ...) cache.UserCache

+ func NewUserOnline(rdb redis.UniversalClient) cache.OnlineCache

+ func ProcessKeysBySlot(ctx context.Context, redisClient redis.UniversalClient, keys []string, ...) error

+ type BatchCacheCallback interface

+ BatchCache func(id K)

+ type BatchDeleterRedis struct

+ func NewBatchDeleterRedis(redisClient redis.UniversalClient, options *rockscache.Options, ...) *BatchDeleterRedis

+ func (c *BatchDeleterRedis) AddKeys(keys ...string)

+ func (c *BatchDeleterRedis) ChainExecDel(ctx context.Context) error

+ func (c *BatchDeleterRedis) Clone() cache.BatchDeleter

+ func (c *BatchDeleterRedis) ExecDelWithKeys(ctx context.Context, keys []string) error

+ type BlackCacheRedis struct

+ func (b *BlackCacheRedis) CloneBlackCache() cache.BlackCache

+ func (b *BlackCacheRedis) DelBlackIDs(_ context.Context, userID string) cache.BlackCache

+ func (b *BlackCacheRedis) GetBlackIDs(ctx context.Context, userID string) (blackIDs []string, err error)

+ type Config struct

+ type ConversationRedisCache struct

+ func (c *ConversationRedisCache) CloneConversationCache() cache.ConversationCache

+ func (c *ConversationRedisCache) DelConversationIDs(userIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelConversationNotReceiveMessageUserIDs(conversationIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelConversationVersionUserIDs(userIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelConversations(ownerUserID string, conversationIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelSuperGroupRecvMsgNotNotifyUserIDs(groupID string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelSuperGroupRecvMsgNotNotifyUserIDsHash(groupID string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelUserAllHasReadSeqs(ownerUserID string, conversationIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelUserConversationIDsHash(ownerUserIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelUserRecvMsgOpt(ownerUserID, conversationID string) cache.ConversationCache

+ func (c *ConversationRedisCache) DelUsersConversation(conversationID string, ownerUserIDs ...string) cache.ConversationCache

+ func (c *ConversationRedisCache) FindMaxConversationUserVersion(ctx context.Context, userID string) (*model.VersionLog, error)

+ func (c *ConversationRedisCache) GetConversation(ctx context.Context, ownerUserID, conversationID string) (*model.Conversation, error)

+ func (c *ConversationRedisCache) GetConversationNotReceiveMessageUserIDs(ctx context.Context, conversationID string) ([]string, error)

+ func (c *ConversationRedisCache) GetConversations(ctx context.Context, ownerUserID string, conversationIDs []string) ([]*model.Conversation, error)

+ func (c *ConversationRedisCache) GetUserAllConversations(ctx context.Context, ownerUserID string) ([]*model.Conversation, error)

+ func (c *ConversationRedisCache) GetUserConversationIDs(ctx context.Context, ownerUserID string) ([]string, error)

+ func (c *ConversationRedisCache) GetUserConversationIDsHash(ctx context.Context, ownerUserID string) (hash uint64, err error)

+ func (c *ConversationRedisCache) GetUserRecvMsgOpt(ctx context.Context, ownerUserID, conversationID string) (opt int, err error)

+ type FriendCacheRedis struct

+ func (f *FriendCacheRedis) CloneFriendCache() cache.FriendCache

+ func (f *FriendCacheRedis) DelFriend(ownerUserID, friendUserID string) cache.FriendCache

+ func (f *FriendCacheRedis) DelFriendIDs(ownerUserIDs ...string) cache.FriendCache

+ func (f *FriendCacheRedis) DelFriends(ownerUserID string, friendUserIDs []string) cache.FriendCache

+ func (f *FriendCacheRedis) DelMaxFriendVersion(ownerUserIDs ...string) cache.FriendCache

+ func (f *FriendCacheRedis) DelOwner(friendUserID string, ownerUserIDs []string) cache.FriendCache

+ func (f *FriendCacheRedis) DelTwoWayFriendIDs(ctx context.Context, ownerUserID string) cache.FriendCache

+ func (f *FriendCacheRedis) FindMaxFriendVersion(ctx context.Context, ownerUserID string) (*model.VersionLog, error)

+ func (f *FriendCacheRedis) GetFriend(ctx context.Context, ownerUserID, friendUserID string) (friend *model.Friend, err error)

+ func (f *FriendCacheRedis) GetFriendIDs(ctx context.Context, ownerUserID string) (friendIDs []string, err error)

+ func (f *FriendCacheRedis) GetTwoWayFriendIDs(ctx context.Context, ownerUserID string) (twoWayFriendIDs []string, err error)

+ type GroupCacheRedis struct

+ func (g *GroupCacheRedis) BatchFindMaxGroupMemberVersion(ctx context.Context, groupIDs []string) ([]*model.VersionLog, error)

+ func (g *GroupCacheRedis) CloneGroupCache() cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupAllRoleLevel(groupID string) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupMemberIDs(groupID string) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupMembersHash(groupID string) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupMembersInfo(groupID string, userIDs ...string) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupRoleLevel(groupID string, roleLevels []int32) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupsInfo(groupIDs ...string) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupsMemberNum(groupID ...string) cache.GroupCache

+ func (g *GroupCacheRedis) DelGroupsOwner(groupIDs ...string) cache.GroupCache

+ func (g *GroupCacheRedis) DelJoinedGroupID(userIDs ...string) cache.GroupCache

+ func (g *GroupCacheRedis) DelMaxGroupMemberVersion(groupIDs ...string) cache.GroupCache

+ func (g *GroupCacheRedis) DelMaxJoinGroupVersion(userIDs ...string) cache.GroupCache

+ func (g *GroupCacheRedis) FindGroupMemberUser(ctx context.Context, groupIDs []string, userID string) ([]*model.GroupMember, error)

+ func (g *GroupCacheRedis) FindMaxGroupMemberVersion(ctx context.Context, groupID string) (*model.VersionLog, error)

+ func (g *GroupCacheRedis) FindMaxJoinGroupVersion(ctx context.Context, userID string) (*model.VersionLog, error)

+ func (g *GroupCacheRedis) GetAllGroupMembersInfo(ctx context.Context, groupID string) (groupMembers []*model.GroupMember, err error)

+ func (g *GroupCacheRedis) GetGroupInfo(ctx context.Context, groupID string) (group *model.Group, err error)

+ func (g *GroupCacheRedis) GetGroupMemberHashMap(ctx context.Context, groupIDs []string) (map[string]*common.GroupSimpleUserID, error)

+ func (g *GroupCacheRedis) GetGroupMemberIDs(ctx context.Context, groupID string) (groupMemberIDs []string, err error)

+ func (g *GroupCacheRedis) GetGroupMemberInfo(ctx context.Context, groupID, userID string) (groupMember *model.GroupMember, err error)

+ func (g *GroupCacheRedis) GetGroupMemberNum(ctx context.Context, groupID string) (memberNum int64, err error)

+ func (g *GroupCacheRedis) GetGroupMembersHash(ctx context.Context, groupID string) (hashCode uint64, err error)

+ func (g *GroupCacheRedis) GetGroupMembersInfo(ctx context.Context, groupID string, userIDs []string) ([]*model.GroupMember, error)

+ func (g *GroupCacheRedis) GetGroupOwner(ctx context.Context, groupID string) (*model.GroupMember, error)

+ func (g *GroupCacheRedis) GetGroupRoleLevelMemberIDs(ctx context.Context, groupID string, roleLevel int32) ([]string, error)

+ func (g *GroupCacheRedis) GetGroupRoleLevelMemberInfo(ctx context.Context, groupID string, roleLevel int32) ([]*model.GroupMember, error)

+ func (g *GroupCacheRedis) GetGroupRolesLevelMemberInfo(ctx context.Context, groupID string, roleLevels []int32) ([]*model.GroupMember, error)

+ func (g *GroupCacheRedis) GetGroupsInfo(ctx context.Context, groupIDs []string) (groups []*model.Group, err error)

+ func (g *GroupCacheRedis) GetGroupsOwner(ctx context.Context, groupIDs []string) ([]*model.GroupMember, error)

+ func (g *GroupCacheRedis) GetJoinedGroupIDs(ctx context.Context, userID string) (joinedGroupIDs []string, err error)

+ type Option func(c *Config)

+ func WithBatchSize(size int) Option

+ func WithConcurrentLimit(limit int) Option

+ func WithContinueOnError(continueOnError bool) Option

+ type RedisShardManager struct

+ func NewRedisShardManager(redisClient redis.UniversalClient, opts ...Option) *RedisShardManager

+ func (rsm *RedisShardManager) ProcessKeysBySlot(ctx context.Context, keys []string, ...) error

+ type UserCacheRedis struct

+ func (u *UserCacheRedis) CloneUserCache() cache.UserCache

+ func (u *UserCacheRedis) DelUsersGlobalRecvMsgOpt(userIDs ...string) cache.UserCache

+ func (u *UserCacheRedis) DelUsersInfo(userIDs ...string) cache.UserCache

+ func (u *UserCacheRedis) GetUserGlobalRecvMsgOpt(ctx context.Context, userID string) (opt int, err error)

+ func (u *UserCacheRedis) GetUserInfo(ctx context.Context, userID string) (userInfo *model.User, err error)

+ func (u *UserCacheRedis) GetUsersInfo(ctx context.Context, userIDs []string) ([]*model.User, error)

v3.8.0-rc.1

Jul 26, 2024

v3.8.0-rc.0

Jul 25, 2024