io.opencensus.trace.Tracing类的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(168)

本文整理了Java中io.opencensus.trace.Tracing类的一些代码示例,展示了Tracing类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tracing类的具体详情如下:
包路径:io.opencensus.trace.Tracing
类名称:Tracing

Tracing介绍

[英]Class that manages a global instance of the TraceComponent.
[中]类,该类管理TraceComponent的全局实例。

代码示例

代码示例来源:origin: googleapis/google-cloud-java

static void exportSpans(String... spans) {
  SampledSpanStore store = Tracing.getExportComponent().getSampledSpanStore();
  if (store != null) {
   store.registerSpanNamesForCollection(Arrays.asList(spans));
  }
 }
}

代码示例来源:origin: googleapis/google-cloud-java

TransactionManagerImpl(SessionImpl session) {
 this.session = session;
 this.span = Tracing.getTracer().getCurrentSpan();
}

代码示例来源:origin: census-instrumentation/opencensus-java

/** Create a new {@code OcJettyHttpClient}. */
public OcJettyHttpClient() {
 super();
 OcJettyHttpClientExtractor extractor = new OcJettyHttpClientExtractor();
 handler =
   new HttpClientHandler<Request, Response, Request>(
     Tracing.getTracer(),
     extractor,
     Tracing.getPropagationComponent().getTraceContextFormat(),
     setter);
}

代码示例来源:origin: dgraph-io/dgraph4j

@Test
public void testOpencensusJaeger() {
 // 1. configure the jaeger exporter
 JaegerTraceExporter.createAndRegister(JAEGER_COLLECTOR, "my-service");
 // 2. Configure 100% sample rate, otherwise, few traces will be sampled.
 TraceConfig traceConfig = Tracing.getTraceConfig();
 TraceParams activeTraceParams = traceConfig.getActiveTraceParams();
 traceConfig.updateActiveTraceParams(
   activeTraceParams.toBuilder().setSampler(Samplers.alwaysSample()).build());
 // 3. Get the global singleton Tracer object.
 Tracer tracer = Tracing.getTracer();
 // 4. Create a scoped span, a scoped span will automatically end when closed.
 // It implements AutoClosable, so it'll be closed when the try block ends.
 try (Scope scope = tracer.spanBuilder("query").startScopedSpan()) {
  runTransactions();
 }
 // 5. Gracefully shutdown the exporter, so that it'll flush queued traces to Jaeger.
 Tracing.getExportComponent().shutdown();
}

代码示例来源:origin: GoogleCloudPlatform/java-docs-samples

