From bce557cc2dc767628bed6aac87301a1be7c5431b Mon Sep 17 00:00:00 2001 From: rxliuli Date: Tue, 4 Nov 2025 05:03:50 +0800 Subject: init commit --- shared/metrics-8/src/recorder/composite.ts | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 shared/metrics-8/src/recorder/composite.ts (limited to 'shared/metrics-8/src/recorder/composite.ts') diff --git a/shared/metrics-8/src/recorder/composite.ts b/shared/metrics-8/src/recorder/composite.ts new file mode 100644 index 0000000..6302921 --- /dev/null +++ b/shared/metrics-8/src/recorder/composite.ts @@ -0,0 +1,20 @@ +import type { MetricsEventRecorder } from '@jet/engine'; +import type { LintedMetricsEvent } from '@jet/environment/types/metrics'; +import type { Opt } from '@jet/environment/types/optional'; + +export class CompositeEventRecorder implements MetricsEventRecorder { + constructor(private readonly eventRecorders: MetricsEventRecorder[]) {} + + record(event: LintedMetricsEvent, topic: Opt): void { + for (const eventRecorder of this.eventRecorders) { + eventRecorder.record(event, topic); + } + } + + async flush(): Promise { + const flushed: number[] = await Promise.all( + this.eventRecorders.map((recorder) => recorder.flush()), + ); + return Math.max(...flushed); + } +} -- cgit v1.2.3