persist_stat

Documentation

Index

• type AccumType
• type MemMetrics
  • func NewMemMetrics() *MemMetrics
  • func (m *MemMetrics) EmitMetric(tag string, value int64)
  • func (m *MemMetrics) GetMetrics() map[string]int64
• type PersistStoreStat
• type Policy

Types

type AccumType

type AccumType int

const (
	SUM AccumType = iota
	AVG
)

type MemMetrics

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

func NewMemMetrics

func NewMemMetrics() *MemMetrics

func (*MemMetrics) EmitMetric

func (m *MemMetrics) EmitMetric(tag string, value int64)

func (*MemMetrics) GetMetrics

func (m *MemMetrics) GetMetrics() map[string]int64

type PersistStoreStat

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

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