Tracing.getExportComponent().getSampledSpanStore().registerSpanNamesForCollection(
  Arrays.asList(SAMPLE_SPAN));
   options.getProjectId(), instanceId, databaseId));
 try (Scope ss = Tracing.getTracer()
   .spanBuilderWithExplicitParent(SAMPLE_SPAN, null)
   .setSampler(Samplers.alwaysSample())

代码示例来源:origin: census-instrumentation/opencensus-java

@Before
public void setup() {
 handler = new TestHandler();
 SpanExporter exporter = Tracing.getExportComponent().getSpanExporter();
 exporter.registerHandler("testing", handler);
 TraceParams params =
   Tracing.getTraceConfig()
     .getActiveTraceParams()
     .toBuilder()
     .setSampler(Samplers.alwaysSample())
     .build();
 Tracing.getTraceConfig().updateActiveTraceParams(params);
}

代码示例来源:origin: census-instrumentation/opencensus-java

/**
 * Default constructor construct new instance with {@link JaxrsContainerExtractor}, {@link
 * io.opencensus.trace.propagation.PropagationComponent#getTraceContextFormat()} and as public
 * endpoint.
 *
 * @see #JaxrsContainerFilter(HttpExtractor, TextFormat, Boolean)
 */
public JaxrsContainerFilter() {
 this(
   new JaxrsContainerExtractor(),
   Tracing.getPropagationComponent().getTraceContextFormat(),
   /* publicEndpoint= */ true);
}

代码示例来源:origin: census-instrumentation/opencensus-java

/** Creates a new {@code OcHttpServletFilter}. */
public OcHttpServletFilter() {
 TraceConfig traceConfig = Tracing.getTraceConfig();
 traceConfig.updateActiveTraceParams(traceConfig.getActiveTraceParams().toBuilder().build());
 handler = buildHttpServerHandler();
}

代码示例来源:origin: census-instrumentation/opencensus-java

@Test
public void implementationOfClock() {
 assertThat(Tracing.getClock()).isInstanceOf(MillisClock.class);
}

代码示例来源:origin: census-instrumentation/opencensus-java

static HttpServerHandler<HttpServletRequest, HttpServletResponse, HttpServletRequest>
  buildHttpServerHandler() {
 return new HttpServerHandler<HttpServletRequest, HttpServletResponse, HttpServletRequest>(
   Tracing.getTracer(),
   // TODO[rghetia]:
   // 1. provide options to configure custom extractor, propagator and endpoint.
   new OcHttpServletExtractor(),
   Tracing.getPropagationComponent().getTraceContextFormat(),
   getter,
   true);
}

代码示例来源:origin: census-instrumentation/opencensus-java

@Test
public void exportToJaeger() throws IOException, InterruptedException {
 Tracer tracer = Tracing.getTracer();
 final long startTimeInMicros = MILLISECONDS.toMicros(currentTimeMillis());
 final long startNanoTime = System.nanoTime();
 Tracing.getExportComponent().shutdown();
 JaegerTraceExporter.unregister();

代码示例来源:origin: census-instrumentation/opencensus-java

/** Constructs new client filter with default configuration. */
public JaxrsClientFilter() {
 this(new JaxrsClientExtractor(), Tracing.getPropagationComponent().getTraceContextFormat());
}

代码示例来源:origin: census-instrumentation/opencensus-java

@Test
 public void defaultTraceConfig() {
  assertThat(Tracing.getTraceConfig()).isSameAs(TraceConfig.getNoopTraceConfig());
 }
}

代码示例来源:origin: census-instrumentation/opencensus-java

@Test
public void implementationOfClock() {
 assertThat(Tracing.getClock()).isInstanceOf(MillisClock.class);
}

代码示例来源:origin: googleapis/google-cloud-java

static void registerAllSpanNamesForCollection() {
 Tracing.getExportComponent()
   .getSampledSpanStore()
   .registerSpanNamesForCollection(ALL_SPAN_NAMES);
}

代码示例来源:origin: googleapis/google-cloud-java

private AbstractReadContext(SessionImpl session, SpannerRpc rpc, int defaultPrefetchChunks) {
 this(session, rpc, defaultPrefetchChunks, Tracing.getTracer().getCurrentSpan());
}

代码示例来源:origin: io.grpc/grpc-core

@VisibleForTesting
final List<? extends ServerStreamTracer.Factory> getTracerFactories() {
 ArrayList<ServerStreamTracer.Factory> tracerFactories = new ArrayList<>();
 if (statsEnabled) {
  CensusStatsModule censusStats = censusStatsOverride;
  if (censusStats == null) {
   censusStats = new CensusStatsModule(
     GrpcUtil.STOPWATCH_SUPPLIER, true, recordStartedRpcs, recordFinishedRpcs,
     recordRealTimeMetrics);
  }
  tracerFactories.add(censusStats.getServerTracerFactory());
 }
 if (tracingEnabled) {
  CensusTracingModule censusTracing =
    new CensusTracingModule(Tracing.getTracer(),
      Tracing.getPropagationComponent().getBinaryFormat());
  tracerFactories.add(censusTracing.getServerTracerFactory());
 }
 tracerFactories.addAll(streamTracerFactories);
 tracerFactories.trimToSize();
 return Collections.unmodifiableList(tracerFactories);
}

代码示例来源:origin: census-instrumentation/opencensus-java

@Test
public void implementationOfBinaryPropagationHandler() {
 assertThat(Tracing.getPropagationComponent()).isInstanceOf(PropagationComponent.class);
}

代码示例来源:origin: GoogleCloudPlatform/cloud-bigtable-examples

public static void main(String[] args) throws IOException, InterruptedException {
 // Consult system properties to get project/instance
 String projectId = requiredProperty("bigtable.projectID");
 String instanceId = requiredProperty("bigtable.instanceID");
 // Force tracing for every request for demo purposes.  Use the default settings
 // in most cases.
 Tracing.getTraceConfig().updateActiveTraceParams(
   TraceParams.DEFAULT.toBuilder().setSampler(Samplers.probabilitySampler(1)).build());
 StackdriverTraceExporter.createAndRegister(
     StackdriverTraceConfiguration.builder()
       .setProjectId(projectId)
       .build());
 // Enable stats exporter to Stackdriver with a 5 second export time.
 // Production settings may vary.
 StackdriverStatsExporter.createAndRegister(
     StackdriverStatsConfiguration.builder()
        .setProjectId(projectId)
        .setExportInterval(Duration.create(5, 0))
        .build());
 RpcViews.registerAllViews();
 // HBase Bigtable specific setup for zpages
 HBaseTracingUtilities.setupTracingConfig();
 // Start a web server on port 8080 for tracing data
 ZPageHandlers.startHttpServerAndRegisterAll(8080);
 doHelloWorld(projectId, instanceId);
 System.out.println("Sleeping for 1 minute so that you can view http://localhost:8080/tracez");
 // Sleep for 1 minute.
 Thread.sleep(TimeUnit.MINUTES.toMillis(1));
}

代码示例来源:origin: census-instrumentation/opencensus-java

Optional.ofNullable(sd.getEndTimestamp()).orElseGet(() -> Tracing.getClock().now());
final long endTime = timestampToNanos(endTimestamp);
final long duration = endTime - startTime;

相关文章