diagnose

package
v0.0.0-...-68360ed Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Category names.
	CategoryHeader   = "header"
	CategoryDiagnose = "diagnose"
	CategoryLoad     = "load"
	CategoryOverview = "overview"
	CategoryTiDB     = "TiDB"
	CategoryPD       = "PD"
	CategoryTiKV     = "TiKV"
	CategoryConfig   = "config"
	CategoryError    = "error"
)

Variables

This section is empty.

Functions

func CompareDiagnose 

func CompareDiagnose(referStartTime, referEndTime, startTime, endTime string, db *gorm.DB) (TableDef, *TableRowDef)

func CompareTables 

func CompareTables(tables1, tables2 []*TableDef) ([]*TableDef, []TableRowDef)

func GetReportEndTables 

func GetReportEndTables(startTime, endTime string, db *gorm.DB, sqliteDB *dbstore.DB, reportID string, progress, totalTableCount *int32) ([]*TableDef, []TableRowDef)

func GetReportHeaderTables 

func GetReportHeaderTables(startTime, endTime string, db *gorm.DB, sqliteDB *dbstore.DB, reportID string, progress, totalTableCount *int32) ([]*TableDef, []TableRowDef)

func GetReportTablesIn2Range 

func GetReportTablesIn2Range(startTime1, endTime1, startTime2, endTime2 string, db *gorm.DB, sqliteDB *dbstore.DB, reportID string, progress, totalTableCount *int32) ([]*TableDef, []TableRowDef)

func NewReport 

func NewReport(db *dbstore.DB, startTime, endTime time.Time, compareStartTime, compareEndTime *time.Time) (string, error)

func RegisterRouter 

func RegisterRouter(r *gin.RouterGroup, auth *user.AuthService, s *Service)

func RoundFloatString 

func RoundFloatString(s string) string

func SaveReportContent 

func SaveReportContent(db *dbstore.DB, reportID string, content string) error

func UpdateReportProgress 

func UpdateReportProgress(db *dbstore.DB, reportID string, progress int) error

Types

type AvgMaxMinTableDef 

type AvgMaxMinTableDef struct {
	Comment string
	// contains filtered or unexported fields
}

type GenDiagnosisReportRequest 

type GenDiagnosisReportRequest struct {
	StartTime int64  `json:"start_time"`
	EndTime   int64  `json:"end_time"`
	Kind      string `json:"kind"` // values: config, error, performance
}

type GenerateMetricsRelationRequest 

type GenerateMetricsRelationRequest struct {
	StartTime int64  `json:"start_time"`
	EndTime   int64  `json:"end_time"`
	Type      string `json:"type"`
}

type GenerateReportRequest 

type GenerateReportRequest struct {
	StartTime        int64 `json:"start_time"`
	EndTime          int64 `json:"end_time"`
	CompareStartTime int64 `json:"compare_start_time"`
	CompareEndTime   int64 `json:"compare_end_time"`
}

type Report 

type Report struct {
	ID               string     `gorm:"primary_key;size:40" json:"id"`
	CreatedAt        time.Time  `json:"created_at"`
	Progress         int        `json:"progress"` // 0~100
	Content          string     `json:"content"`
	StartTime        time.Time  `json:"start_time"`
	EndTime          time.Time  `json:"end_time"`
	CompareStartTime *time.Time `json:"compare_start_time"`
	CompareEndTime   *time.Time `json:"compare_end_time"`
}

func GetReport 

func GetReport(db *dbstore.DB, reportID string) (*Report, error)

func GetReports 

func GetReports(db *dbstore.DB) ([]Report, error)

func (Report) TableName 

func (Report) TableName() string

type Service 

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

func NewService 

func NewService(config *config.Config, tidbClient *tidb.Client, db *dbstore.DB, uiAssetFS http.FileSystem) *Service

type TableDef 

type TableDef struct {
	Category []string `json:"category"` // The category of the table, such as [TiDB]
	Title    string   `json:"title"`
	Comment  string   `json:"comment"`

	Column []string      `json:"column"`
	Rows   []TableRowDef `json:"rows"`
	// contains filtered or unexported fields
}

func GenerateDiffTable 

func GenerateDiffTable(dr diffRows) *TableDef

func GenerateReportError 

func GenerateReportError(errRows []TableRowDef) *TableDef

func GetAllDiagnoseReport 

