cluster

type AddNodeEntryRequest struct {
	Role          NodeRole       `json:"role" binding:"required"`
	InstallDir    string         `json:"install_dir"`
	HazelcastPort int            `json:"hazelcast_port"`
	APIPort       int            `json:"api_port"`
	WorkerPort    int            `json:"worker_port"`
	Overrides     *NodeOverrides `json:"overrides,omitempty"`
}

type AddNodeRequest struct {
	HostID     uint     `json:"host_id" binding:"required"`
	Role       NodeRole `json:"role" binding:"required"`
	InstallDir string   `json:"install_dir"` // SeaTunnel installation directory / SeaTunnel 安装目录

	// Port configuration based on node role / 基于节点角色的端口配置
	// Master: hazelcast_port (default 5801) + api_port (default 8080, optional)
	// Worker: hazelcast_port (default 5802)
	// Hybrid: hazelcast_port (5801) + worker_port (5802)
	HazelcastPort int            `json:"hazelcast_port"`      // Hazelcast cluster port / Hazelcast 集群端口
	APIPort       int            `json:"api_port"`            // REST API port (Master only, optional) / REST API 端口（仅 Master，可选）
	WorkerPort    int            `json:"worker_port"`         // Worker hazelcast port (Hybrid only) / Worker Hazelcast 端口（仅混合模式）
	Overrides     *NodeOverrides `json:"overrides,omitempty"` // Node-level JSON overrides / 节点级 JSON 覆盖配置

	// Whether to skip precheck / 是否跳过预检查
	SkipPrecheck bool `json:"skip_precheck"`
}

type AddNodeResponse struct {
	ErrorMsg string    `json:"error_msg"`
	Data     *NodeInfo `json:"data"`
}

type AddNodesRequest struct {
	HostID       uint                  `json:"host_id" binding:"required"`
	InstallDir   string                `json:"install_dir"`
	Entries      []AddNodeEntryRequest `json:"entries" binding:"required"`
	SkipPrecheck bool                  `json:"skip_precheck"`
}

type AddNodesResponse struct {
	ErrorMsg string      `json:"error_msg"`
	Data     []*NodeInfo `json:"data"`
}

type AgentCommandSender interface {
	// SendCommand sends a command to an agent and returns the result.
	// SendCommand 向 Agent 发送命令并返回结果。
	SendCommand(ctx context.Context, agentID string, commandType string, params map[string]string) (bool, string, error)
}

type ApplyRuntimeStorageRequest struct {
	Enabled     bool   `json:"enabled"`
	StorageType string `json:"storage_type"`
	Namespace   string `json:"namespace"`
	Endpoint    string `json:"endpoint"`
	Bucket      string `json:"bucket"`
	AccessKey   string `json:"access_key"`
	SecretKey   string `json:"secret_key"`
	// HDFS 单 NameNode / HA / Kerberos / hdfs-site
	// HDFS single NameNode / HA / Kerberos / hdfs-site
	HDFSNameNodeHost          string `json:"hdfs_namenode_host"`
	HDFSNameNodePort          int    `json:"hdfs_namenode_port"`
	HDFSHAEnabled             bool   `json:"hdfs_ha_enabled"`
	HDFSNameServices          string `json:"hdfs_name_services"`
	HDFSHANamenodes           string `json:"hdfs_ha_namenodes"`
	HDFSNamenodeRPCAddress1   string `json:"hdfs_namenode_rpc_address_1"`
	HDFSNamenodeRPCAddress2   string `json:"hdfs_namenode_rpc_address_2"`
	HDFSFailoverProxyProvider string `json:"hdfs_failover_proxy_provider"`
	KerberosPrincipal         string `json:"kerberos_principal"`
	KerberosKeytabFilePath    string `json:"kerberos_keytab_file_path"`
	HdfsSitePath              string `json:"hdfs_site_path"`
	// DisableCache 对应 disable.cache；nil 不写入。
	// DisableCache maps to disable.cache; nil omits the key.
	DisableCache *bool `json:"disable_cache"`
	// S3 凭证提供方，对应 fs.s3a.aws.credentials.provider。
	// S3 credentials provider, mapped to fs.s3a.aws.credentials.provider.
	S3CredentialsProvider string `json:"s3_credentials_provider"`
}

type ApplyRuntimeStorageResponse struct {
	ErrorMsg string                     `json:"error_msg"`
	Data     *ApplyRuntimeStorageResult `json:"data"`
}

type ApplyRuntimeStorageResult struct {
	Saved           bool                                         `json:"saved"`
	RestartRequired bool                                         `json:"restart_required"`
	Message         string                                       `json:"message"`
	Versions        []ApplyRuntimeStorageVersion                 `json:"versions,omitempty"`
	Validation      *installerapp.RuntimeStorageValidationResult `json:"validation,omitempty"`
}

type ApplyRuntimeStorageVersion struct {
	ConfigType string `json:"config_type"`
	ConfigID   uint   `json:"config_id"`
	Version    int    `json:"version"`
}

type CleanupRuntimeStorageResponse struct {
	ErrorMsg string                       `json:"error_msg"`
	Data     *RuntimeStorageCleanupResult `json:"data"`
}

