diagnostics

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

type ClusterInspectionFinding struct {
	ID                  uint                      `json:"id" gorm:"primaryKey;autoIncrement"`
	ReportID            uint                      `json:"report_id" gorm:"index;not null"`
	ClusterID           uint                      `json:"cluster_id" gorm:"index;not null"`
	Severity            InspectionFindingSeverity `json:"severity" gorm:"size:20;index;not null"`
	Category            string                    `json:"category" gorm:"size:64;index;not null"`
	CheckCode           string                    `json:"check_code" gorm:"size:100;index;not null"`
	CheckName           string                    `json:"check_name" gorm:"size:200"`
	Summary             string                    `json:"summary" gorm:"type:text"`
	Recommendation      string                    `json:"recommendation" gorm:"type:text"`
	EvidenceSummary     string                    `json:"evidence_summary" gorm:"type:text"`
	RelatedNodeID       uint                      `json:"related_node_id" gorm:"index"`
	RelatedHostID       uint                      `json:"related_host_id" gorm:"index"`
	RelatedErrorGroupID uint                      `json:"related_error_group_id" gorm:"index"`
	RelatedAlertID      string                    `json:"related_alert_id" gorm:"size:120;index"`
	CreatedAt           time.Time                 `json:"created_at" gorm:"autoCreateTime;index"`
	UpdatedAt           time.Time                 `json:"updated_at" gorm:"autoUpdateTime"`
}

type ClusterInspectionFindingFilter struct {
	ReportID            uint                      `json:"report_id"`
	ClusterID           uint                      `json:"cluster_id"`
	Severity            InspectionFindingSeverity `json:"severity"`
	Category            string                    `json:"category"`
	RelatedNodeID       uint                      `json:"related_node_id"`
	RelatedHostID       uint                      `json:"related_host_id"`
	RelatedErrorGroupID uint                      `json:"related_error_group_id"`
	Page                int                       `json:"page"`
	PageSize            int                       `json:"page_size"`
}

type ClusterInspectionFindingInfo struct {
	ID                  uint                      `json:"id"`
	ReportID            uint                      `json:"report_id"`
	ClusterID           uint                      `json:"cluster_id"`
	Severity            InspectionFindingSeverity `json:"severity"`
	Category            string                    `json:"category"`
	CheckCode           string                    `json:"check_code"`
	CheckName           string                    `json:"check_name"`
	Summary             string                    `json:"summary"`
	Recommendation      string                    `json:"recommendation"`
	EvidenceSummary     string                    `json:"evidence_summary"`
	RelatedNodeID       uint                      `json:"related_node_id"`
	RelatedHostID       uint                      `json:"related_host_id"`
	RelatedHostName     string                    `json:"related_host_name"`
	RelatedHostIP       string                    `json:"related_host_ip"`
	RelatedErrorGroupID uint                      `json:"related_error_group_id"`
	RelatedAlertID      string                    `json:"related_alert_id"`
	CreatedAt           time.Time                 `json:"created_at"`
	UpdatedAt           time.Time                 `json:"updated_at"`
}

type ClusterInspectionReport struct {
	ID                uint                    `json:"id" gorm:"primaryKey;autoIncrement"`
	ClusterID         uint                    `json:"cluster_id" gorm:"index;not null"`
	Status            InspectionReportStatus  `json:"status" gorm:"size:20;index;not null"`
	TriggerSource     InspectionTriggerSource `json:"trigger_source" gorm:"size:32;index;not null"`
	LookbackMinutes   int                     `json:"lookback_minutes" gorm:"default:30"`
	ErrorThreshold    int                     `json:"error_threshold" gorm:"default:1"`
	RequestedByUserID uint                    `json:"requested_by_user_id" gorm:"index"`
	RequestedBy       string                  `json:"requested_by" gorm:"size:120;index"`
	Summary           string                  `json:"summary" gorm:"type:text"`
	ErrorMessage      string                  `json:"error_message" gorm:"type:text"`
	FindingTotal      int                     `json:"finding_total" gorm:"default:0"`
	CriticalCount     int                     `json:"critical_count" gorm:"default:0"`
	WarningCount      int                     `json:"warning_count" gorm:"default:0"`
	InfoCount         int                     `json:"info_count" gorm:"default:0"`
	AutoTriggerReason string                  `json:"auto_trigger_reason" gorm:"size:200"`
	StartedAt         *time.Time              `json:"started_at" gorm:"index"`
	FinishedAt        *time.Time              `json:"finished_at" gorm:"index"`
	CreatedAt         time.Time               `json:"created_at" gorm:"autoCreateTime;index"`
	UpdatedAt         time.Time               `json:"updated_at" gorm:"autoUpdateTime"`
}

