metric

type Cluster struct {
	ClusterId uint64

	Item *ClusterItem

	DbCache      *DbItemCache
	MacCache     *MacItemCache
	ProcessCache *ProcessItemCache

	LastReportTime time.Time
}

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

type ClusterItem struct {
	ClusterId          uint64  `json:"cluster_id"`
	CapacityTotal      uint64  `json:"capacity_total"`
	SizeUsed           uint64  `json:"size_used"`
	RangeNum           uint64  `json:"range_num"`
	DbNum              uint64  `json:"db_num"`
	TableNum           uint64  `json:"table_num"`
	TaskNum            uint64  `json:"task_num"`
	NodeUpCount        uint64  `json:"node_up_count,omitempty"`
	NodeDownCount      uint64  `json:"node_down_count,omitempty"`
	NodeOfflineCount   uint64  `json:"node_offline_count,omitempty"`
	NodeTombstoneCount uint64  `json:"node_tombstone_count,omitempty"`
	LeaderBalanceRatio float64 `json:"leader_balance_ratio,omitempty"`
	RegionBalanceRatio float64 `json:"region_balance_ratio,omitempty"`
	GsNum              uint64  `json:"gs_num"`

	Tps uint64 `json:"tps"`
	// 客户端请求最小延时
	Min float64 `json:"min"`
	// 客户端请求最大延时
	Max float64 `json:"max"`
	// 平均延时
	Avg float64 `json:"avg"`
	// TP ...
	TP50        float64 `json:"tp50"`
	TP90        float64 `json:"tp90"`
	TP99        float64 `json:"tp99"`
	TP999       float64 `json:"tp999"`
	TotalNumber uint64  `json:"total_number"`
	ErrNumber   uint64  `json:"err_number"`

	// 默认保留1000条 ??
	SlowLog []string `json:"slow_log"`

	// GS 出入口网络统计
	NetIoInBytePerSec       uint64 `json:"net_io_in_byte_per_sec"`
	NetIoOutBytePerSec      uint64 `json:"net_io_out_byte_per_sec"`
	NetIoInPackagePerSec    uint64 `json:"net_io_in_package_per_sec"`
	NetIoOutPackagePerSec   uint64 `json:"net_io_out_package_per_sec"`
	NetTcpConnections       uint32 `json:"net_tcp_connections"`
	NetTcpActiveOpensPerSec uint32 `json:"net_tcp_activeopens_per_sec"`

	// 更新时间
	UpdateTime int64 `json:"-"`
}

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

type DbItem struct {
	DbName     string `json:"name"`
	TableNum   uint32 `json:"table_num"`
	Size       uint64 `json:"size"`
	UpdateTime int64  `json:"-"`

	TableCache *TableItemCache `json:"-"`
}

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

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

type MacItem struct {
	Type string
	// Ip 地址
	Ip string

	UpdateTime int64

	Item *statspb.MacStats
}

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

type Message struct {
	// 集群
	ClusterId uint64
	// 系统
	Namespace string
	// 子系统
	Subsystem string
	// MsgId
	MsgId string
	// item
	Items interface{}
}

type Metric struct {
	AlarmCli  *alarm.Client
	Threshold ThresholdConfig
	// contains filtered or unexported fields
}

type NodeThreshold struct {
	CapacityUsedRate uint64 `toml:"capacity-used-rate" json:"capacity-used-rate"` // capacity/used_city in node stats
	WriteBps         uint64 `toml:"write-bps" json:"write-bps"`
	WriteOps         uint64 `toml:"write-ops" json:"write-ops"`
	ReadBps          uint64 `toml:"read-bps" json:"read-bps"`
	ReadOps          uint64 `toml:"read-ops" json:"read-ops"`
}

type ProcessItem struct {
	// 类型: MS, DS, GS
	Type string
	// 地址
	Addr string

	UpdateTime int64

	Item *statspb.ProcessStats

	SlowLog *statspb.SlowLogStats
}

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

type RangeThreshold struct {
	WriteBps uint64 `toml:"write-bps" json:"write-bps"`
	WriteOps uint64 `toml:"write-ops" json:"write-ops"`
	ReadBps  uint64 `toml:"read-bps" json:"read-bps"`
	ReadOps  uint64 `toml:"read-ops" json:"read-ops"`
}

type SlowLogItem struct {
	// 类型: MS, DS, GS
	Type string
	// 地址
	Addr string

	UpdateTime int64

	Item *statspb.SlowLogStats
}

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

type Store interface {
	Open() error
	Put(message *Message) error
	Close()
}

type TableItem struct {
	DbName     string `json:"db_name"`
	TableName  string `json:"table_name"`
	RangeNum   uint64 `json:"range_num"`
	Size       uint64 `json:"size"`
	UpdateTime int64  `json:"-"`
}

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

type TaskItem struct {
	UpdateTime int64
	*statspb.TaskInfo
}

type ThresholdConfig struct {
	Node  NodeThreshold  `toml:"node-threshold" json:"node-threshold"`
	Range RangeThreshold `toml:"range-threshold" json:"range-threshold"`
}