Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAZToAnalyzers ¶
func GetAZToAnalyzers(azAnalyzerConns []mysqlmodel.AZAnalyzerConnection, regionToAZLcuuids map[string][]string, ipToAnalyzer map[string]*mysqlmodel.Analyzer) map[string][]*mysqlmodel.Analyzer
Types ¶
type AnalyzerInfo ¶
type AnalyzerInfo struct {
RebalanceData
// contains filtered or unexported fields
}
func NewAnalyzerInfo ¶
func NewAnalyzerInfo(onlyWeight bool) *AnalyzerInfo
func (*AnalyzerInfo) RebalanceAnalyzerByTraffic ¶
func (r *AnalyzerInfo) RebalanceAnalyzerByTraffic(db *mysql.DB, ifCheckout bool, dataDuration int) (*model.VTapRebalanceResult, error)
func (*AnalyzerInfo) RebalanceAnalyzerByTrafficDebug ¶
type ChangeInfo ¶
type DB ¶
type DB interface {
Get() error
}
//go:generate mockgen -source=analyzer.go -destination=./mocks/mock_analyzer.go -package=mocks DB
type DBInfo ¶
type DBInfo struct {
Regions []mysqlmodel.Region
AZs []mysqlmodel.AZ
Analyzers []mysqlmodel.Analyzer
AZAnalyzerConns []mysqlmodel.AZAnalyzerConnection
VTaps []mysqlmodel.VTap
// get query data
Controllers []mysqlmodel.Controller
AZControllerConns []mysqlmodel.AZControllerConnection
}
type Querier ¶
type Querier interface {
GetAgentDispatcher(db *mysql.DB, domainPrefix string, dataDuration int) (map[string]int64, error)
}
//go:generate mockgen -source=query.go -destination=./mocks/mock_querier.go -package=mocks Querier
type RebalanceData ¶
type RebalanceData struct {
RegionToVTapNameToTraffic map[string]map[string]int64 `json:"RegionToVTapNameToTraffic"`
RegionToAZLcuuids map[string][]string `json:"RegionToAZLcuuids"`
AZToRegion map[string]string `json:"AZToRegion"`
AZToVTaps map[string][]*mysqlmodel.VTap `json:"AZToVTaps"`
AZToAnalyzers map[string][]*mysqlmodel.Analyzer `json:"AZToAnalyzers"`
}
Click to show internal directories.
Click to hide internal directories.