Add ecs.version (#109)

closes #91

Author: felixbarny

ecs-logging-core/src/main/java/co/elastic/logging/EcsJsonSerializer.java

@@ -47,6 +47,10 @@ public static void serializeObjectStart(StringBuilder builder, long timeMillis)
         builder.append("\", ");
     }
 
+    public static void serializeEcsVersion(StringBuilder builder) {
+        builder.append("\"ecs.version\": \"1.2.0\",");
+    }
+
     public static void serializeObjectEnd(StringBuilder builder) {
         removeIfEndsWith(builder, ",");
         builder.append('}');

ecs-logging-core/src/test/java/co/elastic/logging/AbstractEcsLoggingTest.java

@@ -51,6 +51,7 @@ void testMetadata() throws Exception {
         assertThat(getLastLogLine().get("log.level").textValue()).isIn("DEBUG", "FINE");
         assertThat(getLastLogLine().get("log.logger")).isNotNull();
         assertThat(getLastLogLine().get("event.dataset").textValue()).isEqualTo("testdataset.log");
+        assertThat(getLastLogLine().get("ecs.version").textValue()).isEqualTo("1.2.0");
     }
 
     @Test

jboss-logmanager-ecs-formatter/src/main/java/co/elastic/logging/jboss/logmanager/EcsFormatter.java

@@ -50,6 +50,7 @@ public String format(ExtLogRecord record) {
         EcsJsonSerializer.serializeObjectStart(builder, record.getMillis());
         EcsJsonSerializer.serializeLogLevel(builder, record.getLevel().getName());
         EcsJsonSerializer.serializeFormattedMessage(builder, record.getFormattedMessage());
+        EcsJsonSerializer.serializeEcsVersion(builder);
         EcsJsonSerializer.serializeServiceName(builder, serviceName);
         EcsJsonSerializer.serializeEventDataset(builder, eventDataset);
         EcsJsonSerializer.serializeThreadName(builder, record.getThreadName());

jul-ecs-formatter/src/main/java/co/elastic/logging/jul/EcsFormatter.java

@@ -58,6 +58,7 @@ public String format(final LogRecord record) {
         EcsJsonSerializer.serializeObjectStart(builder, record.getMillis());
         EcsJsonSerializer.serializeLogLevel(builder, record.getLevel().getName());
         EcsJsonSerializer.serializeFormattedMessage(builder, super.formatMessage(record));
+        EcsJsonSerializer.serializeEcsVersion(builder);
         EcsJsonSerializer.serializeMDC(builder, mdcSupplier.getMDC());
         EcsJsonSerializer.serializeServiceName(builder, serviceName);
         EcsJsonSerializer.serializeEventDataset(builder, eventDataset);

log4j-ecs-layout/src/main/java/co/elastic/logging/log4j/EcsLayout.java

@@ -45,6 +45,7 @@ public String format(LoggingEvent event) {
         EcsJsonSerializer.serializeObjectStart(builder, event.timeStamp);
         EcsJsonSerializer.serializeLogLevel(builder, event.level.toString());
         EcsJsonSerializer.serializeFormattedMessage(builder, event.getRenderedMessage());
+        EcsJsonSerializer.serializeEcsVersion(builder);
         EcsJsonSerializer.serializeServiceName(builder, serviceName);
         EcsJsonSerializer.serializeEventDataset(builder, eventDataset);
         EcsJsonSerializer.serializeThreadName(builder, event.getThreadName());

log4j2-ecs-layout/src/main/java/co/elastic/logging/log4j2/EcsLayout.java

@@ -123,6 +123,7 @@ private StringBuilder toText(LogEvent event, StringBuilder builder, boolean gcFr
         EcsJsonSerializer.serializeObjectStart(builder, event.getTimeMillis());
         EcsJsonSerializer.serializeLogLevel(builder, event.getLevel().toString());
         serializeMessage(builder, gcFree, event.getMessage(), event.getThrown());
+        EcsJsonSerializer.serializeEcsVersion(builder);
         EcsJsonSerializer.serializeServiceName(builder, serviceName);
         EcsJsonSerializer.serializeEventDataset(builder, eventDataset);
         EcsJsonSerializer.serializeThreadName(builder, event.getThreadName());

logback-ecs-encoder/src/main/java/co/elastic/logging/logback/EcsEncoder.java

@@ -93,6 +93,7 @@ public byte[] encode(ILoggingEvent event) {
         EcsJsonSerializer.serializeObjectStart(builder, event.getTimeStamp());
         EcsJsonSerializer.serializeLogLevel(builder, event.getLevel().toString());
         EcsJsonSerializer.serializeFormattedMessage(builder, event.getFormattedMessage());
+        EcsJsonSerializer.serializeEcsVersion(builder);
         serializeMarkers(event, builder);
         EcsJsonSerializer.serializeServiceName(builder, serviceName);
         EcsJsonSerializer.serializeEventDataset(builder, eventDataset);