repository

Documentation

Index

• type Rep
  • func NewRep(svcCtx *svc.ServiceContext) *Rep
  • func (r *Rep) CheckDefaultSuperGroup()
  • func (r *Rep) DelTokenMap(ctx context.Context, uid string, platform string) error
  • func (r *Rep) DeleteToken(ctx context.Context, uid string, platform string, token string) error
  • func (r *Rep) FuncDelBlackCache(ctx context.Context, blacklists ...*model.Blacklist) func(tx *gorm.DB) error
  • func (r *Rep) FuncDelFriendCache(ctx context.Context, friends ...*model.Friendlist) func(tx *gorm.DB) error
  • func (r *Rep) FuncDelInsertUserCache(ctx context.Context, user *model.User, group *model.Group) func(tx *gorm.DB) error
  • func (r *Rep) FuncDelUserCache(ctx context.Context, users ...*model.User) func(tx *gorm.DB) error
  • func (r *Rep) FuncJoinGroup(user *model.User, group *model.Group) func(tx *gorm.DB) error
  • func (r *Rep) GetTokenMap(ctx context.Context, uid string, platform string) (map[string]int64, error)
  • func (r *Rep) RenewalToken(ctx context.Context, uid string, platform string, token string) error
  • func (r *Rep) SendGroupTextMsg(ctx context.Context, user *model.User, group *model.Group, text string) error
  • func (r *Rep) SetTokenMap(ctx context.Context, uid string, platform string, token string) error
  • func (r *Rep) WarmUpUser(ctx context.Context, user *model.User)

Types

type Rep

type Rep struct {
	Cache         redis.UniversalClient
	Mysql         *gorm.DB
	DetailCache   *dc.DbMapping
	RelationCache *rc.RelationMapping
	RateLimiter   *limit.PeriodLimit
	// contains filtered or unexported fields
}

func NewRep

func NewRep(svcCtx *svc.ServiceContext) *Rep

func (*Rep) CheckDefaultSuperGroup

func (r *Rep) CheckDefaultSuperGroup()

func (*Rep) DelTokenMap

func (r *Rep) DelTokenMap(ctx context.Context, uid string, platform string) error

func (*Rep) DeleteToken

func (r *Rep) DeleteToken(ctx context.Context, uid string, platform string, token string) error

func (*Rep) FuncDelBlackCache

func (r *Rep) FuncDelBlackCache(ctx context.Context, blacklists ...*model.Blacklist) func(tx *gorm.DB) error

func (*Rep) FuncDelFriendCache

func (r *Rep) FuncDelFriendCache(ctx context.Context, friends ...*model.Friendlist) func(tx *gorm.DB) error

func (*Rep) FuncDelInsertUserCache

func (r *Rep) FuncDelInsertUserCache(ctx context.Context, user *model.User, group *model.Group) func(tx *gorm.DB) error

func (*Rep) FuncDelUserCache

func (r *Rep) FuncDelUserCache(ctx context.Context, users ...*model.User) func(tx *gorm.DB) error

func (*Rep) FuncJoinGroup

func (r *Rep) FuncJoinGroup(user *model.User, group *model.Group) func(tx *gorm.DB) error

func (*Rep) GetTokenMap

func (r *Rep) GetTokenMap(ctx context.Context, uid string, platform string) (map[string]int64, error)

func (*Rep) RenewalToken

func (r *Rep) RenewalToken(ctx context.Context, uid string, platform string, token string) error

func (*Rep) SendGroupTextMsg

func (r *Rep) SendGroupTextMsg(
	ctx context.Context, user *model.User, group *model.Group, text string) error

func (*Rep) SetTokenMap

func (r *Rep) SetTokenMap(ctx context.Context, uid string, platform string, token string) error

func (*Rep) WarmUpUser

func (r *Rep) WarmUpUser(ctx context.Context, user *model.User)