rebalance

Documentation

Index

• func GetAZToAnalyzers(azAnalyzerConns []mysqlmodel.AZAnalyzerConnection, ...) map[string][]*mysqlmodel.Analyzer
• type AZInfo
• type AnalyzerInfo
  • func NewAnalyzerInfo(onlyWeight bool) *AnalyzerInfo
  • func (r *AnalyzerInfo) RebalanceAnalyzerByTraffic(db *mysql.DB, ifCheckout bool, dataDuration int) (*model.VTapRebalanceResult, error)
  • func (r *AnalyzerInfo) RebalanceAnalyzerByTrafficDebug(db *mysql.DB, dataDuration int) (map[string]interface{}, error)
• type ChangeInfo
• type DB
• type DBInfo
  • func (r *DBInfo) Get(db *mysql.DB) error
• type Querier
• type Query
  • func (q *Query) GetAgentDispatcher(orgDB *mysql.DB, domainPrefix string, dataDuration int) (map[string]int64, error)
• type RebalanceData

Functions

func GetAZToAnalyzers

func GetAZToAnalyzers(azAnalyzerConns []mysqlmodel.AZAnalyzerConnection, regionToAZLcuuids map[string][]string,
	ipToAnalyzer map[string]*mysqlmodel.Analyzer) map[string][]*mysqlmodel.Analyzer

Types

type AZInfo

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

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

func (r *AnalyzerInfo) RebalanceAnalyzerByTrafficDebug(db *mysql.DB, dataDuration int) (map[string]interface{}, error)

type ChangeInfo

type ChangeInfo struct {
	OldIP     string
	NewIP     string
	NewWeight float64
}

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
}

func (*DBInfo) Get

func (r *DBInfo) Get(db *mysql.DB) error

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 Query

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

func (*Query) GetAgentDispatcher

func (q *Query) GetAgentDispatcher(orgDB *mysql.DB, domainPrefix string, dataDuration int) (map[string]int64, error)

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"`
}