type ClusterInspectionReportDetailData struct {
	Report                *ClusterInspectionReportInfo    `json:"report"`
	Findings              []*ClusterInspectionFindingInfo `json:"findings"`
	RelatedDiagnosticTask *DiagnosticTask                 `json:"related_diagnostic_task,omitempty"`
}

type ClusterInspectionReportFilter struct {
	ClusterID     uint                      `json:"cluster_id"`
	Status        InspectionReportStatus    `json:"status"`
	TriggerSource InspectionTriggerSource   `json:"trigger_source"`
	Severity      InspectionFindingSeverity `json:"severity"`
	StartTime     *time.Time                `json:"start_time"`
	EndTime       *time.Time                `json:"end_time"`
	Page          int                       `json:"page"`
	PageSize      int                       `json:"page_size"`
}

type ClusterInspectionReportInfo struct {
	ID                uint                    `json:"id"`
	ClusterID         uint                    `json:"cluster_id"`
	ClusterName       string                  `json:"cluster_name,omitempty"`
	Status            InspectionReportStatus  `json:"status"`
	TriggerSource     InspectionTriggerSource `json:"trigger_source"`
	LookbackMinutes   int                     `json:"lookback_minutes"`
	ErrorThreshold    int                     `json:"error_threshold"`
	RequestedByUserID uint                    `json:"requested_by_user_id"`
	RequestedBy       string                  `json:"requested_by"`
	Summary           string                  `json:"summary"`
	ErrorMessage      string                  `json:"error_message"`
	FindingTotal      int                     `json:"finding_total"`
	CriticalCount     int                     `json:"critical_count"`
	WarningCount      int                     `json:"warning_count"`
	InfoCount         int                     `json:"info_count"`
	AutoTriggerReason string                  `json:"auto_trigger_reason,omitempty"`
	StartedAt         *time.Time              `json:"started_at,omitempty"`
	FinishedAt        *time.Time              `json:"finished_at,omitempty"`
	CreatedAt         time.Time               `json:"created_at"`
	UpdatedAt         time.Time               `json:"updated_at"`
}

type ClusterInspectionReportsData struct {
	Items    []*ClusterInspectionReportInfo `json:"items"`
	Total    int64                          `json:"total"`
	Page     int                            `json:"page"`
	PageSize int                            `json:"page_size"`
}

type ClusterOption struct {
	ClusterID   uint   `json:"cluster_id"`
	ClusterName string `json:"cluster_name"`
}

type CreateDiagnosticTaskRequest struct {
	ClusterID       uint                     `json:"cluster_id"`
	TriggerSource   DiagnosticTaskSourceType `json:"trigger_source"`
	SourceRef       DiagnosticTaskSourceRef  `json:"source_ref"`
	NodeScope       DiagnosticTaskNodeScope  `json:"node_scope,omitempty"`
	SelectedNodeIDs []uint                   `json:"selected_node_ids"`
	Options         DiagnosticTaskOptions    `json:"options"`
	// LookbackMinutes overrides the default diagnostics collection window in minutes.
	// LookbackMinutes 覆盖默认诊断采集时间窗口（分钟），0 表示使用默认或来源巡检窗口。
	LookbackMinutes int    `json:"lookback_minutes,omitempty"`
	Summary         string `json:"summary"`
	AutoStart       bool   `json:"auto_start"`
}

type CreateInspectionAutoPolicyRequest struct {
	ClusterID       uint                     `json:"cluster_id"`
	Name            string                   `json:"name" binding:"required"`
	Enabled         bool                     `json:"enabled"`
	Conditions      InspectionConditionItems `json:"conditions" binding:"required"`
	CooldownMinutes int                      `json:"cooldown_minutes"`
	AutoCreateTask  bool                     `json:"auto_create_task"`
	AutoStartTask   bool                     `json:"auto_start_task"`
	TaskOptions     *DiagnosticTaskOptions   `json:"task_options,omitempty"`
}

type DiagnosticExecutionRequest struct {
	RequestID      string
	IdempotencyKey string
	RequestHash    string
	Confirmed      bool
	ConfirmationID string
	IsAdmin        bool
	ClientType     string
}

