fix: retry jitter

experimental/packages/otlp-exporter-base/src/retryable-transport.ts

@@ -21,6 +21,14 @@ const MAX_ATTEMPTS = 5;
 const INITIAL_BACKOFF = 1000;
 const MAX_BACKOFF = 5000;
 const BACKOFF_MULTIPLIER = 1.5;
+const JITTER = 0.2;
+
+/**
+ * Get a pseudo-random jitter that falls in the range of [-JITTER, +JITTER]
+ */
+function getJitter() {
+  return Math.random() * (2 * JITTER) - JITTER;
+}
 
 class RetryingTransport implements IExporterTransport {
   constructor(private _transport: IExporterTransport) {}
@@ -38,11 +46,9 @@ class RetryingTransport implements IExporterTransport {
     let attempts = MAX_ATTEMPTS;
     let nextBackoff = INITIAL_BACKOFF;
 
-    // TODO: I'm not 100% sure this is correct, please review in-depth.
     while (result.status === 'retryable' && attempts > 0) {
       attempts--;
-      const upperBound = Math.min(nextBackoff, MAX_BACKOFF);
-      const backoff = Math.random() * upperBound;
+      const backoff = Math.min(nextBackoff, MAX_BACKOFF) + getJitter();
       nextBackoff = nextBackoff * BACKOFF_MULTIPLIER;
       result = await this.retry(data, result.retryInMillis ?? backoff);
     }

experimental/packages/otlp-exporter-base/test/common/retrying-transport.test.ts

@@ -152,8 +152,8 @@ describe('RetryingTransport', function () {
 
     it('does retry 5 times, then resolves as retryable', async function () {
       // arrange
-      // make random return low values so that it does not actually need to wait long for the backoff.
-      Math.random = sinon.stub().returns(0.001);
+      // make random return a negative value so that what's passed to setTimeout() is negative and therefore gets executed immediately.
+      Math.random = sinon.stub().returns(-Infinity);
 
       const retryResponse: ExportResponse = {
         status: 'retryable',