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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
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.
*/
final class LogEntry {
private final String message;
private final String severity;
private final Timestamp timestamp;
@Nullable private final String trace;
@Nullable private final String spanId;
private final SourceLocation sourceLocation;
private final Map<String, String> labels;
private final List<StructuredParameter> parameters;
private final Map<String, String> mappedDiagnosticContext;
@Nullable private final String nestedDiagnosticContext;
@Nullable private final String type;
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) {
this.message = message;
this.severity = severity;
this.timestamp = timestamp;
this.trace = trace;
this.spanId = spanId;
this.sourceLocation = sourceLocation;
this.labels = labels;
this.parameters = parameters;
this.mappedDiagnosticContext = mappedDiagnosticContext;
this.nestedDiagnosticContext = nestedDiagnosticContext;
this.type = type;
}
static final class SourceLocation {
@Nullable private final String file;
@Nullable private final String line;
@Nullable private final String function;
SourceLocation(@Nullable String file, @Nullable String line, @Nullable String function) {
this.file = file;
this.line = line;
this.function = function;
}
JsonObject json() {
return Json.createObjectBuilder()
.add("file", file)
.add("line", line)
.add("function", function)
.build();
}
}
static final class Timestamp {
private final long seconds;
private final int nanos;
Timestamp(long seconds, int nanos) {
this.seconds = seconds;
this.nanos = 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);
}
}
|