func GetAllDiagnoseReport(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetCPUUsageTable 

func GetCPUUsageTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetClusterHardwareInfoTable 

func GetClusterHardwareInfoTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetClusterInfoTable 

func GetClusterInfoTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetCompareHeaderTimeTable 

func GetCompareHeaderTimeTable(startTime1, endTime1, startTime2, endTime2 string) *TableDef

func GetCompareReportTablesForDisplay 

func GetCompareReportTablesForDisplay(startTime1, endTime1, startTime2, endTime2 string, db *gorm.DB, sqliteDB *dbstore.DB, reportID string) []*TableDef

func GetDiagnoseReport 

func GetDiagnoseReport(startTime, endTime string, db *gorm.DB, rules []string) (TableDef, error)

func GetGoroutinesCountTable 

func GetGoroutinesCountTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetHeaderTimeTable 

func GetHeaderTimeTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetLoadTable 

func GetLoadTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDClusterStatusTable 

func GetPDClusterStatusTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDConfigChangeInfo 

func GetPDConfigChangeInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDConfigInfo 

func GetPDConfigInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDCurrentConfig 

func GetPDCurrentConfig(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDEtcdStatusTable 

func GetPDEtcdStatusTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDSchedulerInfo 

func GetPDSchedulerInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetPDTimeConsumeTable 

func GetPDTimeConsumeTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetProcessMemUsageTable 

func GetProcessMemUsageTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetReportTables 

func GetReportTables(startTime, endTime string, db *gorm.DB, sqliteDB *dbstore.DB, reportID string) []*TableDef

func GetReportTablesForDisplay 

func GetReportTablesForDisplay(startTime, endTime string, db *gorm.DB, sqliteDB *dbstore.DB, reportID string) []*TableDef

func GetStoreStatusTable 

func GetStoreStatusTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBConnectionCountTable 

func GetTiDBConnectionCountTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBCurrentConfig 

func GetTiDBCurrentConfig(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBDDLOwner 

func GetTiDBDDLOwner(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBGCConfigChangeInfo 

func GetTiDBGCConfigChangeInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBGCConfigInfo 

func GetTiDBGCConfigInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBSlowQueryWithDiffPlan 

func GetTiDBSlowQueryWithDiffPlan(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBStatisticsInfo 

func GetTiDBStatisticsInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBTimeConsumeTable 

func GetTiDBTimeConsumeTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBTopNSlowQuery 

func GetTiDBTopNSlowQuery(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBTopNSlowQueryGroupByDigest 

func GetTiDBTopNSlowQueryGroupByDigest(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiDBTxnTableData 

func GetTiDBTxnTableData(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVCacheHitTable 

func GetTiKVCacheHitTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVCopInfo 

func GetTiKVCopInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVCurrentConfig 

func GetTiKVCurrentConfig(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVErrorTable 

func GetTiKVErrorTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVGCInfo 

func GetTiKVGCInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRaftInfo 

func GetTiKVRaftInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRaftStoreConfigChangeInfo 

func GetTiKVRaftStoreConfigChangeInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRaftStoreConfigInfo 

func GetTiKVRaftStoreConfigInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRegionSizeInfo 

func GetTiKVRegionSizeInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRocksDBConfigChangeInfo 

func GetTiKVRocksDBConfigChangeInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRocksDBConfigInfo 

func GetTiKVRocksDBConfigInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVRocksDBTimeConsumeTable 

func GetTiKVRocksDBTimeConsumeTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVSchedulerInfo 

func GetTiKVSchedulerInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVSnapshotInfo 

func GetTiKVSnapshotInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVStoreInfo 

func GetTiKVStoreInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVTaskInfo 

func GetTiKVTaskInfo(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVThreadCPUTable 

func GetTiKVThreadCPUTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTiKVTotalTimeConsumeTable 

func GetTiKVTotalTimeConsumeTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTotalErrorTable 

func GetTotalErrorTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func GetTotalTimeConsumeTable 

func GetTotalTimeConsumeTable(startTime, endTime string, db *gorm.DB) (TableDef, error)

func (TableDef) ColumnWidth 

func (t TableDef) ColumnWidth() []int

type TableRowDef 

type TableRowDef struct {
	Values    []string   `json:"values"`
	SubValues [][]string `json:"sub_values"` // SubValues need fold default.

	Comment string `json:"comment"`
	// contains filtered or unexported fields
}

func NewTableRowDef 

func NewTableRowDef(values []string, subValues [][]string) TableRowDef

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.