type DiagnosticHostDisplayContext struct {
	HostName string
	HostIP   string
}

type DiagnosticLanguage string

type DiagnosticLogEventType string

type DiagnosticLogLevel string

type DiagnosticLogMetadata map[string]interface{}

type DiagnosticNodeExecution struct {
	ID            uint                 `json:"id" gorm:"primaryKey;autoIncrement"`
	TaskID        uint                 `json:"task_id" gorm:"index;not null;uniqueIndex:idx_diagnostics_task_node_scope"`
	TaskStepID    *uint                `json:"task_step_id" gorm:"index"`
	ClusterNodeID uint                 `json:"cluster_node_id" gorm:"index"`
	NodeID        uint                 `json:"node_id" gorm:"index"`
	HostID        uint                 `json:"host_id" gorm:"index;not null;uniqueIndex:idx_diagnostics_task_node_scope"`
	HostName      string               `json:"host_name" gorm:"size:100"`
	HostIP        string               `json:"host_ip" gorm:"size:64"`
	Role          string               `json:"role" gorm:"size:32;not null;uniqueIndex:idx_diagnostics_task_node_scope"`
	AgentID       string               `json:"agent_id" gorm:"size:120;index"`
	InstallDir    string               `json:"install_dir" gorm:"size:255"`
	Status        DiagnosticTaskStatus `json:"status" gorm:"size:32;index;not null"`
	CurrentStep   DiagnosticStepCode   `json:"current_step" gorm:"size:64;index"`
	Message       string               `json:"message" gorm:"type:text"`
	Error         string               `json:"error" gorm:"type:text"`
	StartedAt     *time.Time           `json:"started_at"`
	CompletedAt   *time.Time           `json:"completed_at"`
	CreatedAt     time.Time            `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt     time.Time            `json:"updated_at" gorm:"autoUpdateTime"`
}

type DiagnosticPlanStep struct {
	Sequence    int                `json:"sequence"`
	Code        DiagnosticStepCode `json:"code"`
	Title       string             `json:"title"`
	Description string             `json:"description"`
	NodeScoped  bool               `json:"node_scoped"`
	Required    bool               `json:"required"`
}

type DiagnosticStepCode string

type DiagnosticStepLog struct {
	ID              uint                   `json:"id" gorm:"primaryKey;autoIncrement"`
	TaskID          uint                   `json:"task_id" gorm:"index;not null"`
	TaskStepID      *uint                  `json:"task_step_id" gorm:"index"`
	NodeExecutionID *uint                  `json:"node_execution_id" gorm:"index"`
	StepCode        DiagnosticStepCode     `json:"step_code" gorm:"size:64;index"`
	Level           DiagnosticLogLevel     `json:"level" gorm:"size:10;index;not null"`
	EventType       DiagnosticLogEventType `json:"event_type" gorm:"size:20;index;not null"`
	Message         string                 `json:"message" gorm:"type:text"`
	CommandSummary  string                 `json:"command_summary" gorm:"type:text"`
	Metadata        DiagnosticLogMetadata  `json:"metadata" gorm:"type:json"`
	CreatedAt       time.Time              `json:"created_at" gorm:"autoCreateTime;index"`
}

type DiagnosticTask struct {
	ID            uint                     `json:"id" gorm:"primaryKey;autoIncrement"`
	ExecutionID   string                   `json:"execution_id,omitempty" gorm:"size:36;index"`
	ClusterID     uint                     `json:"cluster_id" gorm:"index;not null"`
	TriggerSource DiagnosticTaskSourceType `json:"trigger_source" gorm:"size:40;index;not null"`
	SourceRef     DiagnosticTaskSourceRef  `json:"source_ref" gorm:"type:json;not null"`
	Options       DiagnosticTaskOptions    `json:"options" gorm:"type:json;not null"`
	// LookbackMinutes controls the diagnostics collection window in minutes.
	// LookbackMinutes 控制诊断采集时间窗口（分钟），0 表示使用默认或来源巡检窗口。
	LookbackMinutes int                       `json:"lookback_minutes" gorm:"default:0"`
	Status          DiagnosticTaskStatus      `json:"status" gorm:"size:32;index;not null"`
	CurrentStep     DiagnosticStepCode        `json:"current_step" gorm:"size:64;index"`
	FailureStep     DiagnosticStepCode        `json:"failure_step" gorm:"size:64"`
	FailureReason   string                    `json:"failure_reason" gorm:"type:text"`
	SelectedNodes   DiagnosticTaskNodeTargets `json:"selected_nodes" gorm:"type:json;not null"`
	Summary         string                    `json:"summary" gorm:"type:text"`
	BundleDir       string                    `json:"bundle_dir" gorm:"size:500"`
	ManifestPath    string                    `json:"manifest_path" gorm:"size:500"`
	IndexPath       string                    `json:"index_path" gorm:"size:500"`
	StartedAt       *time.Time                `json:"started_at"`
	CompletedAt     *time.Time                `json:"completed_at"`
	CreatedBy       uint                      `json:"created_by"`
	CreatedByName   string                    `json:"created_by_name" gorm:"size:120;index"`
	CreatedAt       time.Time                 `json:"created_at" gorm:"autoCreateTime;index"`
	UpdatedAt       time.Time                 `json:"updated_at" gorm:"autoUpdateTime"`
	Steps           []DiagnosticTaskStep      `json:"steps" gorm:"foreignKey:TaskID"`
	NodeExecutions  []DiagnosticNodeExecution `json:"node_executions" gorm:"foreignKey:TaskID"`
}

type DiagnosticTaskEvent struct {
	TaskID          uint                    `json:"task_id"`
	EventType       DiagnosticTaskEventType `json:"event_type"`
	Timestamp       time.Time               `json:"timestamp"`
	TaskStatus      DiagnosticTaskStatus    `json:"task_status,omitempty"`
	StepStatus      DiagnosticTaskStatus    `json:"step_status,omitempty"`
	NodeStatus      DiagnosticTaskStatus    `json:"node_status,omitempty"`
	CurrentStep     DiagnosticStepCode      `json:"current_step,omitempty"`
	StepID          *uint                   `json:"step_id,omitempty"`
	StepCode        DiagnosticStepCode      `json:"step_code,omitempty"`
	NodeExecutionID *uint                   `json:"node_execution_id,omitempty"`
	HostID          uint                    `json:"host_id,omitempty"`
	HostName        string                  `json:"host_name,omitempty"`
	Level           DiagnosticLogLevel      `json:"level,omitempty"`
	LogEventType    DiagnosticLogEventType  `json:"log_event_type,omitempty"`
	Message         string                  `json:"message,omitempty"`
	Error           string                  `json:"error,omitempty"`
	CommandSummary  string                  `json:"command_summary,omitempty"`
	FailureReason   string                  `json:"failure_reason,omitempty"`
}

type DiagnosticTaskEventType string

type DiagnosticTaskListData struct {
	Items    []*DiagnosticTaskSummary `json:"items"`
	Total    int64                    `json:"total"`
	Page     int                      `json:"page"`
	PageSize int                      `json:"page_size"`
}

type DiagnosticTaskListFilter struct {
	ClusterID     uint                     `json:"cluster_id"`
	TriggerSource DiagnosticTaskSourceType `json:"trigger_source"`
	Status        DiagnosticTaskStatus     `json:"status"`
	Page          int                      `json:"page"`
	PageSize      int                      `json:"page_size"`
	OwnerUserID   uint                     `json:"-"`
	IncludeAll    bool                     `json:"-"`
}

type DiagnosticTaskLogFilter struct {
	TaskID          uint
	StepCode        DiagnosticStepCode
	NodeExecutionID *uint
	Level           DiagnosticLogLevel
	Page            int
	PageSize        int
	OwnerUserID     uint
	IncludeAll      bool
}

type DiagnosticTaskLogListData struct {
	Items    []*DiagnosticStepLog `json:"items"`
	Total    int64                `json:"total"`
	Page     int                  `json:"page"`
	PageSize int                  `json:"page_size"`
}

type DiagnosticTaskNodeScope string

type DiagnosticTaskNodeTarget struct {
	ClusterNodeID uint   `json:"cluster_node_id"`
	NodeID        uint   `json:"node_id"`
	HostID        uint   `json:"host_id"`
	HostName      string `json:"host_name"`
	HostIP        string `json:"host_ip"`
	Role          string `json:"role"`
	AgentID       string `json:"agent_id"`
	InstallDir    string `json:"install_dir"`
}

type DiagnosticTaskNodeTargets []DiagnosticTaskNodeTarget

type DiagnosticTaskOptions struct {
	IncludeThreadDump bool `json:"include_thread_dump"`
	IncludeJVMDump    bool `json:"include_jvm_dump"`
	JVMDumpMinFreeMB  int  `json:"jvm_dump_min_free_mb,omitempty"`
}

type DiagnosticTaskSourceRef struct {
	ErrorGroupID        uint   `json:"error_group_id,omitempty"`
	InspectionReportID  uint   `json:"inspection_report_id,omitempty"`
	InspectionFindingID uint   `json:"inspection_finding_id,omitempty"`
	AlertID             string `json:"alert_id,omitempty"`
}

type DiagnosticTaskSourceType string

type DiagnosticTaskStatus string

type DiagnosticTaskStep struct {
	ID          uint                 `json:"id" gorm:"primaryKey;autoIncrement"`
	TaskID      uint                 `json:"task_id" gorm:"index;not null;uniqueIndex:idx_diagnostics_task_step_code"`
	Code        DiagnosticStepCode   `json:"code" gorm:"size:64;not null;uniqueIndex:idx_diagnostics_task_step_code"`
	Sequence    int                  `json:"sequence" gorm:"not null;index"`
	Title       string               `json:"title" gorm:"size:120"`
	Description string               `json:"description" gorm:"type:text"`
	Status      DiagnosticTaskStatus `json:"status" gorm:"size:32;index;not null"`
	Message     string               `json:"message" gorm:"type:text"`
	Error       string               `json:"error" gorm:"type:text"`
	StartedAt   *time.Time           `json:"started_at"`
	CompletedAt *time.Time           `json:"completed_at"`
	CreatedAt   time.Time            `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt   time.Time            `json:"updated_at" gorm:"autoUpdateTime"`
}

