impl

type AgentServiceImpl struct {
	ioc.ObjectImpl

	// Agent 任务运行广播主题
	TaskRunTopic string `json:"task_run_topic" toml:"task_run_topic" yaml:"task_run_topic"`
	// Agent调度确认超时时间，单位秒
	ScheduledConfirmTTL int64 `json:"scheduled_confirm_ttl" toml:"scheduled_confirm_ttl" yaml:"scheduled_confirm_ttl"`

	// 负载均衡配置
	// Redis Key 前缀 - 存储各节点的 Agent 数量
	RedisKeyNodeAgents string `json:"redis_key_node_agents" toml:"redis_key_node_agents" yaml:"redis_key_node_agents"`
	// Redis Key 前缀 - 存储活跃节点列表
	RedisKeyNodeActive string `json:"redis_key_node_active" toml:"redis_key_node_active" yaml:"redis_key_node_active"`
	// Redis Key 前缀 - 节点最后心跳时间
	RedisKeyNodeLastHeartbeat string `json:"redis_key_node_last_heartbeat" toml:"redis_key_node_last_heartbeat" yaml:"redis_key_node_last_heartbeat"`
	// 允许的不均衡阈值（当前节点数量 > 平均值 * 阈值时拒绝注册）
	BalanceThreshold float64 `json:"balance_threshold" toml:"balance_threshold" yaml:"balance_threshold"`
	// 最小均衡节点数，低于该数量不进行均衡检查
	BalanceMinAgents int `json:"balance_min_agents" toml:"balance_min_agents" yaml:"balance_min_agents"`
	// 节点超时时间（秒），超过此时间未心跳的节点视为离线
	NodeTimeout int64 `json:"node_timeout" toml:"node_timeout" yaml:"node_timeout"` // 节点名称
	// 节点名称
	NodeName string `json:"node_name" toml:"node_name" yaml:"node_name"`
	// 注册锁超时时间（秒）
	RegistryLockTimeoutSeconds int64 `json:"registry_lock_timeout_second" toml:"registry_lock_timeout_second" yaml:"registry_lock_timeout_second"`

	// 性能优化：异步批量心跳更新（基于消息总线）
	// 心跳事件发布Topic
	HeartbeatTopic string `json:"heartbeat_topic" toml:"heartbeat_topic" yaml:"heartbeat_topic"`
	// 心跳批量处理间隔（默认1秒）
	HeartbeatBatchInterval time.Duration `json:"heartbeat_batch_interval" toml:"heartbeat_batch_interval" yaml:"heartbeat_batch_interval"`
	// 心跳批量大小（达到该数量即触发处理）
	HeartbeatBatchSize int `json:"heartbeat_batch_size" toml:"heartbeat_batch_size" yaml:"heartbeat_batch_size"`
	// contains filtered or unexported fields
}

type BalanceDecision struct {
	// 是否允许注册
	Allowed bool
	// 原因说明
	Reason string
	// 建议注册的节点（如果当前节点不允许）
	SuggestedNode string
	// 当前节点 Agent 数量
	CurrentCount int64
	// 平均 Agent 数量
	AverageCount float64
}

type HeartbeatEvent struct {
	AgentId   string             `json:"agent_id"`
	Timestamp time.Time          `json:"timestamp"`
	Status    *agent.AgentStatus `json:"status"`
}

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

type NodeLoadInfo struct {
	NodeName      string
	AgentCount    int64
	LastHeartbeat int64
	IsActive      bool
}

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

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