Versions in this module Expand all Collapse all v1 v1.0.1 Mar 15, 2020 v1.0.0 Mar 15, 2020 Changes in this version + const TaskGroupMaxPreviewLines + const TaskMaxPreviewLines + var MaxRecvMsgSize = math.MaxInt64 + var ServerTypeMap = map[ServerType]string + type CreateTaskGroupRequest struct + Request SearchLogRequest + SearchTargets []SearchTarget + type PreviewModel struct + ID uint + Level diagnosticspb.LogLevel + Message string + TaskGroupID uint + TaskID uint + Time int64 + func (PreviewModel) TableName() string + type Scheduler struct + func NewScheduler(service *Service) *Scheduler + func (s *Scheduler) AsyncAbort(taskGroupID uint) bool + func (s *Scheduler) AsyncStart(taskGroupModel *TaskGroupModel, tasksModel []*TaskModel) bool + type SearchLogRequest diagnosticspb.SearchLogRequest + func (r *SearchLogRequest) Scan(src interface{}) error + func (r *SearchLogRequest) Value() (driver.Value, error) + type SearchTarget struct + IP string + Kind ServerType + Port int + StatusPort int + func (s *SearchTarget) Address() string + func (s *SearchTarget) FileName() string + func (s *SearchTarget) GRPCAddress() string + func (s *SearchTarget) ServerName() string + func (s *SearchTarget) String() string + type ServerType int + const ServerTypePD + const ServerTypeTiDB + const ServerTypeTiKV + type Service struct + func NewService(config *config.Config, db *dbstore.DB) *Service + func (s *Service) CancelTask(c *gin.Context) + func (s *Service) CreateTaskGroup(c *gin.Context) + func (s *Service) DeleteTaskGroup(c *gin.Context) + func (s *Service) DownloadLogs(c *gin.Context) + func (s *Service) GetAllTaskGroups(c *gin.Context) + func (s *Service) GetDownloadToken(c *gin.Context) + func (s *Service) GetTaskGroup(c *gin.Context) + func (s *Service) GetTaskGroupPreview(c *gin.Context) + func (s *Service) Register(r *gin.RouterGroup, auth *user.AuthService) + func (s *Service) RetryTask(c *gin.Context) + type Task struct + func (t *Task) Abort() + func (t *Task) String() string + func (t *Task) SyncRun() + type TaskGroup struct + func (tg *TaskGroup) AbortAll() + func (tg *TaskGroup) InitTasks(taskModels []*TaskModel) + func (tg *TaskGroup) SyncRun() + type TaskGroupModel struct + ID uint + LogStoreDir *string + SearchRequest *SearchLogRequest + State TaskGroupState + func (TaskGroupModel) TableName() string + func (tg *TaskGroupModel) Delete(db *dbstore.DB) + type TaskGroupResponse struct + TaskGroup TaskGroupModel + Tasks []*TaskModel + type TaskGroupState int + const TaskGroupStateFinished + const TaskGroupStateRunning + type TaskModel struct + Error *string + ID uint + LogStorePath *string + SearchTarget *SearchTarget + State TaskState + TaskGroupID uint + func (TaskModel) TableName() string + func (task *TaskModel) RemoveDataAndPreview(db *dbstore.DB) + type TaskState int + const TaskStateError + const TaskStateFinished + const TaskStateRunning
Go to main page