type DiagnosticTaskSummary struct {
	ID            uint                     `json:"id"`
	ExecutionID   string                   `json:"execution_id,omitempty"`
	ClusterID     uint                     `json:"cluster_id"`
	TriggerSource DiagnosticTaskSourceType `json:"trigger_source"`
	Status        DiagnosticTaskStatus     `json:"status"`
	CurrentStep   DiagnosticStepCode       `json:"current_step"`
	FailureStep   DiagnosticStepCode       `json:"failure_step"`
	FailureReason string                   `json:"failure_reason"`
	Summary       string                   `json:"summary"`
	StartedAt     *time.Time               `json:"started_at"`
	CompletedAt   *time.Time               `json:"completed_at"`
	CreatedBy     uint                     `json:"created_by"`
	CreatedByName string                   `json:"created_by_name"`
	CreatedAt     time.Time                `json:"created_at"`
	UpdatedAt     time.Time                `json:"updated_at"`
}

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

type IngestSeatunnelErrorRequest struct {
	ClusterID   uint      `json:"cluster_id"`
	NodeID      uint      `json:"node_id"`
	HostID      uint      `json:"host_id"`
	AgentID     string    `json:"agent_id"`
	Role        string    `json:"role"`
	InstallDir  string    `json:"install_dir"`
	SourceFile  string    `json:"source_file"`
	SourceKind  string    `json:"source_kind"`
	JobID       string    `json:"job_id"`
	OccurredAt  time.Time `json:"occurred_at"`
	Message     string    `json:"message"`
	Evidence    string    `json:"evidence"`
	CursorStart int64     `json:"cursor_start"`
	CursorEnd   int64     `json:"cursor_end"`
}

