aggregate

type ClusterStats struct {
	Timestamp time.Time

	Stats map[string]float64
}

type HookAfterTableDropped func(appID int)

type HookAfterTableStatEmitted func(stats []TableStats, allStats ClusterStats)

type NodeStat struct {
	// Address of the replica node.
	Addr string

	// perfCounter's name -> the value.
	Stats map[string]float64
}

type PartitionStats struct {
	Gpid base.Gpid

	// Address of the primary where this partition locates.
	Addr string

	// perfCounter's name -> the value.
	Stats map[string]float64
}

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

type PerfCounter struct {
	Name  string
	Value float64
}

type PerfSession struct {
	session.NodeSession

	Address string
}

type TableStats struct {
	TableName string
	AppID     int

	Partitions map[int]*PartitionStats

	// the time when the stats was generated
	Timestamp time.Time

	// The aggregated value of table metrics.
	// perfCounter's name -> the value.
	Stats map[string]float64
}

type TableStatsAggregator interface {
	Aggregate() (map[int32]*TableStats, *ClusterStats, error)

	Close()
}