cache

Documentation

Index

• type Cache
  • func NewCache(user *user.User, friend *friend.Friend) *Cache
  • func (c *Cache) BatchGetUserNameAndFaceURL(ctx context.Context, userIDs ...string) (map[string]UserInfo, error)
  • func (c *Cache) GetAllConversations() (conversations []*model_struct.LocalConversation)
  • func (c *Cache) GetAllHasUnreadMessageConversations() (conversations []*model_struct.LocalConversation)
  • func (c *Cache) GetConversation(conversationID string) model_struct.LocalConversation
  • func (c *Cache) GetUserNameAndFaceURL(ctx context.Context, userID string) (faceURL, name string, err error)
  • func (c *Cache) Update(userID, faceURL, nickname string)
  • func (c *Cache) UpdateConversation(conversation model_struct.LocalConversation)
  • func (c *Cache) UpdateConversations(conversations []*model_struct.LocalConversation)
  • func (c *Cache) UpdateStatus(userID string, statusMap *userPb.OnlineStatus)
• type UserInfo

Types

type Cache

type Cache struct {
	SubscriptionStatusMap sync.Map
	// contains filtered or unexported fields
}

func NewCache

func NewCache(user *user.User, friend *friend.Friend) *Cache

func (*Cache) BatchGetUserNameAndFaceURL

func (c *Cache) BatchGetUserNameAndFaceURL(ctx context.Context, userIDs ...string) (map[string]UserInfo, error)

func (*Cache) GetAllConversations

func (c *Cache) GetAllConversations() (conversations []*model_struct.LocalConversation)

func (*Cache) GetAllHasUnreadMessageConversations

func (c *Cache) GetAllHasUnreadMessageConversations() (conversations []*model_struct.LocalConversation)

func (*Cache) GetConversation

func (c *Cache) GetConversation(conversationID string) model_struct.LocalConversation

func (*Cache) GetUserNameAndFaceURL

func (c *Cache) GetUserNameAndFaceURL(ctx context.Context, userID string) (faceURL, name string, err error)

func (*Cache) Update

func (c *Cache) Update(userID, faceURL, nickname string)

func (*Cache) UpdateConversation

func (c *Cache) UpdateConversation(conversation model_struct.LocalConversation)

func (*Cache) UpdateConversations

func (c *Cache) UpdateConversations(conversations []*model_struct.LocalConversation)

func (*Cache) UpdateStatus

func (c *Cache) UpdateStatus(userID string, statusMap *userPb.OnlineStatus)

type UserInfo

type UserInfo struct {
	Nickname string
	FaceURL  string
}