type Cluster struct {
	ID             uint           `json:"id" gorm:"primaryKey;autoIncrement"`
	Name           string         `json:"name" gorm:"size:100;uniqueIndex;not null"`
	Description    string         `json:"description" gorm:"type:text"`
	DeploymentMode DeploymentMode `json:"deployment_mode" gorm:"size:20;not null"`
	Version        string         `json:"version" gorm:"size:20"`
	Status         ClusterStatus  `json:"status" gorm:"size:20;default:created;index"`
	InstallDir     string         `json:"install_dir" gorm:"size:255"`
	Config         ClusterConfig  `json:"config" gorm:"type:json"`
	CreatedAt      time.Time      `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt      time.Time      `json:"updated_at" gorm:"autoUpdateTime"`
	CreatedBy      uint           `json:"created_by"`
	Nodes          []ClusterNode  `json:"nodes" gorm:"foreignKey:ClusterID"`
}

type ClusterConfig map[string]interface{}

type ClusterFilter struct {
	Name           string         `json:"name"`
	Status         ClusterStatus  `json:"status"`
	DeploymentMode DeploymentMode `json:"deployment_mode"`
	Page           int            `json:"page"`
	PageSize       int            `json:"page_size"`
}

type ClusterInfo struct {
	ID             uint           `json:"id"`
	Name           string         `json:"name"`
	Description    string         `json:"description"`
	DeploymentMode DeploymentMode `json:"deployment_mode"`
	Version        string         `json:"version"`
	Status         ClusterStatus  `json:"status"`
	InstallDir     string         `json:"install_dir"`
	Config         ClusterConfig  `json:"config"`
	NodeCount      int            `json:"node_count"`
	OnlineNodes    int            `json:"online_nodes"`  // number of nodes whose host is online / 主机在线的节点数
	HealthStatus   string         `json:"health_status"` // healthy, unhealthy, unknown / 健康状态
	CreatedAt      time.Time      `json:"created_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
}

type ClusterMonitorPusher interface {
	PushClusterMonitorConfigToHost(ctx context.Context, clusterID uint, hostID uint) error
}

type ClusterNode struct {
	ID            uint          `json:"id" gorm:"primaryKey;autoIncrement"`
	ClusterID     uint          `json:"cluster_id" gorm:"index;not null"`
	HostID        uint          `json:"host_id" gorm:"index;not null"`
	Role          NodeRole      `json:"role" gorm:"size:20;not null"`
	InstallDir    string        `json:"install_dir" gorm:"size:255"`           // SeaTunnel installation directory on this node / 此节点上的 SeaTunnel 安装目录
	HazelcastPort int           `json:"hazelcast_port"`                        // Hazelcast cluster port / Hazelcast 集群端口
	APIPort       int           `json:"api_port"`                              // REST API port (Master only) / REST API 端口（仅 Master）
	WorkerPort    int           `json:"worker_port"`                           // Worker hazelcast port (Hybrid only) / Worker Hazelcast 端口（仅混合模式）
	Overrides     NodeOverrides `json:"overrides" gorm:"type:json"`            // Node-level JSON overrides / 节点级 JSON 覆盖配置
	Status        NodeStatus    `json:"status" gorm:"size:20;default:pending"` // Unified status field: pending, installing, running, stopped, error / 统一状态字段
	ProcessPID    int           `json:"process_pid" gorm:"column:process_pid"` // SeaTunnel process PID / SeaTunnel 进程 PID
	LastEventAt   *time.Time    `json:"last_event_at"`                         // 最后事件时间 / Last event time
	CreatedAt     time.Time     `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt     time.Time     `json:"updated_at" gorm:"autoUpdateTime"`
}

type ClusterOperationResponse struct {
	ErrorMsg string           `json:"error_msg"`
	Data     *OperationResult `json:"data"`
}

type ClusterPortConfig struct {
	MasterHazelcastPort int `json:"master_hazelcast_port,omitempty"`
	MasterAPIPort       int `json:"master_api_port,omitempty"`
	WorkerPort          int `json:"worker_port,omitempty"`
	// JavaProxyPort is the managed stx-java-proxy listen port (default 18080).
	// JavaProxyPort 是托管 stx-java-proxy 监听端口（默认 18080）。
	JavaProxyPort int `json:"java_proxy_port,omitempty"`
}

type ClusterScaleOperation struct {
	ID          uint                 `json:"id" gorm:"primaryKey;autoIncrement"`
	ExecutionID string               `json:"execution_id" gorm:"size:64;index"`
	ClusterID   uint                 `json:"cluster_id" gorm:"index;not null"`
	HostID      uint                 `json:"host_id" gorm:"index"`
	NodeIDs     string               `json:"-" gorm:"type:text"` // JSON []uint
	Kind        ScaleKind            `json:"kind" gorm:"size:20;not null"`
	Mode        ScaleMode            `json:"mode" gorm:"size:20"`
	Status      ScaleOperationStatus `json:"status" gorm:"size:20;index"`
	CurrentStep ScaleStepName        `json:"current_step" gorm:"size:40"`
	// LoopbackRestartAck / JobsRiskAck 记录提交时用户的显式确认，执行与重试时据此复核计划护栏。
	// LoopbackRestartAck / JobsRiskAck record the user's explicit acknowledgements at submission, re-checked by
	// the plan guardrails during execution and retry.
	LoopbackRestartAck bool `json:"loopback_restart_ack" gorm:"not null"`
	JobsRiskAck        bool `json:"jobs_risk_ack" gorm:"not null"`
	// RollingRestart 记录用户是否选择了扩容后的滚动重启。/ RollingRestart records whether the user chose the rolling restart.
	RollingRestart bool `json:"rolling_restart" gorm:"not null;default:false"`
	// Lang 是提交时的界面语言（zh/en），执行器据此输出单语言步骤说明。
	// Lang is the UI language at submission (zh/en); the executor writes single-language step messages with it.
	Lang      string        `json:"lang" gorm:"size:8"`
	PlanJSON  db.ScriptText `json:"-"` // 提交时的 Plan 快照（不含敏感内容） / plan snapshot at submission (no secrets)
	StepsJSON db.ScriptText `json:"-"` // []ScaleStepState
	Error     string        `json:"error" gorm:"type:text"`
	CreatedBy uint          `json:"created_by" gorm:"index"`
	// CreatedByName 是发起人登录名快照，用于并发冲突提示（用户改名不回溯）。
	// CreatedByName is a snapshot of the initiator's login name for conflict messages (not updated on rename).
	CreatedByName string     `json:"created_by_name" gorm:"size:100"`
	CreatedAt     time.Time  `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt     time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
	FinishedAt    *time.Time `json:"finished_at"`
}

type ClusterStatus string

