34 lines
803 B
TypeScript
34 lines
803 B
TypeScript
|
import { TARGET, SpanId } from '../shared'
|
||
|
|
import reportToConsole from './to-console'
|
||
|
|
import reportToZipkin from './to-zipkin'
|
||
|
|
import reportToTelemetry from './to-telemetry'
|
||
|
|
|
||
|
|
type Reporter = (
|
||
|
|
spanName: string,
|
||
|
|
duration: number,
|
||
|
|
timestamp: number,
|
||
|
|
id: SpanId,
|
||
|
|
parentId?: SpanId,
|
||
|
|
attrs?: Object
|
||
|
|
) => void
|
||
|
|
|
||
|
|
const target =
|
||
|
|
process.env.TRACE_TARGET && process.env.TRACE_TARGET in TARGET
|
||
|
|
? TARGET[process.env.TRACE_TARGET as TARGET]
|
||
|
|
: TARGET.TELEMETRY
|
||
|
|
|
||
|
|
if (process.env.TRACE_TARGET && !target) {
|
||
|
|
console.info(
|
||
|
|
'For TRACE_TARGET, please specify one of: CONSOLE, ZIPKIN, TELEMETRY'
|
||
|
|
)
|
||
|
|
}
|
||
|
|
|
||
|
|
export let report: Reporter
|
||
|
|
if (target === TARGET.CONSOLE) {
|
||
|
|
report = reportToConsole
|
||
|
|
} else if (target === TARGET.ZIPKIN) {
|
||
|
|
report = reportToZipkin
|
||
|
|
} else {
|
||
|
|
report = reportToTelemetry
|
||
|
|
}
|