gru/RustProxy
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v0.34.3_hf1

Browse Source
This commit is contained in:
Mateusz Gruszczyński committed 2026-10-20 11:48:59 +02:00
1 parent 8f41b39c26
commit 29d9a7dd6c
10 files changed
+122 -68
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/admin/web/app/runtime.js
+14 -17
View File
@@ -174,7 +174,6 @@ $("reload-certificates").addEventListener("click", async () => {
$("reset-certificate").addEventListener("click", () => { $("certificate-form").reset(); $("certificate-file-source").value = "managed"; syncCertificateFileSource(); });
syncCertificateFileSource();
let cacheMixLastCounters = null, cacheMixLastShares = null, cacheMixLastTotal = 0;
let systemSamples = [], connectionOpenSamples = [], connectionExchangeSamples = [], cacheMemorySamples = [], cacheTransientSamples = [], cacheFillSamples = [], cacheColdQueueSamples = [], cacheColdIoSamples = [], cacheColdStorageSamples = [], cacheHitSamples = [], cacheMissSamples = [], cacheBypassSamples = [], lastCacheCounters = null, lastCacheOutcomeRates = null,
processCpuSamples = [], processRssSamples = [], networkRxSamples = [], networkTxSamples = [], responseLatencySamples = [], networkInterfaceSamples = new Map(), settingsDirty = new Set();
const hiddenNetworkInterfaces = (() => {
@@ -332,32 +331,36 @@ function renderNetworkInterfaceCharts(interfaces, appendSample) {
}
}
function cacheOutcomeMix(deltas) {
if (!Array.isArray(deltas) || deltas.length !== 4 ||
deltas.some(value => !Number.isFinite(value) || value < 0)) return null;
const [requests, hits, misses, bypasses] = deltas;
// Cumulative process counters, not rate-sampler deltas. Never invent OTHER
// or force a 100% mix if independently read totals are inconsistent.
function cacheOutcomeMix(totals) {
if (!Array.isArray(totals) || totals.length !== 4 ||
totals.some(value => !Number.isSafeInteger(value) || value < 0)) return null;
const [requests, hits, misses, bypasses] = totals;
const cacheTotal = hits + misses + bypasses;
if (requests <= 0 || cacheTotal > requests) return null;
if (requests === 0 || !Number.isSafeInteger(cacheTotal) || cacheTotal > requests) return null;
const counts = [hits, misses, bypasses, requests - cacheTotal];
return { counts, percentages: counts.map(value => value / requests * 100), requests };
}
function renderCacheMix(mix) {
function renderCacheMix(mix, totalRequests) {
const names = ["hit", "miss", "bypass", "other"];
const unavailable = t(totalRequests === 0 ? "cacheMixWaiting" : "cacheMixInvalid");
names.forEach((name, i) => {
const pct = mix ? mix.percentages[i] : 0;
$(`cache-mix-${name}`).style.width = `${pct}%`;
$(`cache-mix-${name}-count`).textContent = mix ? fmt(mix.counts[i]) : "-";
$(`cache-mix-${name}-percent`).textContent = mix ? `${fmt(pct, 1)}%` : "-";
});
$("cache-mix-headline").textContent = mix ? `${fmt(mix.percentages[0], 1)}% HIT` : "-";
$("cache-mix-caption").textContent = mix
? t("cacheMixSample").replace("{count}", fmt(mix.requests))
: t("cacheMixWaiting");
: unavailable;
$("cache-mix-bar").setAttribute("aria-label", mix
? t("cacheMixAria").replace("{hit}", fmt(mix.counts[0]))
.replace("{miss}", fmt(mix.counts[1]))
.replace("{bypass}", fmt(mix.counts[2]))
.replace("{other}", fmt(mix.counts[3]))
: t("cacheMixWaiting"));
: unavailable);
}
function renderDiagnostics(status, appendSample = true, systemSample = appendSample) {
const d = status.system || {}, live = status.live_system || d, c = status.cache || {}, m = status.metrics || {};
@@ -366,14 +369,8 @@ function renderDiagnostics(status, appendSample = true, systemSample = appendSam
const cacheEvents = cacheHits !== null && cacheMisses !== null ? cacheHits + cacheMisses : 0;
$("metric-cache-ratio").textContent = cacheEvents > 0 ? `${fmt(cacheHits / cacheEvents * 100, 1)}%` : "-";
window.rustProxyExtraOverview?.donut?.("cache-ratio", cacheHits, cacheMisses);
if (appendSample) {
const counters = [m.requests, c.hits, c.misses, c.bypasses].map(value => value == null ? NaN : Number(value));
const delta = rustProxyRateSampling.difference(cacheMixLastCounters, counters,
performance.now(), rustProxyRateSampling.cadence("overview_seconds"));
cacheMixLastCounters = counters.every(Number.isFinite) ? delta.next : null;
cacheMixLastShares = delta.deltas ? cacheOutcomeMix(delta.deltas) : null;
}
renderCacheMix(cacheMixLastShares);
const counters = [m.requests, c.hits, c.misses, c.bypasses].map(value => value == null ? NaN : Number(value));
renderCacheMix(cacheOutcomeMix(counters), counters[0]);
if (systemSample) {
if (d.process_rss_bytes != null) $("metric-rss").textContent = fmtBytes(d.process_rss_bytes);
$("process-summary").hidden = d.process_threads == null;