judge

Documentation

Index

• Variables
• func InitHistoryBigMap()
• func Judge(L *SafeLinkedList, item *dataobj.ItemStatus, now int64)
• type HistoryData
• type SafeItemMap
  • func NewSafeItemMap() *SafeItemMap
  • func (this *SafeItemMap) BatchDelete(keys []string)
  • func (this *SafeItemMap) CleanStale(before int64)
  • func (this *SafeItemMap) Delete(key string)
  • func (this *SafeItemMap) Get(key string) (*SafeLinkedList, bool)
  • func (this *SafeItemMap) Len() int
  • func (this *SafeItemMap) PushFrontAndMaintain(key string, val *dataobj.ItemStatus, maxCount int, now int64)
  • func (this *SafeItemMap) Set(key string, val *SafeLinkedList)
• type SafeLinkedList
  • func (this *SafeLinkedList) Front() *list.Element
  • func (this *SafeLinkedList) HistoryData(limit int) ([]*HistoryData, bool)
  • func (this *SafeLinkedList) Len() int
  • func (this *SafeLinkedList) PushFrontAndMaintain(v *dataobj.ItemStatus, maxCount int) bool

Variables

var HistoryBigMap = make(map[string]*SafeItemMap)

Functions

func InitHistoryBigMap

func InitHistoryBigMap()

func Judge

func Judge(L *SafeLinkedList, item *dataobj.ItemStatus, now int64)

Types

type HistoryData

type HistoryData struct {
	Timestamp int64 `json:"timestamp"`
	Value     int64 `json:"value"`
}

type SafeItemMap

type SafeItemMap struct {
	sync.RWMutex
	M map[string]*SafeLinkedList
}

func NewSafeItemMap

func NewSafeItemMap() *SafeItemMap

func (*SafeItemMap) BatchDelete

func (this *SafeItemMap) BatchDelete(keys []string)

func (*SafeItemMap) CleanStale

func (this *SafeItemMap) CleanStale(before int64)

func (*SafeItemMap) Delete

func (this *SafeItemMap) Delete(key string)

func (*SafeItemMap) Get

func (this *SafeItemMap) Get(key string) (*SafeLinkedList, bool)

func (*SafeItemMap) Len

func (this *SafeItemMap) Len() int

func (*SafeItemMap) PushFrontAndMaintain

func (this *SafeItemMap) PushFrontAndMaintain(key string, val *dataobj.ItemStatus, maxCount int, now int64)

func (*SafeItemMap) Set

func (this *SafeItemMap) Set(key string, val *SafeLinkedList)

type SafeLinkedList

type SafeLinkedList struct {
	sync.RWMutex
	L *list.List
}

func (*SafeLinkedList) Front

func (this *SafeLinkedList) Front() *list.Element

func (*SafeLinkedList) HistoryData

func (this *SafeLinkedList) HistoryData(limit int) ([]*HistoryData, bool)

func (*SafeLinkedList) Len

func (this *SafeLinkedList) Len() int

func (*SafeLinkedList) PushFrontAndMaintain

func (this *SafeLinkedList) PushFrontAndMaintain(v *dataobj.ItemStatus, maxCount int) bool