feat(jaeger-exporter): adds flushing on an interval

closes open-telemetry#340

packages/opentelemetry-exporter-jaeger/src/jaeger.ts

@@ -23,6 +23,7 @@ import * as jaegerTypes from './types';
 import { NoopLogger } from '@opentelemetry/core';
 import * as types from '@opentelemetry/types';
 import { spanToThrift } from './transform';
+import { unrefTimer } from '@opentelemetry/core';
 
 /**
  * Format and sends span information to Jaeger Exporter.
@@ -33,6 +34,7 @@ export class JaegerExporter implements SpanExporter {
   private readonly _sender: typeof jaegerTypes.UDPSender;
   private readonly _forceFlush: boolean = true;
   private readonly _flushTimeout: number;
+  private _timer: NodeJS.Timeout;
 
   constructor(config: jaegerTypes.ExporterConfig) {
     this._logger = config.logger || new NoopLogger();
@@ -48,6 +50,16 @@ export class JaegerExporter implements SpanExporter {
       tags: jaegerTypes.ThriftUtils.getThriftTags(tags),
     };
     this._sender.setProcess(this._process);
+
+    const flushInterval = config.flushInterval || 5000;
+    this._timer = setInterval(() => {
+      this._sender.flush((numSpans: number, err?: string) => {
+        if (err) {
+          this._logger.error(`failed to flush ${numSpans} spans: ${err}`);
+        }
+      });
+    }, flushInterval);
+    unrefTimer(this._timer);
   }
 
   /** Exports a list of spans to Jaeger. */
@@ -61,6 +73,7 @@ export class JaegerExporter implements SpanExporter {
 
   /** Shutdown exporter. */
   shutdown(): void {
+    clearInterval(this._timer);
     if (!this._forceFlush) return;
     // Make an optimistic flush.
     this._sender.flush((numSpans: number, err?: string) => {

packages/opentelemetry-exporter-jaeger/src/types.ts

@@ -28,6 +28,7 @@ export interface ExporterConfig {
   maxPacketSize?: number; // default: 65000
   forceFlush?: boolean; // default: true
   flushTimeout?: number; // default: 2000
+  flushInterval?: number; // default(ms): 5000
 }
 
 // Below require is needed as jaeger-client types does not expose the thrift,