1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
package eu.mulk.quarkus.googlecloud.jsonlogging;
import io.smallrye.common.constraint.Nullable;
import java.time.Instant;
import java.util.List;
import java.util.Map;
import javax.json.Json;
import javax.json.JsonObject;
import javax.json.JsonObjectBuilder;
/**
* A JSON log entry compatible with Google Cloud Logging.
*
* <p>Roughly (but not quite) corresponds to Google Cloud Logging's <a
* href="https://cloud.google.com/logging/docs/reference/v2/rest/v2/LogEntry">LogEntry</a>
* structure.
*
* <p>A few of the fields are treated specially by the fluentd instance running in Google Kubernetes
* Engine. All other fields end up in the jsonPayload field on the Google Cloud Logging side.
*/
record LogEntry(
String message,
String severity,
Timestamp timestamp,
@Nullable String trace,
@Nullable String spanId,
SourceLocation sourceLocation,
Map<String, String> labels,
List<StructuredParameter> parameters,
Map<String, String> mappedDiagnosticContext,
@Nullable String nestedDiagnosticContext,
@Nullable String type) {
static record SourceLocation(
@Nullable String file, @Nullable String line, @Nullable String function) {
JsonObject json() {
return Json.createObjectBuilder()
.add("file", file)
.add("line", line)
.add("function", function)
.build();
}
}
static record Timestamp(long seconds, int nanos) {
Timestamp(Instant t) {
this(t.getEpochSecond(), t.getNano());
}
JsonObject json() {
return Json.createObjectBuilder().add("seconds", seconds).add("nanos", nanos).build();
}
}
JsonObjectBuilder json() {
var b = Json.createObjectBuilder();
if (trace != null) {
b.add("trace", trace);
}
if (spanId != null) {
b.add("spanId", spanId);
}
if (nestedDiagnosticContext != null && !nestedDiagnosticContext.isEmpty()) {
b.add("nestedDiagnosticContext", nestedDiagnosticContext);
}
if (!labels.isEmpty()) {
b.add("labels", jsonOfStringMap(labels));
}
if (type != null) {
b.add("@type", type);
}
return b.add("message", message)
.add("severity", severity)
.add("timestamp", timestamp.json())
.add("sourceLocation", sourceLocation.json())
.addAll(jsonOfStringMap(mappedDiagnosticContext))
.addAll(jsonOfParameterMap(parameters));
}
private static JsonObjectBuilder jsonOfStringMap(Map<String, String> stringMap) {
return stringMap.entrySet().stream()
.reduce(
Json.createObjectBuilder(),
(acc, x) -> acc.add(x.getKey(), x.getValue()),
JsonObjectBuilder::addAll);
}
private static JsonObjectBuilder jsonOfParameterMap(List<StructuredParameter> parameters) {
return parameters.stream()
.reduce(
Json.createObjectBuilder(),
(acc, p) -> acc.addAll(p.json()),
JsonObjectBuilder::addAll);
}
}
|
