persist_stat

type AccumType int

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

type PersistStoreStat interface {

	// 对于etcd后端，interval >= 60s，以控制数据量 1day <= 60 * 24 (1440)
	SetPolicy(policy Policy) error

	Emit(tag string, value int64) error

	Last5Min() (map[string]int64, error)

	Last20Min() (map[string]int64, error)

	Last1Hour() (map[string]int64, error)

	Last6Hour() (map[string]int64, error)

	Last1Day() (map[string]int64, error)

	Stat(beginTimestamp, endTimestamp time.Time) (map[string]int64, error)

	Clear(beforeTimeStamp time.Time) error

	// Metrics 返回自启动以来的 metric 统计
	Metrics() map[string]int64
}

type Policy struct {
	AccumTp      AccumType
	Interval     int // second
	PreserveDays int
}