ubcache

Documentation

Index

• type TimeSeq
  • func (seq *TimeSeq) Filter(maxTs int64, maxLen int64) *TimeSeq
• type UserBehavior
• type UserBehaviorCache
  • func NewUserBehaviorCache() *UserBehaviorCache
  • func (c *UserBehaviorCache) BatchSet(ub UserBehavior)
  • func (c *UserBehaviorCache) Clear()
  • func (c *UserBehaviorCache) Delete(userId int64)
  • func (c *UserBehaviorCache) Get(userId int64, maxTs int64, count int64) (seq *TimeSeq, err error)
  • func (c *UserBehaviorCache) Set(userId int64, seq *TimeSeq)

Types

type TimeSeq

type TimeSeq struct {
	Ts    []int64
	Items []int64
}

TimeSeq is a sequence in Ts desc order

func (*TimeSeq) Filter

func (seq *TimeSeq) Filter(maxTs int64, maxLen int64) *TimeSeq

Filter sequence by maxTs and maxLen

type UserBehavior

type UserBehavior map[int64]*TimeSeq //map[userId]*TimeSeq

type UserBehaviorCache

type UserBehaviorCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewUserBehaviorCache

func NewUserBehaviorCache() *UserBehaviorCache

func (*UserBehaviorCache) BatchSet

func (c *UserBehaviorCache) BatchSet(ub UserBehavior)

BatchSet batch set user behavior sequence

func (*UserBehaviorCache) Clear

func (c *UserBehaviorCache) Clear()

Clear all user behavior sequence

func (*UserBehaviorCache) Delete

func (c *UserBehaviorCache) Delete(userId int64)

Delete user behavior sequence by userId

func (*UserBehaviorCache) Get

func (c *UserBehaviorCache) Get(userId int64, maxTs int64, count int64) (seq *TimeSeq, err error)

Get user behavior sequence by userId and filtered by maxTs and count

func (*UserBehaviorCache) Set

func (c *UserBehaviorCache) Set(userId int64, seq *TimeSeq)

Set user behavior sequence by userId