private async makeRequest()

in src/shippers/elastic_v3/server/src/server_shipper.ts [344:361]


  private async makeRequest(events: Event[]): Promise<string> {
    const response = await fetch(this.url, {
      method: 'POST',
      body: eventsToNDJSON(events),
      headers: this.buildHeaders(this.clusterUuid, this.options.version, this.licenseId),
      ...(this.options.debug && { query: { debug: true } }),
    });

    if (this.options.debug) {
      this.initContext.logger.debug(`${response.status} - ${await response.text()}`);
    }

    if (!response.ok) {
      throw new ErrorWithCode(`${response.status} - ${await response.text()}`, `${response.status}`);
    }

    return `${response.status}`;
  }