type ClusterStatusInfo struct {
	ClusterID    uint          `json:"cluster_id"`
	ClusterName  string        `json:"cluster_name"`
	Status       ClusterStatus `json:"status"`
	HealthStatus HealthStatus  `json:"health_status"`
	TotalNodes   int           `json:"total_nodes"`
	OnlineNodes  int           `json:"online_nodes"`
	OfflineNodes int           `json:"offline_nodes"`
	// RunningNodes 是主机在线且 SeaTunnel 进程运行中的节点数。
	// RunningNodes counts nodes whose host is online and whose SeaTunnel process is running.
	RunningNodes int `json:"running_nodes"`
	// HealthReasons 解释 health_status 不健康的原因（离线、进程未运行、成员分裂）。
	// HealthReasons explains why health_status is not healthy (offline, process down, split members).
	HealthReasons []string          `json:"health_reasons,omitempty"`
	Nodes         []*NodeStatusInfo `json:"nodes"`
}

type ConfigAgentClient interface {
	PullConfig(ctx context.Context, hostID uint, installDir string, configType appconfig.ConfigType) (string, error)
	PushConfig(ctx context.Context, hostID uint, installDir string, configType appconfig.ConfigType, content string) error
}

type CreateClusterRequest struct {
	Name           string         `json:"name" binding:"required,max=100"`
	Description    string         `json:"description"`
	DeploymentMode DeploymentMode `json:"deployment_mode" binding:"required"`
	Version        string         `json:"version" binding:"required"`
	InstallDir     string         `json:"install_dir"`
	Config         ClusterConfig  `json:"config"`
	// Nodes to auto-create from discovery (optional)
	// 从发现自动创建的节点（可选）
	Nodes []CreateNodeFromDiscovery `json:"nodes,omitempty"`
}

type CreateClusterResponse struct {
	ErrorMsg string       `json:"error_msg"`
	Data     *ClusterInfo `json:"data"`
}

type CreateNodeFromDiscovery struct {
	HostID        uint   `json:"host_id"`                  // Host ID / 主机 ID
	InstallDir    string `json:"install_dir"`              // SeaTunnel installation directory / SeaTunnel 安装目录
	Role          string `json:"role"`                     // Node role: master, worker, hybrid / 节点角色
	PID           int    `json:"pid,omitempty"`            // Process ID / 进程 ID
	HazelcastPort int    `json:"hazelcast_port,omitempty"` // Hazelcast cluster port (optional) / Hazelcast 集群端口（可选）
	APIPort       int    `json:"api_port,omitempty"`       // REST API port (optional) / REST API 端口（可选）
}

type DeleteClusterResponse struct {
	ErrorMsg string `json:"error_msg"`
	Data     any    `json:"data"`
}

type DeploymentMode string

type GetClusterResponse struct {
	ErrorMsg string       `json:"error_msg"`
	Data     *ClusterInfo `json:"data"`
}

type GetClusterStatusResponse struct {
	ErrorMsg string             `json:"error_msg"`
	Data     *ClusterStatusInfo `json:"data"`
}

type GetNodeLogsRequest struct {
	Lines  int    `json:"lines" form:"lines"`   // Number of lines / 行数
	Mode   string `json:"mode" form:"mode"`     // "tail" (default), "head", "all" / 模式
	Filter string `json:"filter" form:"filter"` // Filter pattern / 过滤模式
	Date   string `json:"date" form:"date"`     // Date for rolling logs / 滚动日志日期
}

type GetNodeLogsResponse struct {
	ErrorMsg string `json:"error_msg"`
	Data     *struct {
		Logs string `json:"logs"`
	} `json:"data"`
}

type GetNodesResponse struct {
	ErrorMsg string      `json:"error_msg"`
	Data     []*NodeInfo `json:"data"`
}

type GetRuntimeStorageResponse struct {
	ErrorMsg string                 `json:"error_msg"`
	Data     *RuntimeStorageDetails `json:"data"`
}

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

type HealthStatus string

type HostInfo struct {
	ID               uint
	Name             string
	HostType         string
	IPAddress        string
	AgentID          string
	AgentStatus      string
	LastHeartbeat    *time.Time
	ProcessStartedAt *time.Time // when set, online requires heartbeat after this (e.g. API process start)
	// DiskUsage 是 Agent 心跳上报的磁盘使用率（百分比，0 表示未知），扩容预检据此给出磁盘空间警告。
	// DiskUsage is the disk usage percentage reported by Agent heartbeats (0 means unknown); scale-out prechecks use
	// it for the disk space warning.
	DiskUsage float64
}

type HostProvider interface {
	// GetHostByID retrieves host information by ID.
	// GetHostByID 根据 ID 获取主机信息。
	GetHostByID(ctx context.Context, id uint) (*HostInfo, error)
}

type InspectCheckpointRuntimeStorageResponse struct {
	ErrorMsg string                                 `json:"error_msg"`
	Data     *RuntimeStorageCheckpointInspectResult `json:"data"`
}

type InspectIMAPRuntimeStorageResponse struct {
	ErrorMsg string                           `json:"error_msg"`
	Data     *RuntimeStorageIMAPInspectResult `json:"data"`
}

type JVMConfig struct {
	HybridHeapSize int `json:"hybrid_heap_size,omitempty"`
	MasterHeapSize int `json:"master_heap_size,omitempty"`
	WorkerHeapSize int `json:"worker_heap_size,omitempty"`
}

type ListClustersRequest struct {
	Current        int            `json:"current" form:"current" binding:"min=1"`
	Size           int            `json:"size" form:"size" binding:"min=1,max=100"`
	Name           string         `json:"name" form:"name"`
	Status         ClusterStatus  `json:"status" form:"status"`
	DeploymentMode DeploymentMode `json:"deployment_mode" form:"deployment_mode"`
}

type ListClustersResponse struct {
	ErrorMsg string `json:"error_msg"`
	Data     *struct {
		Total    int64          `json:"total"`
		Clusters []*ClusterInfo `json:"clusters"`
	} `json:"data"`
}

