Skip to content

Commit dde2240

Browse files
committed
suggestions
1 parent 63cc2aa commit dde2240

3 files changed

Lines changed: 11 additions & 31 deletions

File tree

communication/src/main/java/datadog/communication/serialization/Mapper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package datadog.communication.serialization;
22

3-
// TODO @FunctionalInterface
3+
@FunctionalInterface
44
public interface Mapper<T> {
55
void map(T data, Writable packer);
66

dd-trace-core/src/main/java/datadog/trace/common/writer/ddagent/TraceMapperV0_4.java

Lines changed: 5 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -56,18 +56,10 @@ MetaWriter withWritable(Writable writable) {
5656
return this;
5757
}
5858

59-
MetaWriter forFirstSpanInTrace(final boolean firstSpanInTrace) {
60-
this.firstSpanInTrace = firstSpanInTrace;
61-
return this;
62-
}
63-
64-
MetaWriter forLastSpanInTrace(final boolean lastSpanInTrace) {
65-
this.lastSpanInTrace = lastSpanInTrace;
66-
return this;
67-
}
68-
69-
MetaWriter forFirstSpanInPayload(final boolean firstSpanInPayload) {
70-
this.firstSpanInPayload = firstSpanInPayload;
59+
MetaWriter forSpan(boolean firstInTrace, boolean lastInTrace, boolean firstInPayload) {
60+
this.firstSpanInTrace = firstInTrace;
61+
this.lastSpanInTrace = lastInTrace;
62+
this.firstSpanInPayload = firstInPayload;
7163
return this;
7264
}
7365

@@ -306,9 +298,7 @@ public void map(List<? extends CoreSpan<?>> trace, final Writable writable) {
306298
span.processTagsAndBaggage(
307299
metaWriter
308300
.withWritable(writable)
309-
.forFirstSpanInPayload(!firstSpanWritten)
310-
.forFirstSpanInTrace(i == 0)
311-
.forLastSpanInTrace(i == trace.size() - 1));
301+
.forSpan(i == 0, i == trace.size() - 1, !firstSpanWritten));
312302
if (!metaStruct.isEmpty()) {
313303
/* 13 */
314304
metaStructWriter.withWritable(writable).write(metaStruct);

dd-trace-core/src/main/java/datadog/trace/common/writer/ddagent/TraceMapperV0_5.java

Lines changed: 5 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -79,9 +79,7 @@ public void map(final List<? extends CoreSpan<?>> trace, final Writable writable
7979
span.processTagsAndBaggage(
8080
metaWriter
8181
.withWritable(writable)
82-
.forFirstSpanInTrace(i == 0)
83-
.forLastSpanInTrace(i == trace.size() - 1)
84-
.forFirstSpanInPayload(!firstSpanWritten));
82+
.forSpan(i == 0, i == trace.size() - 1, !firstSpanWritten));
8583
/* 12 */
8684
writeDictionaryEncoded(writable, span.getType());
8785
firstSpanWritten = true;
@@ -193,18 +191,10 @@ MetaWriter withWritable(final Writable writable) {
193191
return this;
194192
}
195193

196-
MetaWriter forFirstSpanInTrace(final boolean firstSpanInTrace) {
197-
this.firstSpanInTrace = firstSpanInTrace;
198-
return this;
199-
}
200-
201-
MetaWriter forLastSpanInTrace(final boolean lastSpanInTrace) {
202-
this.lastSpanInTrace = lastSpanInTrace;
203-
return this;
204-
}
205-
206-
MetaWriter forFirstSpanInPayload(final boolean firstSpanInPayload) {
207-
this.firstSpanInPayload = firstSpanInPayload;
194+
MetaWriter forSpan(boolean firstInTrace, boolean lastInTrace, boolean firstInPayload) {
195+
this.firstSpanInTrace = firstInTrace;
196+
this.lastSpanInTrace = lastInTrace;
197+
this.firstSpanInPayload = firstInPayload;
208198
return this;
209199
}
210200

0 commit comments

Comments
 (0)