var Component = (() => { var __create = Object.create; var __defProp = Object.defineProperty; var __getOwnPropDesc = Object.getOwnPropertyDescriptor; var __getOwnPropNames = Object.getOwnPropertyNames; var __getProtoOf = Object.getPrototypeOf; var __hasOwnProp = Object.prototype.hasOwnProperty; var __esm = (fn, res) => function __init() { return fn && (res = (0, fn[__getOwnPropNames(fn)[0]])(fn = 0)), res; }; var __commonJS = (cb, mod) => function __require() { return mod || (0, cb[__getOwnPropNames(cb)[0]])((mod = { exports: {} }).exports, mod), mod.exports; }; var __export = (target, all) => { for (var name in all) __defProp(target, name, { get: all[name], enumerable: true }); }; var __copyProps = (to, from, except, desc) => { if (from && typeof from === "object" || typeof from === "function") { for (let key of __getOwnPropNames(from)) if (!__hasOwnProp.call(to, key) && key !== except) __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable }); } return to; }; var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps( // If the importer is in node compatibility mode or this is not an ESM // file that has been converted to a CommonJS file using a Babel- // compatible transform (i.e. "__esModule" has not been set), then set // "default" to the CommonJS "module.exports" for node compatibility. isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target, mod )); var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); // var init_define_process_env = __esm({ ""() { } }); // global-externals:react/jsx-runtime var require_jsx_runtime = __commonJS({ "global-externals:react/jsx-runtime"(exports, module) { init_define_process_env(); module.exports = _jsx_runtime; } }); // _mdx_bundler_entry_point-ff619260-349d-4752-8845-0461fce75f7c.mdx var mdx_bundler_entry_point_ff619260_349d_4752_8845_0461fce75f7c_exports = {}; __export(mdx_bundler_entry_point_ff619260_349d_4752_8845_0461fce75f7c_exports, { default: () => MDXContent, frontmatter: () => frontmatter, toc: () => toc }); init_define_process_env(); var import_jsx_runtime = __toESM(require_jsx_runtime()); // global-externals:@mdx-js/react init_define_process_env(); var { useMDXComponents } = MdxJsReact; // _mdx_bundler_entry_point-ff619260-349d-4752-8845-0461fce75f7c.mdx var toc = []; var frontmatter = { "sidebar-title": "Metrics Flow" }; function _createMdxContent(props) { const { ErrorBoundary, Mermaid } = { ...useMDXComponents(), ...props.components }; if (!ErrorBoundary) _missingMdxReference("ErrorBoundary", true); if (!Mermaid) _missingMdxReference("Mermaid", true); return (0, import_jsx_runtime.jsx)(ErrorBoundary, { children: (0, import_jsx_runtime.jsx)(Mermaid, { children: 'flowchart TD\n %% Input Data\n A["Parsed Inference Results
(Load Balanced)"]\n\n %% Stage 1: Distributed Record Processing\n A --> B1["MetricRecordProcessor
(Distributed instance 1)"]\n A --> B2["MetricRecordProcessor
(Distributed instance 2)"]\n A --> B3["MetricRecordProcessor
(Distributed instance N)"]\n\n %% RECORD Metric Path\n B1 --> C1["RECORD: RequestLatencyMetric
parse_record() \u2192 125ms
(Individual value per request)"]\n B2 --> C2["RECORD: RequestLatencyMetric
parse_record() \u2192 87ms
(Individual value per request)"]\n B3 --> C3["RECORD: RequestLatencyMetric
parse_record() \u2192 203ms
(Individual value per request)"]\n\n %% AGGREGATE Metric Path\n B1 --> D1["AGGREGATE: TotalRequestsMetric
parse_record() \u2192 +1
(Individual contribution)"]\n B2 --> D2["AGGREGATE: TotalRequestsMetric
parse_record() \u2192 +1
(Individual contribution)"]\n B3 --> D3["AGGREGATE: TotalRequestsMetric
parse_record() \u2192 +1
(Individual contribution)"]\n\n %% MetricRecordDict Collection\n C1 --> E1["MetricRecordDict
(Per-record results)"]\n D1 --> E1\n C2 --> E2["MetricRecordDict
(Per-record results)"]\n D2 --> E2\n C3 --> E3["MetricRecordDict
(Per-record results)"]\n D3 --> E3\n\n %% Stage 2: Centralized Results Processing\n E1 --> G["RecordsManager \u2192 MetricResultsProcessor
(Single centralized instance)"]\n E2 --> G\n E3 --> G\n\n %% RECORD Processing in Central\n G --> H1["RECORD Collection
append(125ms)
append(87ms)
append(203ms)
(Collect all individual values)"]\n\n %% AGGREGATE Processing in Central\n G --> H2["AGGREGATE Accumulation
aggregate_value(+1) \u2192 total=1
aggregate_value(+1) \u2192 total=2
aggregate_value(+1) \u2192 total=3
(Accumulate across processors)"]\n\n H1 --> L["MetricResultsDict
(Full profile run results)"]\n H2 --> L\n\n %% Stage 4: Summarize Function Processing\n L --> I2["Summarize Function
summarize()
(Process all collected results)"]\n\n %% Three outputs from Summarize Function\n I2 --> J1["RECORD Statistics
p50=125ms, p95=203ms
mean=138ms, std=58ms
min=87ms, max=203ms
(Full statistical analysis)"]\n\n I2 --> J2["AGGREGATE Results
final_value=3
count=1
(Single accumulated total)"]\n\n I2 --> J3["DERIVED: ThroughputMetric
derive_value(results)
= total_requests / duration
= 3 / 5.2s = 0.58 req/s
(Computed from other metrics)"]\n\n %% Final Output\n J1 --> K["MetricResult List
Complete performance analysis"]\n J2 --> K\n J3 --> K\n\n %% Styling\n classDef input fill:#e3f2fd,stroke:#1976d2,stroke-width:2px,color:#000000,font-weight:bold\n classDef distributed fill:#e8f5e8,stroke:#388e3c,stroke-width:2px,color:#000000,font-weight:bold\n classDef recordMetric fill:#fff3e0,stroke:#f57c00,stroke-width:2px,color:#000000,font-weight:bold\n classDef aggregateMetric fill:#fce4ec,stroke:#c2185b,stroke-width:2px,color:#000000,font-weight:bold\n classDef derivedMetric fill:#f3e5f5,stroke:#7b1fa2,stroke-width:2px,color:#000000,font-weight:bold\n classDef transport fill:#e0f2f1,stroke:#00695c,stroke-width:2px,color:#000000,font-weight:bold\n classDef central fill:#ffebee,stroke:#d32f2f,stroke-width:2px,color:#000000,font-weight:bold\n classDef collection fill:#fff8e1,stroke:#ffa000,stroke-width:2px,color:#000000,font-weight:bold\n classDef statistics fill:#e1f5fe,stroke:#0277bd,stroke-width:2px,color:#000000,font-weight:bold\n classDef output fill:#e8f5e8,stroke:#2e7d32,stroke-width:3px,color:#000000,font-weight:bold\n\n %% Apply styles\n class A input\n class B1,B2,B3 distributed\n class C1,C2,C3,J1,H1 recordMetric\n class D1,D2,D3,J2,H2 aggregateMetric\n class J3 derivedMetric\n class I2 central\n class I1,G statistics\n class E1,E2,E3,F,L transport\n class K output\n' }) }); } function MDXContent(props = {}) { const { wrapper: MDXLayout } = { ...useMDXComponents(), ...props.components }; return MDXLayout ? (0, import_jsx_runtime.jsx)(MDXLayout, { ...props, children: (0, import_jsx_runtime.jsx)(_createMdxContent, { ...props }) }) : _createMdxContent(props); } function _missingMdxReference(id, component) { throw new Error("Expected " + (component ? "component" : "object") + " `" + id + "` to be defined: you likely forgot to import, pass, or provide it."); } return __toCommonJS(mdx_bundler_entry_point_ff619260_349d_4752_8845_0461fce75f7c_exports); })(); ;return Component;