type ListRuntimeStorageResponse struct {
	ErrorMsg string                    `json:"error_msg"`
	Data     *RuntimeStorageListResult `json:"data"`
}

type NodeInfo struct {
	ID            uint          `json:"id"`
	ClusterID     uint          `json:"cluster_id"`
	HostID        uint          `json:"host_id"`
	HostName      string        `json:"host_name"`
	HostIP        string        `json:"host_ip"`
	Role          NodeRole      `json:"role"`
	InstallDir    string        `json:"install_dir"`    // SeaTunnel installation directory / SeaTunnel 安装目录
	HazelcastPort int           `json:"hazelcast_port"` // Hazelcast cluster port / Hazelcast 集群端口
	APIPort       int           `json:"api_port"`       // REST API port (Master only) / REST API 端口（仅 Master）
	WorkerPort    int           `json:"worker_port"`    // Worker hazelcast port (Hybrid only) / Worker Hazelcast 端口（仅混合模式）
	Overrides     NodeOverrides `json:"overrides"`      // Node-level JSON overrides / 节点级 JSON 覆盖配置
	Status        NodeStatus    `json:"status"`         // Unified status: pending, installing, running, stopped, error, offline / 统一状态
	IsOnline      bool          `json:"is_online"`      // Whether host is online; when false, status may be shown as offline / 主机是否在线
	ProcessPID    int           `json:"process_pid"`    // SeaTunnel process PID / SeaTunnel 进程 PID
	CreatedAt     time.Time     `json:"created_at"`
	UpdatedAt     time.Time     `json:"updated_at"`
}

type NodeJVMOverrides struct {
	HybridHeapSize *int `json:"hybrid_heap_size,omitempty"`
	MasterHeapSize *int `json:"master_heap_size,omitempty"`
	WorkerHeapSize *int `json:"worker_heap_size,omitempty"`
}

type NodeOperationResult struct {
	NodeID   uint   `json:"node_id"`
	HostID   uint   `json:"host_id"`
	HostName string `json:"host_name"`
	Success  bool   `json:"success"`
	Message  string `json:"message"`
}

type NodeOverrides struct {
	JVM *NodeJVMOverrides `json:"jvm,omitempty"`
}

type NodeRole string

type NodeStatus string

type NodeStatusInfo struct {
	NodeID     uint       `json:"node_id"`
	HostID     uint       `json:"host_id"`
	HostName   string     `json:"host_name"`
	HostIP     string     `json:"host_ip"`
	Role       NodeRole   `json:"role"`
	Status     NodeStatus `json:"status"`      // Unified status: pending, installing, running, stopped, error / 统一状态
	IsOnline   bool       `json:"is_online"`   // Whether host is online / 主机是否在线
	ProcessPID int        `json:"process_pid"` // SeaTunnel process PID / SeaTunnel 进程 PID
	// MemberCount 是该节点看到的 Hazelcast 成员数；未知（Agent 不支持或 REST 不可达）时为空。
	// MemberCount is the number of Hazelcast members seen by this node; nil when unknown.
	MemberCount *int `json:"member_count,omitempty"`
}

type OperationEvent struct {
	ClusterID   uint
	ClusterName string
	NodeID      uint
	HostID      uint
	HostName    string
	HostIP      string
	Role        string
	Operation   OperationType
	Success     bool
	Message     string
	Operator    string
	Trigger     string
}

type OperationResult struct {
	ClusterID   uint                   `json:"cluster_id"`
	Operation   OperationType          `json:"operation"`
	Success     bool                   `json:"success"`
	Message     string                 `json:"message"`
	NodeResults []*NodeOperationResult `json:"node_results"`
}

type OperationType string

type PrecheckCheckItem struct {
	Name    string `json:"name"`    // Check name / 检查名称
	Status  string `json:"status"`  // passed, failed, skipped / 通过、失败、跳过
	Message string `json:"message"` // Detail message / 详细信息
}

type PrecheckNodeResponse struct {
	ErrorMsg string          `json:"error_msg"`
	Data     *PrecheckResult `json:"data"`
}

type PrecheckRequest struct {
	HostID        uint     `json:"host_id" binding:"required"`
	Role          NodeRole `json:"role" binding:"required"`
	InstallDir    string   `json:"install_dir"`
	HazelcastPort int      `json:"hazelcast_port" binding:"required"`
	APIPort       int      `json:"api_port"`
	WorkerPort    int      `json:"worker_port"`
}

type PrecheckResult struct {
	Success bool                 `json:"success"`
	Message string               `json:"message"`
	Checks  []*PrecheckCheckItem `json:"checks"`
}

type PreviewRuntimeStorageResponse struct {
	ErrorMsg string                       `json:"error_msg"`
	Data     *RuntimeStoragePreviewResult `json:"data"`
}

type RecordRemovalCleanup struct {
	// MembersPatched 表示剩余节点的 member-list 已修补；MembersSkippedReason 说明未修补的原因。
	// MembersPatched means the remaining nodes' member lists were patched; MembersSkippedReason explains why not.
	MembersPatched       bool     `json:"members_patched"`
	MembersSkippedReason string   `json:"members_skipped_reason,omitempty"`
	DeletedConfigs       int      `json:"deleted_configs"`
	MonitorRefreshed     bool     `json:"monitor_refreshed"`
	Warnings             []string `json:"warnings"`
}

type RemoveNodeResponse struct {
	ErrorMsg string `json:"error_msg"`
	Data     any    `json:"data"`
}

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

type RunningJobsProvider interface {
	ListClusterRunningJobs(ctx context.Context, clusterID uint) ([]ScaleRunningJob, error)
}

type RuntimeStorageCheckpointInspectJobConfig struct {
	Content       string                 `json:"content,omitempty"`
	ContentFormat string                 `json:"content_format,omitempty"`
	Variables     map[string]interface{} `json:"variables,omitempty"`
}

