86
87
constructor(
89
>
private readonly _logService: ILogService,
90
>
private readonly _fetchFn?: typeof globalThis.fetch,
91
>
) {
92
>
super();
93
>
this._resolvedEndpoint = resolveOtlpTracesEndpoint(_options.endpoint);
94
>
this._register(toDisposable(() => { this._disposed = true; }));
95
>
}
96
97
forwardRaw(body: Buffer, contentType: string): void {
99
return;
100
}
102
>
}
103
104
async flush(): Promise<void> {
106
>
await this._queue.queue(() => Promise.resolve());
107
>
} catch { /* never throws */ }
108
>
}
109
110
private async _sendOnce(body: Buffer, contentType: string): Promise<void> {
112
>
if (this._fetchFn) {
113
const response = await this._fetchFn(this._resolvedEndpoint, {
114
method: 'POST',