diff options
author | Bogdan Drutu <bdrutu@google.com> | 2018-09-22 09:37:29 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-09-22 09:37:29 -0700 |
commit | f0e78ba5a10165cce2b63809bfdfe3e34b1eb456 (patch) | |
tree | 68b4ed0d345bf218d15a7b9234a2b70e2f0ec660 /impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java | |
parent | 0c988a28144199450fa21ef55ddcac8c2c9323bc (diff) | |
download | opencensus-java-f0e78ba5a10165cce2b63809bfdfe3e34b1eb456.tar.gz |
Split SpanImpl into record/notrecord span impl to avoid checks of recording all time. (#1468)
* Split SpanImpl into record/notrecord span impl to avoid checks of recording all time.
* Remove one extra SuppressWarnings.
Diffstat (limited to 'impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java')
-rw-r--r-- | impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java | 53 |
1 files changed, 25 insertions, 28 deletions
diff --git a/impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java b/impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java index d99776d1..f8f1d917 100644 --- a/impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java +++ b/impl_core/src/test/java/io/opencensus/implcore/trace/export/SpanExporterImplTest.java @@ -23,11 +23,10 @@ import static org.mockito.Mockito.doThrow; import io.opencensus.common.Duration; import io.opencensus.implcore.common.MillisClock; import io.opencensus.implcore.internal.SimpleEventQueue; -import io.opencensus.implcore.trace.SpanImpl; -import io.opencensus.implcore.trace.SpanImpl.StartEndHandler; +import io.opencensus.implcore.trace.RecordEventsSpanImpl; +import io.opencensus.implcore.trace.RecordEventsSpanImpl.StartEndHandler; import io.opencensus.implcore.trace.StartEndHandlerImpl; import io.opencensus.testing.export.TestHandler; -import io.opencensus.trace.Span.Options; import io.opencensus.trace.SpanContext; import io.opencensus.trace.SpanId; import io.opencensus.trace.TraceId; @@ -35,7 +34,6 @@ import io.opencensus.trace.TraceOptions; import io.opencensus.trace.config.TraceParams; import io.opencensus.trace.export.SpanData; import io.opencensus.trace.export.SpanExporter.Handler; -import java.util.EnumSet; import java.util.List; import java.util.Random; import org.junit.Before; @@ -60,7 +58,6 @@ public class SpanExporterImplTest { SpanContext.create( TraceId.generateRandomId(random), SpanId.generateRandomId(random), TraceOptions.DEFAULT); private final RunningSpanStoreImpl runningSpanStore = new InProcessRunningSpanStoreImpl(); - private final EnumSet<Options> recordSpanOptions = EnumSet.of(Options.RECORD_EVENTS); private final TestHandler serviceHandler = new TestHandler(); @Mock private Handler mockServiceHandler; @@ -69,11 +66,11 @@ public class SpanExporterImplTest { MockitoAnnotations.initMocks(this); } - private SpanImpl createSampledEndedSpan(StartEndHandler startEndHandler, String spanName) { - SpanImpl span = - SpanImpl.startSpan( + private RecordEventsSpanImpl createSampledEndedSpan( + StartEndHandler startEndHandler, String spanName) { + RecordEventsSpanImpl span = + RecordEventsSpanImpl.startSpan( sampledSpanContext, - recordSpanOptions, spanName, null, null, @@ -86,11 +83,11 @@ public class SpanExporterImplTest { return span; } - private SpanImpl createNotSampledEndedSpan(StartEndHandler startEndHandler, String spanName) { - SpanImpl span = - SpanImpl.startSpan( + private RecordEventsSpanImpl createNotSampledEndedSpan( + StartEndHandler startEndHandler, String spanName) { + RecordEventsSpanImpl span = + RecordEventsSpanImpl.startSpan( notSampledSpanContext, - recordSpanOptions, spanName, null, null, @@ -111,8 +108,8 @@ public class SpanExporterImplTest { spanExporter.registerHandler("test.service", serviceHandler); - SpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); + RecordEventsSpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); List<SpanData> exported = serviceHandler.waitForExport(2); assertThat(exported).containsExactly(span1.toSpanData(), span2.toSpanData()); } @@ -125,12 +122,12 @@ public class SpanExporterImplTest { spanExporter.registerHandler("test.service", serviceHandler); - SpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span3 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span4 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span5 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span6 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span3 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span4 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span5 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span6 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); List<SpanData> exported = serviceHandler.waitForExport(6); assertThat(exported) .containsExactly( @@ -167,11 +164,11 @@ public class SpanExporterImplTest { spanExporter.registerHandler("test.service", serviceHandler); spanExporter.registerHandler("mock.service", mockServiceHandler); - SpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); List<SpanData> exported = serviceHandler.waitForExport(1); assertThat(exported).containsExactly(span1.toSpanData()); // Continue to export after the exception was received. - SpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); exported = serviceHandler.waitForExport(1); assertThat(exported).containsExactly(span2.toSpanData()); } @@ -186,8 +183,8 @@ public class SpanExporterImplTest { TestHandler serviceHandler2 = new TestHandler(); spanExporter.registerHandler("test.service2", serviceHandler2); - SpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); + RecordEventsSpanImpl span1 = createSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); List<SpanData> exported1 = serviceHandler.waitForExport(2); List<SpanData> exported2 = serviceHandler2.waitForExport(2); assertThat(exported1).containsExactly(span1.toSpanData(), span2.toSpanData()); @@ -202,8 +199,8 @@ public class SpanExporterImplTest { spanExporter.registerHandler("test.service", serviceHandler); - SpanImpl span1 = createNotSampledEndedSpan(startEndHandler, SPAN_NAME_1); - SpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); + RecordEventsSpanImpl span1 = createNotSampledEndedSpan(startEndHandler, SPAN_NAME_1); + RecordEventsSpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); // Spans are recorded and exported in the same order as they are ended, we test that a non // sampled span is not exported by creating and ending a sampled span after a non sampled span // and checking that the first exported span is the sampled span (the non sampled did not get @@ -224,7 +221,7 @@ public class SpanExporterImplTest { spanExporter.registerHandler("test.service", serviceHandler); - SpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); + RecordEventsSpanImpl span2 = createSampledEndedSpan(startEndHandler, SPAN_NAME_2); // Force a flush, without this, the #waitForExport() call below would block indefinitely. spanExporter.flush(); |