type RuntimeStorageCheckpointInspectResult struct {
	ClusterID           uint                                              `json:"cluster_id"`
	Path                string                                            `json:"path,omitempty"`
	FileName            string                                            `json:"file_name,omitempty"`
	StorageType         string                                            `json:"storage_type,omitempty"`
	SizeBytes           int64                                             `json:"size_bytes,omitempty"`
	Truncated           bool                                              `json:"truncated,omitempty"`
	Binary              bool                                              `json:"binary,omitempty"`
	Encoding            string                                            `json:"encoding,omitempty"`
	TextPreview         string                                            `json:"text_preview,omitempty"`
	HexPreview          string                                            `json:"hex_preview,omitempty"`
	PipelineState       map[string]interface{}                            `json:"pipeline_state,omitempty"`
	CompletedCheckpoint map[string]interface{}                            `json:"completed_checkpoint,omitempty"`
	ActionStates        []map[string]interface{}                          `json:"action_states,omitempty"`
	TaskStatistics      []map[string]interface{}                          `json:"task_statistics,omitempty"`
	SourceStateInspect  *RuntimeStorageCheckpointSourceStateInspectResult `json:"source_state_inspect,omitempty"`
}

type RuntimeStorageCheckpointSourceStateInspectResult struct {
	PipelineState       map[string]interface{}   `json:"pipeline_state,omitempty"`
	CompletedCheckpoint map[string]interface{}   `json:"completed_checkpoint,omitempty"`
	Sources             []map[string]interface{} `json:"sources,omitempty"`
	Sinks               []map[string]interface{} `json:"sinks,omitempty"`
	UnsupportedSources  []map[string]interface{} `json:"unsupported_sources,omitempty"`
	Warnings            []string                 `json:"warnings,omitempty"`
	ErrorMessage        string                   `json:"error_message,omitempty"`
}

type RuntimeStorageCleanupResult struct {
	ClusterID uint                         `json:"cluster_id"`
	Success   bool                         `json:"success"`
	Message   string                       `json:"message"`
	Nodes     []*RuntimeStorageNodeCleanup `json:"nodes,omitempty"`
}

type RuntimeStorageDetails struct {
	ClusterID            uint                `json:"cluster_id"`
	Checkpoint           *RuntimeStorageSpec `json:"checkpoint,omitempty"`
	IMAP                 *RuntimeStorageSpec `json:"imap,omitempty"`
	ConfiguredCheckpoint *RuntimeStorageSpec `json:"configured_checkpoint,omitempty"`
	ConfiguredIMAP       *RuntimeStorageSpec `json:"configured_imap,omitempty"`
	ConfigSource         string              `json:"config_source,omitempty"`
}

type RuntimeStorageIMAPInspectResult struct {
	ClusterID   uint                     `json:"cluster_id"`
	Path        string                   `json:"path,omitempty"`
	FileName    string                   `json:"file_name,omitempty"`
	StorageType string                   `json:"storage_type,omitempty"`
	SizeBytes   int64                    `json:"size_bytes,omitempty"`
	Truncated   bool                     `json:"truncated,omitempty"`
	Binary      bool                     `json:"binary,omitempty"`
	Encoding    string                   `json:"encoding,omitempty"`
	TextPreview string                   `json:"text_preview,omitempty"`
	HexPreview  string                   `json:"hex_preview,omitempty"`
	EntryCount  int                      `json:"entry_count,omitempty"`
	Entries     []map[string]interface{} `json:"entries,omitempty"`
}

type RuntimeStorageListItem struct {
	Path       string `json:"path,omitempty"`
	Name       string `json:"name,omitempty"`
	Directory  bool   `json:"directory,omitempty"`
	SizeBytes  int64  `json:"size_bytes,omitempty"`
	ModifiedAt string `json:"modified_at,omitempty"`
}

type RuntimeStorageListResult struct {
	ClusterID uint                     `json:"cluster_id"`
	Kind      string                   `json:"kind"`
	Path      string                   `json:"path,omitempty"`
	Items     []RuntimeStorageListItem `json:"items"`
}

type RuntimeStorageNodeCleanup struct {
	HostID   uint   `json:"host_id"`
	HostName string `json:"host_name"`
	Success  bool   `json:"success"`
	Message  string `json:"message"`
}

type RuntimeStorageNodeStat struct {
	NodeID    uint   `json:"node_id"`
	HostID    uint   `json:"host_id"`
	HostName  string `json:"host_name"`
	Path      string `json:"path,omitempty"`
	Exists    bool   `json:"exists"`
	SizeBytes int64  `json:"size_bytes"`
	Message   string `json:"message,omitempty"`
}

type RuntimeStoragePreviewResult struct {
	ClusterID   uint   `json:"cluster_id"`
	Kind        string `json:"kind"`
	StorageType string `json:"storage_type,omitempty"`
	Path        string `json:"path,omitempty"`
	FileName    string `json:"file_name,omitempty"`
	SizeBytes   int64  `json:"size_bytes,omitempty"`
	Truncated   bool   `json:"truncated,omitempty"`
	Binary      bool   `json:"binary,omitempty"`
	Encoding    string `json:"encoding,omitempty"`
	TextPreview string `json:"text_preview,omitempty"`
	HexPreview  string `json:"hex_preview,omitempty"`
}