type InspectionAutoPolicy struct {
	ID              uint                     `json:"id" gorm:"primaryKey;autoIncrement"`
	ClusterID       uint                     `json:"cluster_id" gorm:"index;not null;default:0"`
	Name            string                   `json:"name" gorm:"size:200;not null"`
	Enabled         bool                     `json:"enabled" gorm:"not null;default:true"`
	Conditions      InspectionConditionItems `json:"conditions" gorm:"type:json;not null"`
	CooldownMinutes int                      `json:"cooldown_minutes" gorm:"not null;default:30"`
	// AutoCreateTask controls whether a diagnostics bundle task should be created automatically after an inspection is triggered.
	// AutoCreateTask 控制巡检触发后是否自动创建诊断包任务。
	AutoCreateTask bool `json:"auto_create_task" gorm:"not null;default:false"`
	// AutoStartTask controls whether the auto-created diagnostics task should start immediately.
	// AutoStartTask 控制自动创建的诊断任务是否立即开始执行。
	AutoStartTask bool `json:"auto_start_task" gorm:"not null;default:true"`
	// TaskOptions configures the diagnostics task bundle options (thread dump / JVM dump / log sample, etc.).
	// TaskOptions 配置诊断任务的采集选项（线程栈 / JVM Dump / 日志采样等）。
	TaskOptions DiagnosticTaskOptions `json:"task_options" gorm:"type:json;not null"`
	CreatedAt   time.Time             `json:"created_at" gorm:"autoCreateTime;index"`
	UpdatedAt   time.Time             `json:"updated_at" gorm:"autoUpdateTime"`
}

