IntenseWebs/grafana
3
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-02-25 18:55:37 -06:00
Code Issues Packages Projects Releases Wiki Activity

devenv:loki faster test-data generation (#68201)

Browse Source
This commit is contained in:
Gábor Farkas 2023-05-10 13:54:50 +02:00 committed by GitHub
parent b0e681c339
commit 62a660c6f6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
devenv/docker/blocks/loki/data/data.js
View File

@ -176,8 +176,8 @@ async function sendOldLogs() {
const timestampNs = `${timestampMs}${getRandomNanosecPart()}`; const timestampNs = `${timestampMs}${getRandomNanosecPart()}`;
globalCounter += 1; globalCounter += 1;
const item = getRandomLogItem(globalCounter) const item = getRandomLogItem(globalCounter)
await lokiSendLogLine(timestampNs, JSON.stringify(item), {place:'moon', ...sharedLabels}); await lokiSendLogLine(timestampNs, JSON.stringify(item), {age:'old', place:'moon', ...sharedLabels});
await lokiSendLogLine(timestampNs, logFmtLine(item), {place:'luna', ...sharedLabels}); await lokiSendLogLine(timestampNs, logFmtLine(item), {age:'old', place:'luna', ...sharedLabels});
}; };
} }
@ -187,18 +187,16 @@ async function sendNewLogs() {
const nowMs = new Date().getTime(); const nowMs = new Date().getTime();
const timestampNs = `${nowMs}${getRandomNanosecPart()}`; const timestampNs = `${nowMs}${getRandomNanosecPart()}`;
const item = getRandomLogItem(globalCounter) const item = getRandomLogItem(globalCounter)
await lokiSendLogLine(timestampNs, JSON.stringify(item), {place:'moon', ...sharedLabels}); await lokiSendLogLine(timestampNs, JSON.stringify(item), {age:'new', place:'moon', ...sharedLabels});
await lokiSendLogLine(timestampNs, logFmtLine(item), {place:'luna', ...sharedLabels}); await lokiSendLogLine(timestampNs, logFmtLine(item), {age:'new', place:'luna', ...sharedLabels});
const sleepDuration = 200 + Math.random() * 800; // between 0.2 and 1 seconds const sleepDuration = 200 + Math.random() * 800; // between 0.2 and 1 seconds
await sleep(sleepDuration); await sleep(sleepDuration);
} }
} }
async function main() { async function main() {
// first we send logs to build a last-7-days log-data // we generate both old-logs and new-logs at the same time
await sendOldLogs(); await Promise.all([sendOldLogs(), sendNewLogs()])
// then keep sending new data forever
await sendNewLogs();
} }
// when running in docker, we catch the needed stop-signal, to shutdown fast // when running in docker, we catch the needed stop-signal, to shutdown fast