From 7d6d247b351af3d29fdd6d417a369095eeec72c3 Mon Sep 17 00:00:00 2001
From: vigneshshanmugam <vignesh.shanmugam22@gmail.com>
Date: Wed, 7 Jul 2021 12:10:43 -0700
Subject: [PATCH] Heartbeat: add datastream fields to synthetics

---
 heartbeat/monitors/factory.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/heartbeat/monitors/factory.go b/heartbeat/monitors/factory.go
index c71103c083b..78d5aa64809 100644
--- a/heartbeat/monitors/factory.go
+++ b/heartbeat/monitors/factory.go
@@ -120,6 +120,10 @@ func newCommonPublishConfigs(info beat.Info, cfg *common.Config) (pipetool.Confi
 		fields := clientCfg.Processing.Fields.Clone()
 		fields.Put("event.dataset", dataset)
 
+		if settings.DataStream != nil {
+			fields.Put("data_stream", settings.DataStream)
+		}
+
 		meta := clientCfg.Processing.Meta.Clone()
 		if settings.Pipeline != "" {
 			meta.Put("pipeline", settings.Pipeline)