type InspectionAutoPolicyInfo struct {
	ID              uint                     `json:"id"`
	ClusterID       uint                     `json:"cluster_id"`
	Name            string                   `json:"name"`
	Enabled         bool                     `json:"enabled"`
	Conditions      InspectionConditionItems `json:"conditions"`
	CooldownMinutes int                      `json:"cooldown_minutes"`
	AutoCreateTask  bool                     `json:"auto_create_task"`
	AutoStartTask   bool                     `json:"auto_start_task"`
	TaskOptions     DiagnosticTaskOptions    `json:"task_options"`
	CreatedAt       time.Time                `json:"created_at"`
	UpdatedAt       time.Time                `json:"updated_at"`
}

type InspectionAutoPolicyListData struct {
	Items    []*InspectionAutoPolicyInfo `json:"items"`
	Total    int64                       `json:"total"`
	Page     int                         `json:"page"`
	PageSize int                         `json:"page_size"`
}

type InspectionConditionCategory string

type InspectionConditionItem struct {
	TemplateCode          InspectionConditionTemplateCode `json:"template_code"`
	Enabled               bool                            `json:"enabled"`
	ThresholdOverride     *int                            `json:"threshold_override,omitempty"`
	WindowMinutesOverride *int                            `json:"window_minutes_override,omitempty"`
	CronExprOverride      string                          `json:"cron_expr_override,omitempty"`
	ExtraKeywords         []string                        `json:"extra_keywords,omitempty"`
}

type InspectionConditionItems []InspectionConditionItem

type InspectionConditionTemplate struct {
	Code                 InspectionConditionTemplateCode `json:"code"`
	Category             InspectionConditionCategory     `json:"category"`
	Name                 string                          `json:"name"`
	Description          string                          `json:"description"`
	DefaultThreshold     int                             `json:"default_threshold"`
	DefaultWindowMinutes int                             `json:"default_window_minutes"`
	DefaultCronExpr      string                          `json:"default_cron_expr,omitempty"`
	ImmediateOnMatch     bool                            `json:"immediate_on_match"`
}

type InspectionConditionTemplateCode string

type InspectionEvaluationResult struct {
	ClusterID     uint                        `json:"cluster_id"`
	GeneratedAt   time.Time                   `json:"generated_at"`
	Summary       string                      `json:"summary"`
	FindingTotal  int                         `json:"finding_total"`
	CriticalCount int                         `json:"critical_count"`
	WarningCount  int                         `json:"warning_count"`
	InfoCount     int                         `json:"info_count"`
	Findings      []*ClusterInspectionFinding `json:"findings"`
}

type InspectionFindingSeverity string

type InspectionReportStatus string

type InspectionTriggerSource string

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

type Response struct {
	ErrorMsg string      `json:"error_msg"`
	Data     interface{} `json:"data"`
}

type SeatunnelErrorEvent struct {
	ID             uint      `json:"id" gorm:"primaryKey;autoIncrement"`
	ErrorGroupID   uint      `json:"error_group_id" gorm:"index;not null"`
	Fingerprint    string    `json:"fingerprint" gorm:"size:64;index;not null"`
	ClusterID      uint      `json:"cluster_id" gorm:"index"`
	NodeID         uint      `json:"node_id" gorm:"index"`
	HostID         uint      `json:"host_id" gorm:"index"`
	AgentID        string    `json:"agent_id" gorm:"size:100;index;not null"`
	Role           string    `json:"role" gorm:"size:20;index"`
	InstallDir     string    `json:"install_dir" gorm:"size:255"`
	SourceFile     string    `json:"source_file" gorm:"size:500;index"`
	SourceKind     string    `json:"source_kind" gorm:"size:20;index"`
	JobID          string    `json:"job_id" gorm:"size:100;index"`
	OccurredAt     time.Time `json:"occurred_at" gorm:"index"`
	Message        string    `json:"message" gorm:"type:text"`
	ExceptionClass string    `json:"exception_class" gorm:"size:255;index"`
	NormalizedText string    `json:"normalized_text" gorm:"type:text"`
	Evidence       string    `json:"evidence" gorm:"type:text"`
	CursorStart    int64     `json:"cursor_start"`
	CursorEnd      int64     `json:"cursor_end"`
	CreatedAt      time.Time `json:"created_at" gorm:"autoCreateTime;index"`
}

