-
将迁移
+
+ 将释放
- {{ bal.wouldMigrate.local }}:{{ bal.wouldMigrate.remotePort }}
- 从 {{ shortId(bal.wouldMigrate.from) }} 迁往 {{ shortId(bal.wouldMigrate.to) }}
+ 本机将撤销 {{ bal.wouldRelease.local }}:{{ bal.wouldRelease.remotePort }}
+ 并丢回环上，由最闲节点接管
-
-
等待确认
+
+ 冷却中
- 失衡已持续 {{ Math.floor((nowMs / 1000 - bal.overloadedSince) / 60) }} 分钟，
- 需连续 {{ Math.round(bal.sustainSec / 60) }} 分钟后才会迁移
+ 本机超出份额，但距上次释放不足
+ {{ Math.round(bal.cooldownSec / 60) }} 分钟
+
+ （已过 {{ cooldownAgo }}）
+
+
+ 暂不释放
+ 本机超出份额，原因：{{ blockedLabel }}
+
+
+ 单节点
+ 本机未加入集群，无需均衡
+
已均衡
- 各节点负载在阈值内，无需迁移
+
+ 本机持有 {{ bal.selfForwards }} 条，未超平摊份额 {{ bal.share }}，无需释放
+
@@ -284,7 +313,7 @@ import { ref, reactive, computed, onMounted, onBeforeUnmount } from 'vue'
import { ElMessage } from 'element-plus'
import { api, downloadAuditCsv } from '../api'
import { canWrite } from '../auth'
-import type { BalanceNodeReport, BalanceReport, RingSnapshot, RingTaskInfo, RingLogEntry } from '../types'
+import type { BalanceReport, RingSnapshot, RingTaskInfo, RingLogEntry } from '../types'
const ring = ref
(null)
const busy = ref(false)
@@ -306,23 +335,40 @@ const load = async () => {
}
// ---- load balancer view ---- //
-// Ordered by descending score so the hottest node is always on top.
-const balNodes = computed(() => [...(bal.value?.nodes ?? [])].sort((a, b) => b.score - a.score))
-const balAvgScore = computed(() => {
- const n = bal.value?.nodes ?? []
- return n.length ? n.reduce((s, x) => s + x.score, 0) / n.length : 0
-})
-// isHot mirrors the server's rule: above ratio x mean. The server additionally
-// requires a forward-count floor and the sustained window, so a node can be
-// "hot" here while the plan is still empty — that is the waiting state.
-const isHot = (n: BalanceNodeReport) =>
- balAvgScore.value > 0 && n.score > balAvgScore.value * (bal.value?.ratio ?? 2)
-// barWidth scales against the max score rather than an absolute, so the shape is
-// readable whether the cluster is idle (scores ~5) or loaded (scores ~500).
-const barWidth = (score: number) => {
- const max = Math.max(...(bal.value?.nodes ?? []).map((n) => n.score), 1)
- return Math.min(100, Math.round((score / max) * 100))
+// Each node decides about its OWN forwards, so this page has no cluster-wide
+// plan to show — only what THIS node holds and what it is about to do.
+// Ordered by descending count: the busiest node first is what an operator
+// scanning for a hotspot wants.
+const balNodes = computed(() => [...(bal.value?.nodes ?? [])].sort((a, b) => b.forwards - a.forwards))
+// barWidth scales against the busiest node rather than an absolute, so the shape
+// is readable whether the cluster holds 3 forwards or 300. The bar is context;
+// `share` is what actually decides whether a node is over.
+const barWidth = (forwards: number) => {
+ const max = Math.max(...(bal.value?.nodes ?? []).map((n) => n.forwards), 1)
+ return Math.min(100, Math.round((forwards / max) * 100))
}
+// blockedLabel renders the server's machine reason as something readable. The
+// reason matters: "over its share but not acting" is otherwise indistinguishable
+// from "broken".
+const blockedLabel = computed(() => {
+ switch (bal.value?.blockedBy) {
+ case 'cooldown': return '冷却期未过'
+ case 'in-flight': return '上一次释放尚未确认'
+ case 'nothing-active': return '本机可释放的转发都已停用'
+ case 'below-min': return '持有量低于下限'
+ case 'single-node': return '单节点环'
+ default: return bal.value?.blockedBy || '未说明'
+ }
+})
+// cooldownAgo says how long ago the last release was, so an operator can see
+// whether the cooldown is about to expire.
+const cooldownAgo = computed(() => {
+ const t = bal.value?.lastReleaseAt ?? 0
+ if (!t) return ''
+ const s = Math.max(0, Math.floor(nowMs.value / 1000) - t)
+ if (s < 60) return s + ' 秒前'
+ return Math.floor(s / 60) + ' 分钟前'
+})
const shortId = (id: string) => (id.length > 22 ? '…' + id.slice(-20) : id)
@@ -776,7 +822,11 @@ onBeforeUnmount(() => {
min-width: 0;
}
.bal-node.self { border-color: var(--w4f-primary); }
-.bal-node.hot { border-color: var(--w4f-warning); }
+.bal-node.over { border-color: var(--w4f-warning); }
+.bal-note {
+ margin: 0 0 10px; font-size: 11.5px; line-height: 1.55;
+ color: var(--w4f-muted);
+}
.bn-top { display: flex; align-items: center; gap: 6px; flex-wrap: wrap; margin-bottom: 7px; }
.bn-id {
font-family: var(--w4f-mono, ui-monospace, monospace);