in src/shippers/elastic_v3/server/src/server_shipper.ts [328:342]
private async sendEvents(events: Event[]) {
this.initContext.logger.debug(`Reporting ${events.length} events...`);
this.inFlightRequests$.next(this.inFlightRequests$.value + 1);
try {
const code = await this.makeRequest(events);
this.reportTelemetryCounters(events, { code });
this.initContext.logger.debug(`Reported ${events.length} events...`);
} catch (error) {
this.initContext.logger.debug(`Failed to report ${events.length} events...`);
this.initContext.logger.debug(error);
this.reportTelemetryCounters(events, { code: error.code, error });
this.firstTimeOffline = undefined;
}
this.inFlightRequests$.next(Math.max(0, this.inFlightRequests$.value - 1));
}