grpc

type AgentReadyHook func(ctx context.Context, hostID uint)

type ClusterNodeProvider interface {
	GetNodeByHostAndInstallDirAndRole(ctx context.Context, hostID uint, installDir, role string) (clusterID, nodeID uint, found bool, err error)
	// GetNodesByHostID returns all nodes on a specific host with their cluster's monitor config.
	// GetNodesByHostID 返回特定主机上的所有节点及其集群的监控配置。
	GetNodesByHostID(ctx context.Context, hostID uint) ([]*NodeWithMonitorConfig, error)
	// UpdateNodeProcessStatus updates the process PID and status for a node.
	// UpdateNodeProcessStatus 更新节点的进程 PID 和状态。
	UpdateNodeProcessStatus(ctx context.Context, nodeID uint, pid int, status string) error
	// RefreshClusterStatusFromNodes recalculates cluster status from its nodes (e.g. after heartbeat).
	// RefreshClusterStatusFromNodes 根据节点状态重新计算集群状态（如心跳更新节点后）。
	RefreshClusterStatusFromNodes(ctx context.Context, clusterID uint)
	// GetClusterNodeDisplayInfo returns cluster name and node display "主机名 - 角色" for audit resource name.
	// GetClusterNodeDisplayInfo 返回集群名及节点展示「主机名 - 角色」，用于审计资源名称。
	GetClusterNodeDisplayInfo(ctx context.Context, clusterID, nodeID uint) (clusterName, nodeDisplay string)
}

type MonitorService interface {
	GetConfig(ctx context.Context, clusterID uint) (*monitor.MonitorConfig, error)
	RecordEventFromReport(ctx context.Context, clusterID, nodeID, hostID uint, eventType monitor.ProcessEventType, pid int, processName, installDir, role string, details map[string]string) error
}

type NodeWithMonitorConfig struct {
	ClusterID     uint                   `json:"cluster_id"`
	NodeID        uint                   `json:"node_id"`
	InstallDir    string                 `json:"install_dir"`
	Role          string                 `json:"role"`
	ProcessPID    int                    `json:"process_pid"`
	MonitorConfig *monitor.MonitorConfig `json:"monitor_config"`
	// JavaHome 是节点指定的 JDK（cluster_nodes.java_home），Agent 自动拉起时使用；为空表示自动探测。
	// JavaHome is the node JDK (cluster_nodes.java_home) used by Agent auto-restart; empty means auto detection.
	JavaHome string `json:"java_home"`
}

type Server struct {
	pb.UnimplementedAgentServiceServer
	// contains filtered or unexported fields
}

type ServerConfig struct {
	// Port is the port number for the gRPC server.
	// Port 是 gRPC 服务器的端口号。
	Port int

	// TLSEnabled indicates whether TLS is enabled.
	// TLSEnabled 表示是否启用 TLS。
	TLSEnabled bool

	// CertFile is the path to the TLS certificate file.
	// CertFile 是 TLS 证书文件的路径。
	CertFile string

	// KeyFile is the path to the TLS key file.
	// KeyFile 是 TLS 密钥文件的路径。
	KeyFile string

	// CAFile is the path to the CA certificate file for client verification.
	// CAFile 是用于客户端验证的 CA 证书文件路径。
	CAFile string

	// MaxRecvMsgSize is the maximum receive message size in bytes.
	// MaxRecvMsgSize 是最大接收消息大小（字节）。
	MaxRecvMsgSize int

	// MaxSendMsgSize is the maximum send message size in bytes.
	// MaxSendMsgSize 是最大发送消息大小（字节）。
	MaxSendMsgSize int

	// HeartbeatInterval is the heartbeat interval to send to Agents (seconds).
	// HeartbeatInterval 是发送给 Agent 的心跳间隔（秒）。
	HeartbeatInterval int
}