type RuntimeStorageSpec struct {
	Kind        string `json:"kind"`
	Enabled     bool   `json:"enabled"`
	StorageType string `json:"storage_type"`
	Namespace   string `json:"namespace,omitempty"`
	Endpoint    string `json:"endpoint,omitempty"`
	Bucket      string `json:"bucket,omitempty"`
	External    bool   `json:"external"`
	// HDFS HA / Kerberos / hdfs-site，仅 HDFS 类型有值。
	// HDFS HA / Kerberos / hdfs-site; populated only for HDFS.
	HDFSHAEnabled             bool   `json:"hdfs_ha_enabled,omitempty"`
	HDFSNameServices          string `json:"hdfs_name_services,omitempty"`
	HDFSHANamenodes           string `json:"hdfs_ha_namenodes,omitempty"`
	HDFSNamenodeRPCAddress1   string `json:"hdfs_namenode_rpc_address_1,omitempty"`
	HDFSNamenodeRPCAddress2   string `json:"hdfs_namenode_rpc_address_2,omitempty"`
	HDFSFailoverProxyProvider string `json:"hdfs_failover_proxy_provider,omitempty"`
	HDFSNameNodeHost          string `json:"hdfs_namenode_host,omitempty"`
	HDFSNameNodePort          int    `json:"hdfs_namenode_port,omitempty"`
	KerberosPrincipal         string `json:"kerberos_principal,omitempty"`
	KerberosKeytabFilePath    string `json:"kerberos_keytab_file_path,omitempty"`
	HdfsSitePath              string `json:"hdfs_site_path,omitempty"`
	DisableCache              *bool  `json:"disable_cache,omitempty"`
	// S3CredentialsProvider 对应 fs.s3a.aws.credentials.provider。
	// S3CredentialsProvider maps to fs.s3a.aws.credentials.provider.
	S3CredentialsProvider string                    `json:"s3_credentials_provider,omitempty"`
	SizeAvailable         bool                      `json:"size_available"`
	TotalSizeBytes        int64                     `json:"total_size_bytes"`
	CleanupSupported      bool                      `json:"cleanup_supported"`
	Warning               string                    `json:"warning,omitempty"`
	Nodes                 []*RuntimeStorageNodeStat `json:"nodes,omitempty"`
}

type STXJavaProxyConfig struct {
	Port    int    `json:"port,omitempty"`
	JvmOpts string `json:"jvm_opts,omitempty"`
}

type STXJavaProxyLogPreviewResponse struct {
	ErrorMsg string                        `json:"error_msg"`
	Data     *STXJavaProxyLogPreviewResult `json:"data"`
}

type STXJavaProxyLogPreviewResult struct {
	ClusterID uint   `json:"cluster_id"`
	LogPath   string `json:"log_path,omitempty"`
	Lines     int    `json:"lines,omitempty"`
	Logs      string `json:"logs,omitempty"`
}

type STXJavaProxyResponse struct {
	ErrorMsg string              `json:"error_msg"`
	Data     *STXJavaProxyStatus `json:"data"`
}

type STXJavaProxyStatus struct {
	ClusterID   uint                   `json:"cluster_id"`
	ClusterName string                 `json:"cluster_name,omitempty"`
	NodeID      uint                   `json:"node_id,omitempty"`
	HostID      uint                   `json:"host_id,omitempty"`
	HostName    string                 `json:"host_name,omitempty"`
	HostIP      string                 `json:"host_ip,omitempty"`
	Role        string                 `json:"role,omitempty"`
	InstallDir  string                 `json:"install_dir,omitempty"`
	Version     string                 `json:"version,omitempty"`
	Service     string                 `json:"service,omitempty"`
	Managed     bool                   `json:"managed"`
	Running     bool                   `json:"running"`
	Healthy     bool                   `json:"healthy"`
	Endpoint    string                 `json:"endpoint,omitempty"`
	Port        int                    `json:"port,omitempty"`
	PID         int                    `json:"pid,omitempty"`
	LogPath     string                 `json:"log_path,omitempty"`
	Message     string                 `json:"message,omitempty"`
	JvmOpts     string                 `json:"jvm_opts,omitempty"`
	JvmMemory   map[string]interface{} `json:"jvm_memory,omitempty"`
}

type ScaleCheck struct {
	Name     string           `json:"name"`
	Status   ScaleCheckStatus `json:"status"`
	Blocking bool             `json:"blocking"`
	Message  string           `json:"message"`
	Target   string           `json:"target,omitempty"`
}

type ScaleCheckStatus string

type ScaleCheckpointStorage struct {
	Type     string `json:"type"`
	Location string `json:"location"`
	Local    bool   `json:"local"`
}

type ScaleConfigManager interface {
	GetByCluster(ctx context.Context, clusterID uint) ([]*appconfig.ConfigInfo, error)
	PatchMemberList(ctx context.Context, clusterID uint, deploymentMode string, members []string, opRef string, userID uint) (*appconfig.MemberListPatchResult, error)
	ApplyTemplatesToHost(ctx context.Context, clusterID uint, hostID uint, deploymentMode string, members []string, opRef string, userID uint) (*appconfig.ConfigChangeResult, error)
	RegisterHostConfigsFromNode(ctx context.Context, clusterID uint, hostID uint, installDir string, userID uint) (*appconfig.ConfigChangeResult, error)
	DeleteHostConfigs(ctx context.Context, clusterID uint, hostID uint) (int, error)
}

type ScaleDiscoveredProcess struct {
	PID           int
	Role          string
	InstallDir    string
	Version       string
	HazelcastPort int
	APIPort       int
}

type ScaleExecutionRequest struct {
	RequestID      string
	IdempotencyKey string
	RequestHash    string
	Confirmed      bool
	ConfirmationID string
	ClientType     string
	Lang           string
	// Username 是发起人登录名，随操作记录保存，用于并发冲突时告知其他用户是谁在操作。
	// Username is the initiator's login name, stored with the operation so a conflict can tell other users who
	// is running it.
	Username string
}

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

type ScaleInProgressError struct {
	OperationID   uint      `json:"operation_id"`
	Kind          ScaleKind `json:"kind"`
	CreatedBy     uint      `json:"created_by"`
	CreatedByName string    `json:"created_by_name"`
}

type ScaleInSubmitRequest struct {
	PlanFingerprint string `json:"plan_fingerprint" binding:"required"`
	JobsRiskAck     bool   `json:"jobs_risk_ack"`
}

type ScaleInstaller interface {
	StartInstallation(ctx context.Context, req *installerapp.InstallationRequest) (*installerapp.InstallationStatus, error)
	GetInstallationStatusSnapshot(ctx context.Context, hostID uint) (*installerapp.InstallationStatus, error)
}