type SeatunnelErrorEventFilter struct {
	ErrorGroupID   uint       `json:"error_group_id"`
	ClusterID      uint       `json:"cluster_id"`
	NodeID         uint       `json:"node_id"`
	HostID         uint       `json:"host_id"`
	Role           string     `json:"role"`
	JobID          string     `json:"job_id"`
	Keyword        string     `json:"keyword"`
	ExceptionClass string     `json:"exception_class"`
	StartTime      *time.Time `json:"start_time"`
	EndTime        *time.Time `json:"end_time"`
	Page           int        `json:"page"`
	PageSize       int        `json:"page_size"`
}

type SeatunnelErrorEventInfo struct {
	ID             uint      `json:"id"`
	ErrorGroupID   uint      `json:"error_group_id"`
	Fingerprint    string    `json:"fingerprint"`
	ClusterID      uint      `json:"cluster_id"`
	NodeID         uint      `json:"node_id"`
	HostID         uint      `json:"host_id"`
	HostName       string    `json:"host_name"`
	HostIP         string    `json:"host_ip"`
	AgentID        string    `json:"agent_id"`
	Role           string    `json:"role"`
	InstallDir     string    `json:"install_dir"`
	SourceFile     string    `json:"source_file"`
	SourceKind     string    `json:"source_kind"`
	JobID          string    `json:"job_id"`
	OccurredAt     time.Time `json:"occurred_at"`
	Message        string    `json:"message"`
	ExceptionClass string    `json:"exception_class"`
	Evidence       string    `json:"evidence"`
	CursorStart    int64     `json:"cursor_start"`
	CursorEnd      int64     `json:"cursor_end"`
}

type SeatunnelErrorEventsData struct {
	Items    []*SeatunnelErrorEventInfo `json:"items"`
	Total    int64                      `json:"total"`
	Page     int                        `json:"page"`
	PageSize int                        `json:"page_size"`
}

