judge

Documentation

Index

• Variables
• func LastTs(key string) int64
• func Start()
• func StartJudgeCron()
• func TurnNodata(key string, ts int64)
• func TurnOk(key string, ts int64)
• type NodataStatus
  • func GetAllNodataStatus() []*NodataStatus
  • func GetNodataStatus(key string) *NodataStatus
  • func NewNodataStatus(key string, status string, cnt int, ts int64) *NodataStatus
  • func (this *NodataStatus) String() string

Variables

var (
	StatusMap = nmap.NewSafeMap()
)

Nodata Status Cache

Functions

func LastTs

func LastTs(key string) int64

func Start

func Start()

func StartJudgeCron

func StartJudgeCron()

func TurnNodata

func TurnNodata(key string, ts int64)

func TurnOk

func TurnOk(key string, ts int64)

Types

type NodataStatus

type NodataStatus struct {
	Key    string
	Status string // OK|NODATA
	Cnt    int
	Ts     int64
}

Nodata Status Struct

func GetAllNodataStatus

func GetAllNodataStatus() []*NodataStatus

func GetNodataStatus

func GetNodataStatus(key string) *NodataStatus

func NewNodataStatus

func NewNodataStatus(key string, status string, cnt int, ts int64) *NodataStatus

func (*NodataStatus) String

func (this *NodataStatus) String() string