type ScaleJavaProxyFollow struct {
	FromNodeID     uint   `json:"from_node_id"`
	FromHostID     uint   `json:"from_host_id"`
	FromHostName   string `json:"from_host_name"`
	FromInstallDir string `json:"from_install_dir"`
	ToNodeID       uint   `json:"to_node_id"`
	ToHostID       uint   `json:"to_host_id"`
	ToHostName     string `json:"to_host_name"`
}

type ScaleKind string

type ScaleLoopbackNode struct {
	NodeID   uint   `json:"node_id"`
	HostID   uint   `json:"host_id"`
	HostName string `json:"host_name"`
	Address  string `json:"address"`
	// Source 为 config（节点配置）或 runtime（Hazelcast 运行时成员）。
	// Source is config (node config) or runtime (Hazelcast runtime members).
	Source string `json:"source"`
}

type ScaleMode string

type ScaleNodePorts struct {
	HazelcastPort int `json:"hazelcast_port"`
	APIPort       int `json:"api_port"`
	WorkerPort    int `json:"worker_port"`
}

type ScaleOperationFilter struct {
	ClusterID   uint
	Status      ScaleOperationStatus
	OwnerUserID uint
	IncludeAll  bool
	Limit       int
}

type ScaleOperationInfo struct {
	ID                 uint                 `json:"id"`
	ExecutionID        string               `json:"execution_id"`
	ClusterID          uint                 `json:"cluster_id"`
	HostID             uint                 `json:"host_id"`
	NodeIDs            []uint               `json:"node_ids"`
	Kind               ScaleKind            `json:"kind"`
	Mode               ScaleMode            `json:"mode,omitempty"`
	Status             ScaleOperationStatus `json:"status"`
	CurrentStep        ScaleStepName        `json:"current_step"`
	LoopbackRestartAck bool                 `json:"loopback_restart_ack"`
	JobsRiskAck        bool                 `json:"jobs_risk_ack"`
	RollingRestart     bool                 `json:"rolling_restart"`
	Error              string               `json:"error,omitempty"`
	// Warnings 汇总 partial 步骤的说明，操作仍按成功结束。
	// Warnings summarizes partial steps; the operation still finishes as succeeded.
	Warnings  []string         `json:"warnings"`
	Retryable bool             `json:"retryable"`
	Plan      *ScalePlan       `json:"plan"`
	Steps     []ScaleStepState `json:"steps"`
	CreatedBy uint             `json:"created_by"`
	// CreatedByName 发起人登录名快照 / initiator login name snapshot
	CreatedByName string     `json:"created_by_name"`
	CreatedAt     time.Time  `json:"created_at"`
	UpdatedAt     time.Time  `json:"updated_at"`
	FinishedAt    *time.Time `json:"finished_at,omitempty"`
}

type ScaleOperationListData struct {
	Items []*ScaleOperationInfo `json:"items"`
}

type ScaleOperationListResponse struct {
	ErrorCode string                  `json:"error_code,omitempty"`
	ErrorMsg  string                  `json:"error_msg"`
	Data      *ScaleOperationListData `json:"data"`
}

type ScaleOperationResponse struct {
	ErrorCode string              `json:"error_code,omitempty"`
	ErrorMsg  string              `json:"error_msg"`
	Data      *ScaleOperationInfo `json:"data"`
}

type ScaleOperationStatus string

type ScaleOutRequest struct {
	HostID uint `json:"host_id" binding:"required"`
	// Mode 为 install / register；为空时使用自动识别结果。
	// Mode is install / register; empty uses the detected mode.
	Mode ScaleMode `json:"mode"`
	// Role 仅分离模式需要（master / worker）；混合模式固定为 master/worker。
	// Role is only required in separated mode (master / worker); hybrid always uses master/worker.
	Role       NodeRole       `json:"role"`
	InstallDir string         `json:"install_dir"`
	Ports      ScaleNodePorts `json:"ports"`
}

type ScaleOutSubmitRequest struct {
	ScaleOutRequest
	PlanFingerprint    string `json:"plan_fingerprint" binding:"required"`
	LoopbackRestartAck bool   `json:"loopback_restart_ack"`
	// RollingRestart 入群后滚动重启现有节点（可选，见 ScalePlan.RollingRestart）。
	// RollingRestart restarts existing nodes one by one after the join (optional, see ScalePlan.RollingRestart).
	RollingRestart bool `json:"rolling_restart"`
}

type ScalePlan struct {
	Kind               ScaleKind               `json:"kind"`
	Mode               ScaleMode               `json:"mode,omitempty"`
	DetectedMode       ScaleMode               `json:"detected_mode,omitempty"`
	ClusterID          uint                    `json:"cluster_id"`
	DeploymentMode     DeploymentMode          `json:"deployment_mode"`
	ClusterVersion     string                  `json:"cluster_version"`
	Target             ScaleTarget             `json:"target"`
	Fingerprint        string                  `json:"fingerprint"`
	MembersBefore      []string                `json:"members_before"`
	MembersAfter       []string                `json:"members_after"`
	Checks             []ScaleCheck            `json:"checks"`
	LoopbackNodes      []ScaleLoopbackNode     `json:"loopback_nodes"`
	RequiresRestartAck bool                    `json:"requires_restart_ack"`
	PluginsToReplay    []ScalePluginItem       `json:"plugins_to_replay"`
	RunningJobs        []ScaleRunningJob       `json:"running_jobs"`
	RunningJobsKnown   bool                    `json:"running_jobs_known"`
	RequiresJobsAck    bool                    `json:"requires_jobs_ack"`
	CheckpointStorage  *ScaleCheckpointStorage `json:"checkpoint_storage"`
	JavaProxyFollow    *ScaleJavaProxyFollow   `json:"java_proxy_follow"`
	// RollingRestart 只用于扩容：入群后可选的滚动重启。/ Scale-out only: the optional rolling restart after the join.
	RollingRestart  *ScaleRollingRestart `json:"rolling_restart"`
	Steps           []ScaleStepName      `json:"steps"`
	CanSubmit       bool                 `json:"can_submit"`
	BlockingReasons []string             `json:"blocking_reasons"`
	Warnings        []string             `json:"warnings"`
	// Lang 是生成本计划文案所用的语言，不参与序列化。
	// Lang is the language used for this plan's texts and is not serialized.
	Lang string `json:"-"`
}