type SeatunnelErrorGroup struct {
	ID                 uint      `json:"id" gorm:"primaryKey;autoIncrement"`
	Fingerprint        string    `json:"fingerprint" gorm:"size:64;uniqueIndex;not null"`
	FingerprintVersion string    `json:"fingerprint_version" gorm:"size:20;not null"`
	Title              string    `json:"title" gorm:"type:text"`
	ExceptionClass     string    `json:"exception_class" gorm:"size:255;index"`
	NormalizedText     string    `json:"normalized_text" gorm:"type:text"`
	SampleMessage      string    `json:"sample_message" gorm:"type:text"`
	SampleEvidence     string    `json:"sample_evidence" gorm:"type:text"`
	OccurrenceCount    int64     `json:"occurrence_count" gorm:"default:0"`
	FirstSeenAt        time.Time `json:"first_seen_at" gorm:"index"`
	LastSeenAt         time.Time `json:"last_seen_at" gorm:"index"`
	LastClusterID      uint      `json:"last_cluster_id" gorm:"index"`
	LastNodeID         uint      `json:"last_node_id" gorm:"index"`
	LastHostID         uint      `json:"last_host_id" gorm:"index"`
	CreatedAt          time.Time `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt          time.Time `json:"updated_at" gorm:"autoUpdateTime"`
}

type SeatunnelErrorGroupDetailData struct {
	Group  *SeatunnelErrorGroupInfo   `json:"group"`
	Events []*SeatunnelErrorEventInfo `json:"events"`
}

type SeatunnelErrorGroupFilter struct {
	ClusterID      uint       `json:"cluster_id"`
	NodeID         uint       `json:"node_id"`
	HostID         uint       `json:"host_id"`
	Role           string     `json:"role"`
	JobID          string     `json:"job_id"`
	Keyword        string     `json:"keyword"`
	ExceptionClass string     `json:"exception_class"`
	StartTime      *time.Time `json:"start_time"`
	EndTime        *time.Time `json:"end_time"`
	Page           int        `json:"page"`
	PageSize       int        `json:"page_size"`
}

type SeatunnelErrorGroupInfo struct {
	ID                 uint      `json:"id"`
	Fingerprint        string    `json:"fingerprint"`
	FingerprintVersion string    `json:"fingerprint_version"`
	Title              string    `json:"title"`
	ExceptionClass     string    `json:"exception_class"`
	SampleMessage      string    `json:"sample_message"`
	OccurrenceCount    int64     `json:"occurrence_count"`
	FirstSeenAt        time.Time `json:"first_seen_at"`
	LastSeenAt         time.Time `json:"last_seen_at"`
	LastClusterID      uint      `json:"last_cluster_id"`
	LastNodeID         uint      `json:"last_node_id"`
	LastHostID         uint      `json:"last_host_id"`
	LastHostName       string    `json:"last_host_name"`
	LastHostIP         string    `json:"last_host_ip"`
}

type SeatunnelErrorGroupsData struct {
	Items    []*SeatunnelErrorGroupInfo `json:"items"`
	Total    int64                      `json:"total"`
	Page     int                        `json:"page"`
	PageSize int                        `json:"page_size"`
}

type SeatunnelLogCursor struct {
	ID             uint       `json:"id" gorm:"primaryKey;autoIncrement"`
	AgentID        string     `json:"agent_id" gorm:"size:100;not null;uniqueIndex:idx_diag_log_cursor"`
	HostID         uint       `json:"host_id" gorm:"index;uniqueIndex:idx_diag_log_cursor"`
	ClusterID      uint       `json:"cluster_id" gorm:"index"`
	NodeID         uint       `json:"node_id" gorm:"index"`
	InstallDir     string     `json:"install_dir" gorm:"size:255;not null;uniqueIndex:idx_diag_log_cursor"`
	Role           string     `json:"role" gorm:"size:20;not null;uniqueIndex:idx_diag_log_cursor"`
	SourceFile     string     `json:"source_file" gorm:"size:500;not null;uniqueIndex:idx_diag_log_cursor"`
	CursorOffset   int64      `json:"cursor_offset"`
	LastOccurredAt *time.Time `json:"last_occurred_at"`
	CreatedAt      time.Time  `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt      time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
}

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

type StartClusterInspectionRequest struct {
	ClusterID       uint                    `json:"cluster_id" binding:"required"`
	TriggerSource   InspectionTriggerSource `json:"trigger_source"`
	LookbackMinutes int                     `json:"lookback_minutes,omitempty"`
	ErrorThreshold  int                     `json:"error_threshold,omitempty"`
}

type UpdateInspectionAutoPolicyRequest struct {
	Name            *string                   `json:"name,omitempty"`
	Enabled         *bool                     `json:"enabled,omitempty"`
	Conditions      *InspectionConditionItems `json:"conditions,omitempty"`
	CooldownMinutes *int                      `json:"cooldown_minutes,omitempty"`
	AutoCreateTask  *bool                     `json:"auto_create_task,omitempty"`
	AutoStartTask   *bool                     `json:"auto_start_task,omitempty"`
	TaskOptions     *DiagnosticTaskOptions    `json:"task_options,omitempty"`
}

type WorkspaceBootstrapData struct {
	GeneratedAt    time.Time            `json:"generated_at"`
	DefaultTab     WorkspaceTabKey      `json:"default_tab"`
	Tabs           []*WorkspaceTab      `json:"tabs"`
	ClusterOptions []*ClusterOption     `json:"cluster_options"`
	EntryContext   *WorkspaceContext    `json:"entry_context,omitempty"`
	Boundaries     []*WorkspaceBoundary `json:"boundaries"`
}

type WorkspaceBootstrapRequest struct {
	ClusterID *uint
	Source    string
	AlertID   string
}

type WorkspaceBoundary struct {
	Key         string `json:"key"`
	Title       string `json:"title"`
	Description string `json:"description"`
}

type WorkspaceContext struct {
	ClusterID   *uint  `json:"cluster_id,omitempty"`
	ClusterName string `json:"cluster_name,omitempty"`
	Source      string `json:"source,omitempty"`
	AlertID     string `json:"alert_id,omitempty"`
}

type WorkspaceTab struct {
	Key         WorkspaceTabKey `json:"key"`
	Label       string          `json:"label"`
	Description string          `json:"description"`
}

type WorkspaceTabKey string