diff --git a/x-pack/heartbeat/monitors/browser/synthexec/enrich.go b/x-pack/heartbeat/monitors/browser/synthexec/enrich.go index 3e01c387cb70..57c5fe5a5a21 100644 --- a/x-pack/heartbeat/monitors/browser/synthexec/enrich.go +++ b/x-pack/heartbeat/monitors/browser/synthexec/enrich.go @@ -107,6 +107,7 @@ func (je *journeyEnricher) enrich(event *beat.Event, se *SynthEvent, fields StdS "monitor": common.MapStr{ "id": id, "name": name, + "type": fields.Type, }, }) diff --git a/x-pack/heartbeat/monitors/browser/synthexec/enrich_test.go b/x-pack/heartbeat/monitors/browser/synthexec/enrich_test.go index da2f8980dc81..140ec86bdec6 100644 --- a/x-pack/heartbeat/monitors/browser/synthexec/enrich_test.go +++ b/x-pack/heartbeat/monitors/browser/synthexec/enrich_test.go @@ -90,12 +90,14 @@ func TestJourneyEnricher(t *testing.T) { "suite.name": stdFields.Name, "monitor.id": fmt.Sprintf("%s-%s", stdFields.Id, journey.Id), "monitor.name": fmt.Sprintf("%s - %s", stdFields.Name, journey.Name), + "monitor.type": stdFields.Type, }) } inlineValidator := func() validator.Validator { return lookslike.MustCompile(common.MapStr{ "monitor.id": stdFields.Id, "monitor.name": stdFields.Name, + "monitor.type": stdFields.Type, }) } commonValidator := func(se *SynthEvent) validator.Validator {