type ScalePlanResponse struct {
	ErrorCode string     `json:"error_code,omitempty"`
	ErrorMsg  string     `json:"error_msg"`
	Data      *ScalePlan `json:"data"`
}

type ScalePluginItem struct {
	Name           string   `json:"name"`
	ArtifactID     string   `json:"artifact_id"`
	Version        string   `json:"version"`
	Status         string   `json:"status"`
	ProfileKeys    []string `json:"profile_keys"`
	ProfileUnknown bool     `json:"profile_unknown"`
	// ProfileInferred 画像由控制面缓存中的依赖反推 / profile inferred from dependencies cached on the Control Plane
	ProfileInferred bool `json:"profile_inferred"`
}

type ScalePluginReplayer interface {
	ListReplayCandidates(ctx context.Context, clusterID uint) ([]pluginapp.PluginReplayCandidate, error)
	ReplayClusterPluginsToHost(ctx context.Context, clusterID uint, hostID uint, installDir string) (*pluginapp.PluginReplayReport, error)
}

type ScaleProcessDiscoverer interface {
	DiscoverSeaTunnelProcesses(ctx context.Context, hostID uint) ([]ScaleDiscoveredProcess, error)
}

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

type ScaleRestartNode struct {
	NodeID   uint   `json:"node_id"`
	HostID   uint   `json:"host_id"`
	HostName string `json:"host_name"`
	Address  string `json:"address"`
}

type ScaleRollingRestart struct {
	Nodes       []ScaleRestartNode `json:"nodes"`
	Available   bool               `json:"available"`
	Recommended bool               `json:"recommended"`
	// BlockedReason 不可选的原因；Note 是可选但需留意的说明（如作业状态未知）。
	// BlockedReason explains why it cannot be chosen; Note is a caveat when it can (e.g. jobs unknown).
	BlockedReason string `json:"blocked_reason,omitempty"`
	Note          string `json:"note,omitempty"`
}

type ScaleRunningJob struct {
	JobID   string `json:"job_id"`
	JobName string `json:"job_name"`
}

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

type ScaleStepName string

type ScaleStepState struct {
	Name       ScaleStepName   `json:"name"`
	Status     ScaleStepStatus `json:"status"`
	Attempts   int             `json:"attempts"`
	Message    string          `json:"message,omitempty"`
	Error      string          `json:"error,omitempty"`
	StartedAt  *time.Time      `json:"started_at,omitempty"`
	FinishedAt *time.Time      `json:"finished_at,omitempty"`
	Result     json.RawMessage `json:"result,omitempty"`
}

type ScaleStepStatus string

type ScaleSubmitResponse struct {
	ErrorCode string             `json:"error_code,omitempty"`
	ErrorMsg  string             `json:"error_msg"`
	Data      *ScaleSubmitResult `json:"data"`
}

type ScaleSubmitResult struct {
	ExecutionID string              `json:"execution_id"`
	OperationID uint                `json:"operation_id"`
	Operation   *ScaleOperationInfo `json:"operation"`
}

type ScaleTarget struct {
	NodeID        uint     `json:"node_id,omitempty"`
	HostID        uint     `json:"host_id"`
	HostName      string   `json:"host_name"`
	HostIP        string   `json:"host_ip"`
	Role          NodeRole `json:"role"`
	InstallDir    string   `json:"install_dir"`
	HazelcastPort int      `json:"hazelcast_port"`
	APIPort       int      `json:"api_port"`
	WorkerPort    int      `json:"worker_port"`
	Address       string   `json:"address"`
}

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

type ServiceConfig struct {
	HeartbeatTimeout time.Duration
}

type SwitchJobLogModeRequest struct {
	Mode string `json:"mode" binding:"required"` // "per_job" or "mixed"
}

type SwitchJobLogModeResponse struct {
	ErrorMsg string                  `json:"error_msg"`
	Data     *SwitchJobLogModeResult `json:"data"`
}

type SwitchJobLogModeResult struct {
	Saved           bool   `json:"saved"`
	RestartRequired bool   `json:"restart_required"`
	Mode            string `json:"mode"`
	Message         string `json:"message"`
	ConfigVersion   int    `json:"config_version,omitempty"`
}

type UpdateClusterRequest struct {
	Name        *string        `json:"name"`
	Description *string        `json:"description"`
	Version     *string        `json:"version"`
	InstallDir  *string        `json:"install_dir"`
	Config      *ClusterConfig `json:"config"`
}

type UpdateClusterResponse struct {
	ErrorMsg string       `json:"error_msg"`
	Data     *ClusterInfo `json:"data"`
}

type UpdateNodeRequest struct {
	InstallDir    *string        `json:"install_dir"`         // SeaTunnel installation directory / SeaTunnel 安装目录
	HazelcastPort *int           `json:"hazelcast_port"`      // Hazelcast cluster port / Hazelcast 集群端口
	APIPort       *int           `json:"api_port"`            // REST API port (Master only, optional) / REST API 端口（仅 Master，可选）
	WorkerPort    *int           `json:"worker_port"`         // Worker hazelcast port (Hybrid only) / Worker Hazelcast 端口（仅混合模式）
	Overrides     *NodeOverrides `json:"overrides,omitempty"` // Node-level JSON overrides / 节点级 JSON 覆盖配置
}

type UpdateSTXJavaProxyConfigRequest struct {
	JvmOpts *string `json:"jvm_opts"`
	Port    *int    `json:"port,omitempty"`
	Restart *bool   `json:"restart,omitempty"`
}

type ValidateRuntimeStorageResponse struct {
	ErrorMsg string                                       `json:"error_msg"`
	Data     *installerapp.RuntimeStorageValidationResult `json:"data"`
}