java.util.EmptyStackException#io.opentracing.Span源码实例Demo

下面列出了java.util.EmptyStackException#io.opentracing.Span 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

@Override
@Deprecated
public Long zrangebyscore(ValueStreamingChannel<V> channel, K key,
    String min, String max) {
  Span span = helper.buildSpan("zrangebyscore", key);
  span.setTag("min", min);
  span.setTag("max", max);
  try {
    return commands.zrangebyscore(channel, key, min, max);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码2 项目: opentracing-java   文件: ErrorReportingTest.java
@Test
public void testCallbackError() {
    final Span span = tracer.buildSpan("one").start();
    executor.submit(new Runnable() {
        @Override
        public void run() {
            try (Scope scope = tracer.activateSpan(span)) {
                throw new RuntimeException("Invalid state");
            } catch (Exception exc) {
                Tags.ERROR.set(span, true);
            } finally {
                span.finish();
            }
        }
    });

    await().atMost(5, TimeUnit.SECONDS).until(finishedSpansSize(tracer), equalTo(1));

    List<MockSpan> spans = tracer.finishedSpans();
    assertEquals(spans.size(), 1);
    assertEquals(spans.get(0).tags().get(Tags.ERROR.getKey()), true);
}
 
@Override
public List<ScoredValue<V>> zrangebyscoreWithScores(K key,
    Range<? extends Number> range, Limit
    limit) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("range", range == null ? "null" : range.toString());
  span.setTag("limit", limit == null ? "null" : limit.toString());
  try {
    return commands.zrangebyscoreWithScores(key, range, limit);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码4 项目: thorntail   文件: TracingContextProvider.java
@Override
public MiniConProp.ContextSnapshot capture() {
    Tracer tracer = GlobalTracer.get();
    ScopeManager scopeManager = tracer.scopeManager();
    Scope activeScope = scopeManager.active();

    if (activeScope != null) {
        Span span = activeScope.span();
        return () -> {
            Scope propagated = scopeManager.activate(span, false);
            return propagated::close;
        };
    }

    return MiniConProp.ContextSnapshot.NOOP;
}
 
源代码5 项目: nakadi   文件: SubscriptionService.java
public ItemsWrapper<SubscriptionEventTypeStats> getSubscriptionStat(final String subscriptionId,
                                                                    final StatsMode statsMode,
                                                                    final Span span)
        throws InconsistentStateException, NoSuchEventTypeException,
        NoSuchSubscriptionException, ServiceTemporarilyUnavailableException {
    final Subscription subscription;
    try {
        subscription = subscriptionRepository.getSubscription(subscriptionId);
        authorizationValidator.authorizeSubscriptionView(subscription);
    } catch (final ServiceTemporarilyUnavailableException ex) {
        TracingService.logErrorInSpan(span, ex);
        throw new InconsistentStateException(ex.getMessage());
    }
    final List<SubscriptionEventTypeStats> subscriptionStat = createSubscriptionStat(subscription, statsMode);
    return new ItemsWrapper<>(subscriptionStat);
}
 
@Override
public void onPreHandle(HttpServletRequest httpServletRequest, Object handler, Span span) {
  Map<String, Object> logs = new HashMap<>(3);
  logs.put("event", "preHandle");
  logs.put(HandlerUtils.HANDLER, handler);

  String metaData = HandlerUtils.className(handler);
  if (metaData != null) {
    logs.put(HandlerUtils.HANDLER_CLASS_NAME, metaData);
  }

  metaData = HandlerUtils.methodName(handler);
  if (metaData != null) {
    logs.put(HandlerUtils.HANDLER_METHOD_NAME, metaData);
  }

  span.log(logs);
}
 
@Override
@Deprecated
public List<V> zrangebylex(K key, String min, String max, long offset, long count) {
  Span span = helper.buildSpan("zrangebylex", key);
  span.setTag("min", min);
  span.setTag("max", max);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrangebylex(key, min, max, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码8 项目: java-redis-client   文件: TracingJedisCluster.java
@Override
public List<byte[]> srandmember(byte[] key, int count) {
  Span span = helper.buildSpan("srandmember", key);
  span.setTag("count", count);
  try {
    return super.srandmember(key, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
@Deprecated
public RedisFuture<Long> zrangebyscore(
    ValueStreamingChannel<V> channel, K key, String min,
    String max, long offset, long count) {
  Span span = helper.buildSpan("zrangebyscore", key);
  span.setTag("min", min);
  span.setTag("max", max);
  span.setTag("offset", offset);
  span.setTag("count", count);
  return prepareRedisFuture(commands.zrangebyscore(channel, key, min, max, offset, count), span);
}
 
源代码10 项目: opentracing-toolbox   文件: LogInterceptor.java
@CheckReturnValue
default Collection<Log> intercept(
        final Span span,
        final long timestamp,
        final Map<String, ?> fields) {

    return singleton(Log.of(timestamp, fields));
}
 
@Override
public RFuture<Integer> sortToAsync(String destName, SortOrder order) {
  Span span = tracingRedissonHelper.buildSpan("sortToAsync", set);
  span.setTag("destName", nullable(destName));
  span.setTag("order", nullable(order));
  return tracingRedissonHelper.prepareRFuture(span, () -> set.sortToAsync(destName, order));
}
 
源代码12 项目: hono   文件: AbstractRegistrationService.java
private Future<RegistrationResult> createSuccessfulRegistrationResult(
        final String tenantId,
        final String deviceId,
        final JsonObject deviceData,
        final Span span) {
    return getAssertionPayload(tenantId, deviceId, deviceData, span)
            .compose(payload -> Future.succeededFuture(RegistrationResult.from(
                    HttpURLConnection.HTTP_OK,
                    payload,
                    getRegistrationAssertionCacheDirective(deviceId, tenantId))))
            .recover(thr -> Future.succeededFuture(RegistrationResult.from(ServiceInvocationException.extractStatusCode(thr))));
}
 
@Override
public RedisFuture<List<V>> zrange(K key, long start, long stop) {
  Span span = helper.buildSpan("zrange", key);
  span.setTag("start", start);
  span.setTag("stop", stop);
  return prepareRedisFuture(commands.zrange(key, start, stop), span);
}
 
源代码14 项目: java-redis-client   文件: TracingRMultimap.java
@Override
public RFuture<Boolean> removeAsync(Object key, Object value) {
  Span span = tracingRedissonHelper.buildSpan("removeAsync", map);
  span.setTag("key", nullable(key));
  span.setTag("value", nullable(value));
  return tracingRedissonHelper.prepareRFuture(span, () -> map.removeAsync(key, value));
}
 
源代码15 项目: java-redis-client   文件: TracingRedisCommands.java
@Override
public Boolean hsetnx(K key, K field, V value) {
  Span span = helper.buildSpan("hsetnx", key);
  try {
    return commands.hsetnx(key, field, value);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
public RedisFuture<String> migrate(String host, int port, int db, long timeout,
    MigrateArgs<K> migrateArgs) {
  Span span = helper.buildSpan("migrate");
  span.setTag("host", host);
  span.setTag("port", port);
  span.setTag("db", db);
  span.setTag("timeout", timeout);
  return prepareRedisFuture(commands.migrate(host, port, db, timeout, migrateArgs), span);
}
 
源代码17 项目: java-redis-client   文件: TracingJedisCluster.java
@Override
public List<String> blpop(int timeout, String... keys) {
  Span span = helper.buildSpan("blpop", keys);
  span.setTag("timeout", timeout);
  try {
    return super.blpop(timeout, keys);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码18 项目: java-redis-client   文件: TracingJedisCluster.java
@Override
public Boolean getbit(String key, long offset) {
  Span span = helper.buildSpan("getbit", key);
  span.setTag("offset", offset);
  try {
    return super.getbit(key, offset);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码19 项目: java-redis-client   文件: TracingRedisCommands.java
@Override
public String ltrim(K key, long start, long stop) {
  Span span = helper.buildSpan("ltrim", key);
  span.setTag("start", start);
  span.setTag("stop", stop);
  try {
    return commands.ltrim(key, start, stop);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码20 项目: java-redis-client   文件: TracingRedisCommands.java
@Override
public Boolean move(K key, int db) {
  Span span = helper.buildSpan("move", key);
  span.setTag("db", db);
  try {
    return commands.move(key, db);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码21 项目: hono   文件: DelegatedCommandSenderImpl.java
private Future<ProtonDelivery> runSendAndWaitForOutcomeOnContext(final Message rawMessage, final Span span) {
    return connection.executeOnContext(result -> {
        if (sender.sendQueueFull()) {
            final ServiceInvocationException e = new ServerErrorException(HttpURLConnection.HTTP_UNAVAILABLE, "no credit available");
            logMessageSendingError("error sending message [ID: {}, address: {}], no credit available",
                    rawMessage.getMessageId(), getMessageAddress(rawMessage));
            logError(span, e);
            span.finish();
            result.fail(e);
        } else {
            sendMessageAndWaitForOutcome(rawMessage, span).onComplete(result);
        }
    });
}
 
@Override
public Long sunionstore(K destination, K... keys) {
  Span span = helper.buildSpan("sunionstore", keys);
  try {
    return commands.sunionstore(destination, keys);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
public String clusterReset(boolean hard) {
  Span span = helper.buildSpan("clusterReset");
  span.setTag("hard", hard);
  try {
    return commands.clusterReset(hard);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
public void debugSegfault() {
  Span span = helper.buildSpan("debugSegfault");
  try {
    commands.debugSegfault();
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
public String auth(String password) {
  Span span = helper.buildSpan("auth");
  try {
    return commands.auth(password);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
public void channelRead(final ChannelHandlerContext handlerContext, final Object message) {
  if (!(message instanceof HttpRequest)) {
    handlerContext.fireChannelRead(message);
    return;
  }

  final HttpRequest request = (HttpRequest)message;
  final Tracer tracer = GlobalTracer.get();

  final SpanBuilder spanBuilder = tracer.buildSpan(request.method().name())
    .withTag(Tags.COMPONENT, "netty")
    .withTag(Tags.SPAN_KIND, Tags.SPAN_KIND_SERVER)
    .withTag(Tags.HTTP_METHOD, request.method().name())
    .withTag(Tags.HTTP_URL, request.uri());

  final SpanContext spanContext = tracer.extract(Builtin.HTTP_HEADERS, new NettyExtractAdapter(request.headers()));
  if (spanContext != null)
    spanBuilder.asChildOf(spanContext);

  final Span span = spanBuilder.start();
  try (final Scope scope = tracer.activateSpan(span)) {
    handlerContext.channel().attr(SERVER_ATTRIBUTE_KEY).set(span);

    try {
      handlerContext.fireChannelRead(message);
    }
    catch (final Throwable t) {
      OpenTracingApiUtil.setErrorTag(span, t);
      span.finish();
      throw t;
    }
  }
}
 
@Override
public void reset() {
  Span span = helper.buildSpan("reset");
  try {
    commands.reset();
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
@Override
public String flushdb() {
  Span span = helper.buildSpan("flushdb");
  try {
    return commands.flushdb();
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
 
源代码29 项目: opentracing-toolbox   文件: SpanDecorator.java
@Override
default void onRequest(
        final HttpServletRequest request,
        final Span span) {

    // nothing to do
}
 
private <T> RedisFuture<T> continueScopeSpan(RedisFuture<T> redisFuture) {
  Tracer tracer = tracingConfiguration.getTracer();
  Span span = tracer.activeSpan();
  CompletableRedisFuture<T> customRedisFuture = new CompletableRedisFuture<>(redisFuture);
  redisFuture.whenComplete((v, throwable) -> {
    try (Scope ignored = tracer.scopeManager().activate(span)) {
      if (throwable != null) {
        customRedisFuture.completeExceptionally(throwable);
      } else {
        customRedisFuture.complete(v);
      }
    }
  });
  return customRedisFuture;
}