55 lines
1.8 KiB
TypeScript
55 lines
1.8 KiB
TypeScript
import { DataFrame, FieldType, MutableDataFrame, TraceSpanRow } from '@grafana/data';
|
|
|
|
import { Span, TraceProcess, TraceResponse } from './types';
|
|
|
|
export function createTraceFrame(data: TraceResponse): DataFrame {
|
|
const spans = data.spans.map((s) => toSpanRow(s, data.processes));
|
|
|
|
const frame = new MutableDataFrame({
|
|
fields: [
|
|
{ name: 'traceID', type: FieldType.string },
|
|
{ name: 'spanID', type: FieldType.string },
|
|
{ name: 'parentSpanID', type: FieldType.string },
|
|
{ name: 'operationName', type: FieldType.string },
|
|
{ name: 'serviceName', type: FieldType.string },
|
|
{ name: 'serviceTags', type: FieldType.other },
|
|
{ name: 'startTime', type: FieldType.number },
|
|
{ name: 'duration', type: FieldType.number },
|
|
{ name: 'logs', type: FieldType.other },
|
|
{ name: 'tags', type: FieldType.other },
|
|
{ name: 'warnings', type: FieldType.other },
|
|
{ name: 'stackTraces', type: FieldType.other },
|
|
],
|
|
meta: {
|
|
preferredVisualisationType: 'trace',
|
|
},
|
|
});
|
|
|
|
for (const span of spans) {
|
|
frame.add(span);
|
|
}
|
|
|
|
return frame;
|
|
}
|
|
|
|
function toSpanRow(span: Span, processes: Record<string, TraceProcess>): TraceSpanRow {
|
|
return {
|
|
spanID: span.spanID,
|
|
traceID: span.traceID,
|
|
parentSpanID: span.references?.find((r) => r.refType === 'CHILD_OF')?.spanID,
|
|
operationName: span.operationName,
|
|
// from micro to millis
|
|
startTime: span.startTime / 1000,
|
|
duration: span.duration / 1000,
|
|
logs: span.logs.map((l) => ({
|
|
...l,
|
|
timestamp: l.timestamp / 1000,
|
|
})),
|
|
tags: span.tags,
|
|
warnings: span.warnings ?? undefined,
|
|
stackTraces: span.stackTraces,
|
|
serviceName: processes[span.processID].serviceName,
|
|
serviceTags: processes[span.processID].tags,
|
|
};
|
|
}
|