Config work and Gelf Encoder

jstachio · Jan 17, 2024 · ccdbcdc · ccdbcdc
1 parent 928da9a
commit ccdbcdc
Show file tree

Hide file tree

Showing 7 changed files with 637 additions and 18 deletions.
diff --git a/core/src/main/java/io/jstach/rainbowgum/LogEvent.java b/core/src/main/java/io/jstach/rainbowgum/LogEvent.java
@@ -212,6 +212,13 @@ default void formattedMessage(Appendable a) {
 	 */
 	public LogEvent freeze();
 
+	/**
+	 * Freeze and replace with the given timestamp.
+	 * @param timestamp instant to replace timestamp in this.
+	 * @return a copy of this with the given timestamp.
+	 */
+	public LogEvent freeze(Instant timestamp);
+
 }
 
 enum EmptyLogEvent implements LogEvent {
@@ -276,6 +283,11 @@ public LogEvent freeze() {
 		return this;
 	}
 
+	@Override
+	public LogEvent freeze(Instant timestamp) {
+		return this;
+	}
+
 }
 
 record OneArgLogEvent(Instant timestamp, String threadName, long threadId, System.Logger.Level level, String loggerName,
@@ -295,6 +307,10 @@ public int argCount() {
 	}
 
 	public LogEvent freeze() {
+		return freeze(timestamp);
+	}
+
+	public LogEvent freeze(Instant timestamp) {
 		StringBuilder sb = new StringBuilder(message.length());
 		formattedMessage(sb);
 		return new DefaultLogEvent(timestamp, threadName, threadId, level, loggerName, sb.toString(),
@@ -320,6 +336,10 @@ public int argCount() {
 	}
 
 	public LogEvent freeze() {
+		return freeze(timestamp);
+	}
+
+	public LogEvent freeze(Instant timestamp) {
 		StringBuilder sb = new StringBuilder(message.length());
 		formattedMessage(sb);
 		return new DefaultLogEvent(timestamp, threadName, threadId, level, loggerName, sb.toString(),
@@ -344,11 +364,16 @@ public int argCount() {
 	}
 
 	public LogEvent freeze() {
+		return freeze(timestamp);
+	}
+
+	public LogEvent freeze(Instant timestamp) {
 		StringBuilder sb = new StringBuilder(message.length());
 		formattedMessage(sb);
 		return new DefaultLogEvent(timestamp, threadName, threadId, level, loggerName, sb.toString(),
 				keyValues.freeze(), null);
 	}
+
 }
 
 record DefaultLogEvent(Instant timestamp, String threadName, long threadId, System.Logger.Level level,
@@ -379,4 +404,13 @@ public LogEvent freeze() {
 		return this;
 	}
 
+	public LogEvent freeze(Instant timestamp) {
+		if (keyValues instanceof MutableKeyValues mkvs) {
+			return new DefaultLogEvent(timestamp, threadName, threadId, level, loggerName, formattedMessage, mkvs,
+					throwable);
+		}
+		return new DefaultLogEvent(timestamp, threadName, threadId, level, loggerName, formattedMessage, keyValues,
+				throwable);
+	}
+
 }