aboutsummaryrefslogtreecommitdiff
path: root/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java
diff options
context:
space:
mode:
authorKristen Kozak <sebright@google.com>2017-08-17 12:00:51 -0700
committerKristen Kozak <sebright@google.com>2017-08-17 17:45:32 -0700
commit7edf0c605414a38f14d719747235d3993791136e (patch)
tree1d06ec611ce23971e60233e1f1769d12016ec76d /impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java
parent59990408b1c2c43862a999f902bfef5661743cea (diff)
downloadopencensus-java-7edf0c605414a38f14d719747235d3993791136e.tar.gz
Use different package names in each artifact. (fixes #379)
This commit uses the following package name prefixes in each artifact, in order to ensure that no package is split across artifacts: opencensus-api: io.opencensus opencensus-impl-core: io.opencensus.implcore opencensus-impl: io.opencensus.impl opencensus-impl-lite: io.opencensus.impllite
Diffstat (limited to 'impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java')
-rw-r--r--impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java87
1 files changed, 87 insertions, 0 deletions
diff --git a/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java b/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java
new file mode 100644
index 00000000..8c16950d
--- /dev/null
+++ b/impl_core/src/main/java/io/opencensus/implcore/trace/TraceComponentImplBase.java
@@ -0,0 +1,87 @@
+/*
+ * Copyright 2017, Google Inc.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.opencensus.implcore.trace;
+
+import io.opencensus.common.Clock;
+import io.opencensus.implcore.internal.EventQueue;
+import io.opencensus.implcore.internal.SimpleEventQueue;
+import io.opencensus.implcore.trace.SpanImpl.StartEndHandler;
+import io.opencensus.implcore.trace.config.TraceConfigImpl;
+import io.opencensus.implcore.trace.export.ExportComponentImpl;
+import io.opencensus.implcore.trace.internal.RandomHandler;
+import io.opencensus.implcore.trace.propagation.PropagationComponentImpl;
+import io.opencensus.trace.TraceComponent;
+import io.opencensus.trace.Tracer;
+import io.opencensus.trace.config.TraceConfig;
+import io.opencensus.trace.export.ExportComponent;
+import io.opencensus.trace.propagation.PropagationComponent;
+
+/** Base implementation of the {@link TraceComponent}. */
+public class TraceComponentImplBase extends TraceComponent {
+ private final ExportComponentImpl exportComponent;
+ private final PropagationComponent propagationComponent = new PropagationComponentImpl();
+ private final Clock clock;
+ private final StartEndHandler startEndHandler;
+ private final TraceConfig traceConfig = new TraceConfigImpl();
+ private final Tracer tracer;
+
+ /**
+ * Creates a new {@code TraceComponentImplBase}.
+ *
+ * @param clock the clock to use throughout tracing.
+ * @param randomHandler the random number generator for generating trace and span IDs.
+ * @param eventQueue the queue implementation.
+ */
+ public TraceComponentImplBase(Clock clock, RandomHandler randomHandler, EventQueue eventQueue) {
+ this.clock = clock;
+ // TODO(bdrutu): Add a config/argument for supportInProcessStores.
+ if (eventQueue instanceof SimpleEventQueue) {
+ exportComponent = ExportComponentImpl.createWithoutInProcessStores();
+ } else {
+ exportComponent = ExportComponentImpl.createWithInProcessStores();
+ }
+ startEndHandler =
+ new StartEndHandlerImpl(
+ exportComponent.getSpanExporter(),
+ exportComponent.getRunningSpanStore(),
+ exportComponent.getSampledSpanStore(),
+ eventQueue);
+ tracer = new TracerImpl(randomHandler, startEndHandler, clock, traceConfig);
+ }
+
+ @Override
+ public Tracer getTracer() {
+ return tracer;
+ }
+
+ @Override
+ public PropagationComponent getPropagationComponent() {
+ return propagationComponent;
+ }
+
+ @Override
+ public final Clock getClock() {
+ return clock;
+ }
+
+ @Override
+ public ExportComponent getExportComponent() {
+ return exportComponent;
+ }
+
+ @Override
+ public TraceConfig getTraceConfig() {
+ return traceConfig;
+ }
+}