discovery

type AgentDiscoverer interface {
	TriggerDiscovery(ctx context.Context, agentID string) ([]*DiscoveredCluster, error)
	DiscoverProcesses(ctx context.Context, agentID string) ([]*DiscoveredProcess, error)
}

type ClusterMatcher interface {
	FindClusterByInstallDir(ctx context.Context, hostID uint, installDir string) (clusterID uint, nodeID uint, found bool, err error)
	CreateClusterFromDiscovery(ctx context.Context, hostID uint, cluster *DiscoveredCluster) (uint, error)
	UpdateNodeFromDiscovery(ctx context.Context, nodeID uint, node *DiscoveredNode) error
}

type ConfirmDiscoveryRequest struct {
	HostID      uint     `json:"host_id" binding:"required"`
	ClusterIDs  []string `json:"cluster_ids"`  // 要纳管的集群标识 / Cluster identifiers to manage
	InstallDirs []string `json:"install_dirs"` // 要纳管的安装目录 / Install directories to manage
	// JavaHomes 按安装目录指定节点 JDK；空值表示自动探测（AC1e）。
	// JavaHomes maps install directories to node JDKs; empty means auto detection (AC1e).
	JavaHomes map[string]string `json:"java_homes,omitempty"`
}

type DiscoveredCluster struct {
	Name           string                 `json:"name"`
	InstallDir     string                 `json:"install_dir"`
	Version        string                 `json:"version"`
	DeploymentMode string                 `json:"deployment_mode"`
	Nodes          []*DiscoveredNode      `json:"nodes"`
	Config         map[string]interface{} `json:"config"`
	DiscoveredAt   time.Time              `json:"discovered_at"`
	IsNew          bool                   `json:"is_new"`      // 是否为新发现的集群 / Whether it's a newly discovered cluster
	ExistingID     uint                   `json:"existing_id"` // 如果已存在，关联的集群 ID / If exists, the associated cluster ID
	// JavaHome 是纳管时用户选定的节点 JDK；空表示自动探测（AC1e）。实现 CreateClusterFromDiscovery 时应写入节点。
	// JavaHome is the node JDK chosen at import; empty means auto detection (AC1e). CreateClusterFromDiscovery should persist it.
	JavaHome string `json:"java_home,omitempty"`
}

type DiscoveredNode struct {
	PID           int       `json:"pid"`
	Role          string    `json:"role"`
	HazelcastPort int       `json:"hazelcast_port"`
	APIPort       int       `json:"api_port"`
	StartTime     time.Time `json:"start_time"`
	// JavaHome 是进程实际 JDK（AC1f）/ Process actual JDK (AC1f)
	JavaHome string `json:"java_home,omitempty"`
}

type DiscoveredProcess struct {
	PID           int    `json:"pid"`
	Role          string `json:"role"`                   // master, worker, or hybrid
	InstallDir    string `json:"install_dir"`            // SeaTunnel installation directory / SeaTunnel 安装目录
	Version       string `json:"version"`                // SeaTunnel version / SeaTunnel 版本
	HazelcastPort int    `json:"hazelcast_port"`         // Hazelcast cluster port / Hazelcast 集群端口
	APIPort       int    `json:"api_port"`               // REST API port / REST API 端口
	ClusterName   string `json:"cluster_name,omitempty"` // Hazelcast cluster-name / Hazelcast 集群标识
	// JavaHome 是进程实际使用的 JDK（由 Agent 从 /proc/<pid>/exe 解析）；解析不到为空（AC1f）。
	// JavaHome is the JDK the process actually uses (resolved by the Agent from /proc/<pid>/exe); empty when unresolved (AC1f).
	JavaHome string `json:"java_home,omitempty"`
}

type DiscoveryResult struct {
	Success    bool                 `json:"success"`
	Message    string               `json:"message"`
	Clusters   []*DiscoveredCluster `json:"clusters"`
	NewCount   int                  `json:"new_count"`
	ExistCount int                  `json:"exist_count"`
}

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

type HostInfo struct {
	ID          uint
	Name        string
	IPAddress   string
	AgentID     string
	AgentStatus string
}

type HostProvider interface {
	GetHostByID(ctx context.Context, hostID uint) (*HostInfo, error)
	GetHostByAgentID(ctx context.Context, agentID string) (*HostInfo, error)
}

type ProcessDiscoveryResult struct {
	Success   bool                 `json:"success"`
	Message   string               `json:"message"`
	Processes []*DiscoveredProcess `json:"processes"`
}

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