cache

type NoteCache ¶

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

Note cache stat representation states:

sorted set: {{list.0, score0}, {list.1, score1}, {list.2, score2}}

list:

list.0: [{"nid": "xxx", "inc": 1}, {"nid": "xxx", "inc": 1}]
list.1: [{"nid": "xxx", "inc": -1}, {"nid": "xxx", "inc": -1}]
list.2: [{"nid": "xxx", "inc": 1}, {"nid": "xxx", "inc": -1}]

func NewNoteCache(numOfList uint32) *NoteCache

func (b *NoteCache) Add(ctx context.Context,
	statType NoteInteractStatType, stat NoteStatRepr) error

func (b *NoteCache) ConsumeCommentCount(ctx context.Context, want int) ([]NoteStatRepr, error)

func (b *NoteCache) ConsumeLikeCount(ctx context.Context, want int) ([]NoteStatRepr, error)

type NoteInteractStatType ¶

type NoteInteractStatType string

const (
	NoteLikeCountStat    NoteInteractStatType = "note_like"
	NoteCommentCountStat NoteInteractStatType = "note_comment"
)

type NoteStatRepr ¶

type NoteStatRepr struct {
	Type   NoteInteractStatType `json:"-"`
	NoteId string               `json:"nid"` // note_id
	Inc    int64                `json:"inc"` // increment
}