monitor

type AgentConfigSender interface {
	// SendMonitorConfig sends monitor config and tracked processes to agent.
	// SendMonitorConfig 向 Agent 发送监控配置和跟踪的进程列表。
	SendMonitorConfig(ctx context.Context, agentID string, config *MonitorConfig, processes []*TrackedProcessInfo) error
}

type ClusterNodeProvider interface {
	// GetNodesByClusterID returns all nodes for a cluster.
	// GetNodesByClusterID 返回集群的所有节点。
	GetNodesByClusterID(ctx context.Context, clusterID uint) ([]*NodeInfoForMonitor, error)
}

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

type MonitorConfig struct {
	ID              uint       `json:"id" gorm:"primaryKey;autoIncrement"`
	ClusterID       uint       `json:"cluster_id" gorm:"uniqueIndex;not null"` // 关联的集群 ID / Associated cluster ID
	AutoMonitor     bool       `json:"auto_monitor" gorm:"default:true"`       // 是否启用自动监控 / Whether auto monitoring is enabled
	AutoRestart     bool       `json:"auto_restart" gorm:"default:true"`       // 是否启用自动拉起 / Whether auto restart is enabled
	MonitorInterval int        `json:"monitor_interval" gorm:"default:5"`      // 监控间隔（秒）/ Monitor interval (seconds)
	RestartDelay    int        `json:"restart_delay" gorm:"default:10"`        // 重启延迟（秒）/ Restart delay (seconds)
	MaxRestarts     int        `json:"max_restarts" gorm:"default:3"`          // 最大重启次数 / Max restart count
	TimeWindow      int        `json:"time_window" gorm:"default:300"`         // 时间窗口（秒，5分钟）/ Time window (seconds, 5 minutes)
	CooldownPeriod  int        `json:"cooldown_period" gorm:"default:1800"`    // 冷却时间（秒，30分钟）/ Cooldown period (seconds, 30 minutes)
	ConfigVersion   int        `json:"config_version" gorm:"default:1"`        // 配置版本号 / Config version number
	LastSyncAt      *time.Time `json:"last_sync_at"`                           // 最后同步时间 / Last sync time
	CreatedAt       time.Time  `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt       time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
}

type NodeInfoForMonitor struct {
	HostID     uint   `json:"host_id"`
	AgentID    string `json:"agent_id"`
	InstallDir string `json:"install_dir"`
	Role       string `json:"role"`
	ProcessPID int    `json:"process_pid"`
}

type ProcessEvent struct {
	ID          uint             `json:"id" gorm:"primaryKey;autoIncrement"`
	ClusterID   uint             `json:"cluster_id" gorm:"index"`                // 关联的集群 ID / Associated cluster ID
	NodeID      uint             `json:"node_id" gorm:"index"`                   // 关联的节点 ID / Associated node ID
	HostID      uint             `json:"host_id" gorm:"index"`                   // 关联的主机 ID / Associated host ID
	EventType   ProcessEventType `json:"event_type" gorm:"size:30;index"`        // 事件类型 / Event type
	PID         int              `json:"pid"`                                    // 进程 PID / Process PID
	ProcessName string           `json:"process_name" gorm:"size:100"`           // 进程名称 / Process name
	InstallDir  string           `json:"install_dir" gorm:"size:255"`            // 安装目录 / Install directory
	Role        string           `json:"role" gorm:"size:20"`                    // 节点角色 / Node role
	Details     string           `json:"details" gorm:"type:text"`               // 事件详情（JSON）/ Event details (JSON)
	CreatedAt   time.Time        `json:"created_at" gorm:"autoCreateTime;index"` // 事件时间 / Event time
}

type ProcessEventFilter struct {
	ClusterID uint             `json:"cluster_id"`
	NodeID    uint             `json:"node_id"`
	HostID    uint             `json:"host_id"`
	EventType ProcessEventType `json:"event_type"`
	StartTime *time.Time       `json:"start_time"`
	EndTime   *time.Time       `json:"end_time"`
	Page      int              `json:"page"`
	PageSize  int              `json:"page_size"`
}

type ProcessEventType string

type ProcessEventWithHost struct {
	ProcessEvent
	Hostname string `json:"hostname"` // 主机名 / Hostname
	IP       string `json:"ip"`       // 主机 IP / Host IP
}

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

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

type TrackedProcessInfo struct {
	PID        int    `json:"pid"`         // 进程 PID / Process PID
	Name       string `json:"name"`        // 进程名称 / Process name (e.g., "seatunnel-master")
	InstallDir string `json:"install_dir"` // 安装目录 / Install directory
	Role       string `json:"role"`        // 节点角色 / Node role
}

type UpdateMonitorConfigRequest struct {
	AutoMonitor     *bool `json:"auto_monitor"`
	AutoRestart     *bool `json:"auto_restart"`
	MonitorInterval *int  `json:"monitor_interval"`
	RestartDelay    *int  `json:"restart_delay"`
	MaxRestarts     *int  `json:"max_restarts"`
	TimeWindow      *int  `json:"time_window"`
	CooldownPeriod  *int  `json:"cooldown_period"`
}