hotkeymgr

package

v0.0.0-...-b133f75 Latest Latest Go to latest Published: Dec 20, 2024 License: MIT Imports: 4 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type HotKey struct {
	Key   string
	Count int64
}

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

func NewHotKeyMgr(size int, duration time.Duration) *HotKeyMgr

func (hkm *HotKeyMgr) AddRequest(key string)

func (hkm *HotKeyMgr) GetHotKeyCache() map[string]int64

func (hkm *HotKeyMgr) GetHotKeyFromCache(key string) (int64, bool)

func (hkm *HotKeyMgr) MergeBucketsToHeap()

func (hkm *HotKeyMgr) Start(topK, threshold int, duration time.Duration)

func (hkm *HotKeyMgr) UpdateTopK(topK int, threshold int64)

type MaxHeap []HotKey

func NewMaxHeap() *MaxHeap

func (h MaxHeap) Len() int

func (h MaxHeap) Less(i, j int) bool

func (h *MaxHeap) Pop() interface{}

func (h *MaxHeap) Push(x interface{})

func (h MaxHeap) Swap(i, j int)

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

func NewSliderWindow(size int, windowsDuration time.Duration) *SliderWindow

func (sw *SliderWindow) Add(key string)

Add 更新当前时间的桶

func (sw *SliderWindow) GetBucketIndex(currentTime int64) int

func (sw *SliderWindow) MergeBucketsToHeap(h *MaxHeap)

MergeBucketsToHeap 将所有桶中的商品数据合并到大顶堆中