diff options
| author | Bogdan Drutu <bdrutu@google.com> | 2018-07-17 18:51:34 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-07-17 18:51:34 -0400 |
| commit | 7e9d4b5563650ea06f96e4130b27789caf776753 (patch) | |
| tree | 3c0228f62494c70f0b46cada6f09b1ed7e453747 /exporters | |
| parent | 508146f8a0807caadfea37dd9a8b160935466b4f (diff) | |
| download | platform_external_opencensus-java-7e9d4b5563650ea06f96e4130b27789caf776753.tar.gz platform_external_opencensus-java-7e9d4b5563650ea06f96e4130b27789caf776753.tar.bz2 platform_external_opencensus-java-7e9d4b5563650ea06f96e4130b27789caf776753.zip | |
Small cleanup in Stackdriver trace exporter. (#1319)
* Small cleanup in Stackdriver trace exporter.
* Remove unused imports.
Diffstat (limited to 'exporters')
| -rw-r--r-- | exporters/trace/stackdriver/src/main/java/io/opencensus/exporter/trace/stackdriver/StackdriverV2ExporterHandler.java | 34 |
1 files changed, 11 insertions, 23 deletions
diff --git a/exporters/trace/stackdriver/src/main/java/io/opencensus/exporter/trace/stackdriver/StackdriverV2ExporterHandler.java b/exporters/trace/stackdriver/src/main/java/io/opencensus/exporter/trace/stackdriver/StackdriverV2ExporterHandler.java index 46a18a59..2ced3bf2 100644 --- a/exporters/trace/stackdriver/src/main/java/io/opencensus/exporter/trace/stackdriver/StackdriverV2ExporterHandler.java +++ b/exporters/trace/stackdriver/src/main/java/io/opencensus/exporter/trace/stackdriver/StackdriverV2ExporterHandler.java @@ -24,7 +24,6 @@ import com.google.cloud.trace.v2.TraceServiceClient; import com.google.cloud.trace.v2.TraceServiceSettings; import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.ImmutableMap; -import com.google.common.io.BaseEncoding; import com.google.devtools.cloudtrace.v2.AttributeValue; import com.google.devtools.cloudtrace.v2.ProjectName; import com.google.devtools.cloudtrace.v2.Span; @@ -53,8 +52,6 @@ import io.opencensus.trace.MessageEvent.Type; import io.opencensus.trace.Sampler; import io.opencensus.trace.Span.Kind; import io.opencensus.trace.SpanContext; -import io.opencensus.trace.SpanId; -import io.opencensus.trace.TraceId; import io.opencensus.trace.Tracer; import io.opencensus.trace.Tracing; import io.opencensus.trace.export.SpanData; @@ -113,7 +110,7 @@ final class StackdriverV2ExporterHandler extends SpanExporter.Handler { StackdriverV2ExporterHandler(String projectId, TraceServiceClient traceServiceClient) { this.projectId = checkNotNull(projectId, "projectId"); this.traceServiceClient = traceServiceClient; - projectName = ProjectName.newBuilder().setProject(projectId).build(); + projectName = ProjectName.of(this.projectId); Tracing.getExportComponent() .getSampledSpanStore() @@ -131,21 +128,20 @@ final class StackdriverV2ExporterHandler extends SpanExporter.Handler { projectId, TraceServiceClient.create(traceServiceSettings)); } - static StackdriverV2ExporterHandler create(String projectId) throws IOException { - return new StackdriverV2ExporterHandler(projectId, TraceServiceClient.create()); - } - @VisibleForTesting Span generateSpan(SpanData spanData, Map<String, AttributeValue> resourceLabels) { SpanContext context = spanData.getContext(); - final String traceIdHex = encodeTraceId(context.getTraceId()); - final String spanIdHex = encodeSpanId(context.getSpanId()); + final String spanIdHex = context.getSpanId().toLowerBase16(); SpanName spanName = - SpanName.newBuilder().setProject(projectId).setTrace(traceIdHex).setSpan(spanIdHex).build(); + SpanName.newBuilder() + .setProject(projectId) + .setTrace(context.getTraceId().toLowerBase16()) + .setSpan(spanIdHex) + .build(); Span.Builder spanBuilder = Span.newBuilder() .setName(spanName.toString()) - .setSpanId(encodeSpanId(context.getSpanId())) + .setSpanId(spanIdHex) .setDisplayName( toTruncatableStringProto(toDisplayName(spanData.getName(), spanData.getKind()))) .setStartTime(toTimestampProto(spanData.getStartTimestamp())) @@ -166,20 +162,12 @@ final class StackdriverV2ExporterHandler extends SpanExporter.Handler { spanBuilder.setChildSpanCount(Int32Value.newBuilder().setValue(childSpanCount).build()); } if (spanData.getParentSpanId() != null && spanData.getParentSpanId().isValid()) { - spanBuilder.setParentSpanId(encodeSpanId(spanData.getParentSpanId())); + spanBuilder.setParentSpanId(spanData.getParentSpanId().toLowerBase16()); } return spanBuilder.build(); } - private static String encodeSpanId(SpanId spanId) { - return BaseEncoding.base16().lowerCase().encode(spanId.getBytes()); - } - - private static String encodeTraceId(TraceId traceId) { - return BaseEncoding.base16().lowerCase().encode(traceId.getBytes()); - } - private static Span.TimeEvents toTimeEventsProto( TimedEvents<Annotation> annotationTimedEvents, TimedEvents<io.opencensus.trace.MessageEvent> messageEventTimedEvents) { @@ -449,8 +437,8 @@ final class StackdriverV2ExporterHandler extends SpanExporter.Handler { private static Link toLinkProto(io.opencensus.trace.Link link) { checkNotNull(link); return Link.newBuilder() - .setTraceId(encodeTraceId(link.getTraceId())) - .setSpanId(encodeSpanId(link.getSpanId())) + .setTraceId(link.getTraceId().toLowerBase16()) + .setSpanId(link.getSpanId().toLowerBase16()) .setType(toLinkTypeProto(link.getType())) .setAttributes(toAttributesBuilderProto(link.getAttributes(), 0)) .build(); |
