io.micrometer.core.instrument.Tags.and()方法的使用及代码示例

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

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

Tags.and介绍

暂无

代码示例

代码示例来源：origin: micrometer-metrics/micrometer

  1. @Threads(16)
  2. @Benchmark
  3. public void dotAnd() {
  4.   Tags.of("key", "value").and("key2", "value2", "key3", "value3", "key4", "value4", "key5", "value5");
  5. }

代码示例来源：origin: rsocket/rsocket-java

  1. private static Counter counter(
  2.    Type connectionType, MeterRegistry meterRegistry, String frameType, Tag... tags) {
  3.   return meterRegistry.counter(
  4.     "rsocket.frame",
  5.     Tags.of(tags).and("connection.type", connectionType.name()).and("frame.type", frameType));
  6.  }
  7. }

代码示例来源：origin: org.springframework.boot/spring-boot-actuator

  1. @SuppressWarnings({ "unchecked" })
  2. private MeterBinder getMeterBinder(Cache cache, Tags tags) {
  3.   Tags cacheTags = tags.and(getAdditionalTags(cache));
  4.   return LambdaSafe
  5.       .callbacks(CacheMeterBinderProvider.class, this.binderProviders, cache)
  6.       .withLogger(CacheMetricsRegistrar.class)
  7.       .invokeAnd((binderProvider) -> binderProvider.getMeterBinder(cache,
  8.           cacheTags))
  9.       .filter(Objects::nonNull).findFirst().orElse(null);
  10. }

代码示例来源：origin: rsocket/rsocket-java

  1. private static Counter counter(
  2.    MeterRegistry meterRegistry, String interactionModel, SignalType signalType, Tag... tags) {
  3.   return meterRegistry.counter(
  4.     "rsocket." + interactionModel, Tags.of(tags).and("signal.type", signalType.name()));
  5.  }
  6. }

代码示例来源：origin: rsocket/rsocket-java

  1. private static Timer timer(
  2.    MeterRegistry meterRegistry, String interactionModel, SignalType signalType, Tag... tags) {
  3.   return meterRegistry.timer(
  4.     "rsocket." + interactionModel, Tags.of(tags).and("signal.type", signalType.name()));
  5.  }
  6. }

代码示例来源：origin: rsocket/rsocket-java

  1. /**
  2.  * Creates a new {@link DuplexConnection}.
  3.  *
  4.  * @param connectionType the type of connection being monitored
  5.  * @param delegate the {@link DuplexConnection} to delegate to
  6.  * @param meterRegistry the {@link MeterRegistry} to use
  7.  * @param tags additional tags to attach to {@link Meter}s
  8.  * @throws NullPointerException if {@code connectionType}, {@code delegate}, or {@code
  9.  *     meterRegistry} is {@code null}
  10.  */
  11. MicrometerDuplexConnection(
  12.   Type connectionType, DuplexConnection delegate, MeterRegistry meterRegistry, Tag... tags) {
  13.  Objects.requireNonNull(connectionType, "connectionType must not be null");
  14.  this.delegate = Objects.requireNonNull(delegate, "delegate must not be null");
  15.  Objects.requireNonNull(meterRegistry, "meterRegistry must not be null");
  16.  this.close =
  17.    meterRegistry.counter(
  18.      "rsocket.duplex.connection.close",
  19.      Tags.of(tags).and("connection.type", connectionType.name()));
  20.  this.dispose =
  21.    meterRegistry.counter(
  22.      "rsocket.duplex.connection.dispose",
  23.      Tags.of(tags).and("connection.type", connectionType.name()));
  24.  this.frameCounters = new FrameCounters(connectionType, meterRegistry, tags);
  25. }

代码示例来源：origin: com.hotels.road/road-offramp-service

  1. private AtomicLong getPartitionLatencyHolder(int partition) {
  2.  return partitionLatencies.computeIfAbsent(partition, k -> {
  3.   Tags tags = roadStreamTags.and("partition", Integer.toString(k));
  4.   AtomicLong latencyHolder = new AtomicLong();
  5.   registry.more().timeGauge(OFFRAMP + LATENCY, tags, latencyHolder, MILLISECONDS, AtomicLong::doubleValue);
  6.   return latencyHolder;
  7.  });
  8. }

代码示例来源：origin: eclipse/hono

  1. @Override
  2. public final void incrementProcessedMessages(final String type, final String tenantId) {
  3.   Objects.requireNonNull(type);
  4.   Objects.requireNonNull(tenantId);
  5.   this.registry.counter(METER_MESSAGES_PROCESSED,
  6.       Tags.of(MetricsTags.TAG_TENANT, tenantId).and(MetricsTags.TAG_TYPE, type))
  7.       .increment();
  8. }

代码示例来源：origin: eclipse/hono

  1. @Override
  2. public final void incrementUndeliverableMessages(final String type, final String tenantId) {
  3.   Objects.requireNonNull(type);
  4.   Objects.requireNonNull(tenantId);
  5.   this.registry.counter(METER_MESSAGES_UNDELIVERABLE,
  6.       Tags.of(MetricsTags.TAG_TENANT, tenantId).and(MetricsTags.TAG_TYPE, type))
  7.       .increment();
  8. }

代码示例来源：origin: eclipse/hono

  1. @Override
  2. public final void incrementProcessedPayload(final String type, final String tenantId,
  3.     final long payloadSize) {
  4.   Objects.requireNonNull(type);
  5.   Objects.requireNonNull(tenantId);
  6.   if (payloadSize < 0) {
  7.     // A negative size would mess up the metrics
  8.     return;
  9.   }
  10.   this.registry.counter("hono.messages.processed.payload",
  11.       Tags.of(MetricsTags.TAG_TENANT, tenantId).and(MetricsTags.TAG_TYPE, type))
  12.       .increment(payloadSize);
  13. }

代码示例来源：origin: com.hotels.road/road-offramp-service

  1. public <T> T record(TimerTag timerTag, Supplier<T> supplier) {
  2.  return registry.timer(OFFRAMP_TIMER, roadStreamTags.and(timerTag.tag)).record(supplier);
  3. }

代码示例来源：origin: com.hotels.road/road-offramp-service

  1. public void record(TimerTag timerTag, Runnable runnable) {
  2.  registry.timer(OFFRAMP_TIMER, roadStreamTags.and(timerTag.tag)).record(runnable);
  3. }

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Verifies that HTTP adapter metrics are correctly mapped to
  3.  * the legacy format's metric names.
  4.  */
  5. @Test
  6. public void testMappingOfHttpAdapterMetrics() {
  7.   final Tags httpTags = defaultTags
  8.       .and(MetricsTags.TAG_COMPONENT_TYPE, MetricsTags.VALUE_COMPONENT_TYPE_ADAPTER)
  9.       .and(MetricsTags.TAG_COMPONENT_NAME, Constants.PROTOCOL_ADAPTER_TYPE_HTTP)
  10.       .and(MetricsTags.TAG_TENANT, TENANT);
  11.   assertCommonAdapterMetrics("http", httpTags);
  12. }

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. @Override
  2. public final void incrementProcessedMessages(final String type, final String tenantId) {
  3.   this.registry.counter("hono.messages.processed",
  4.       Tags
  5.           .of("tenant", tenantId)
  6.           .and("type", type))
  7.       .increment();
  8. }

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. @Override
  2. public final void incrementUndeliverableMessages(final String type, final String tenantId) {
  3.   this.registry.counter("hono.messages.undeliverable",
  4.       Tags
  5.           .of("tenant", tenantId)
  6.           .and("type", type))
  7.       .increment();
  8. }

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Verifies that MQTT adapter metrics are correctly mapped to
  3.  * the legacy format's metric names.
  4.  */
  5. @Test
  6. public void testMappingOfMqttAdapterMetrics() {
  7.   final Tags mqttTags = defaultTags
  8.       .and(MetricsTags.TAG_COMPONENT_TYPE, MetricsTags.VALUE_COMPONENT_TYPE_ADAPTER)
  9.       .and(MetricsTags.TAG_COMPONENT_NAME, Constants.PROTOCOL_ADAPTER_TYPE_MQTT);
  10.   assertConnectionMetrics("mqtt", mqttTags);
  11.   final Tags mqttWithTenantTags = mqttTags.and(MetricsTags.TAG_TENANT, TENANT);
  12.   assertCommonAdapterMetrics("mqtt", mqttWithTenantTags);
  13. }

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. @Override
  2. public final void incrementProcessedPayload(final String type, final String tenantId,
  3.     final long payloadSize) {
  4.   if (payloadSize < 0) {
  5.     // A negative size would mess up the metrics
  6.     return;
  7.   }
  8.   this.registry.counter("hono.messages.processed.payload",
  9.       Tags
  10.           .of("tenant", tenantId)
  11.           .and("type", type))
  12.       .increment(payloadSize);
  13. }

代码示例来源：origin: eclipse/hono

  1. private void assertConnectionMetrics(final String protocol, final Tags tags) {
  2.   final Tags tagsWithTenant = tags.and(MetricsTags.TAG_TENANT, TENANT);
  3.   assertMapping(
  4.       new Id(MicrometerBasedMetrics.METER_CONNECTIONS_UNAUTHENTICATED, tags, null, null, Type.GAUGE),
  5.       String.format("%s.counter.hono.%s.connections.unauthenticated.count",
  6.           HOSTNAME_MAPPED, protocol));
  7.   assertMapping(
  8.       new Id(MicrometerBasedMetrics.METER_CONNECTIONS_AUTHENTICATED, tagsWithTenant, null, null, Type.GAUGE),
  9.       String.format("%s.counter.hono.%s.connections.authenticated.%s.count",
  10.           HOSTNAME_MAPPED, protocol, TENANT));
  11. }

代码示例来源：origin: com.hotels.road/road-offramp-service

  1. OfframpMetrics(
  2.   String roadName,
  3.   String streamName,
  4.   MeterRegistry registry,
  5.   Clock clock,
  6.   Map<RoadAndStream, AtomicInteger> activeConnections) {
  7.  this.registry = registry;
  8.  this.clock = clock;
  9.  this.activeConnections = activeConnections;
  10.  roadAndStream = RoadAndStream.of(roadName, streamName);
  11.  roadStreamTags = Tags.of(ROAD, roadName).and(STREAM, streamName);
  12.  commitSuccessCounter = registry.counter(OFFRAMP + COMMIT_SUCCESS, roadStreamTags);
  13.  commitFailureCounter = registry.counter(OFFRAMP + COMMIT_FAILURE, roadStreamTags);
  14.  messageCounter = registry.counter(OFFRAMP + MESSAGE, roadStreamTags);
  15.  bytesCounter = registry.counter(OFFRAMP + BYTES, roadStreamTags);
  16.  rebalanceCounter = registry.counter(OFFRAMP + REBALANCE, roadStreamTags);
  17.  roadNotFoundCounter = registry.counter(OFFRAMP + ROAD_NOT_FOUND, roadStreamTags);
  18.  transportErrorCounter = registry.counter(OFFRAMP + TRANSPORT_ERROR, roadStreamTags);
  19.  connectionEstablishedCounter = registry.counter(OFFRAMP + CONNECTIONS_ESTABLISHED, roadStreamTags);
  20.  partitionLatencies = new ConcurrentHashMap<>();
  21. }

代码示例来源：origin: org.apache.camel/camel-micrometer

  1. @Override
  2. public void process(Exchange exchange) {
  3.   Message in = exchange.getIn();
  4.   String defaultMetricsName = simple(exchange, getEndpoint().getMetricsName(), String.class);
  5.   String finalMetricsName = getStringHeader(in, HEADER_METRIC_NAME, defaultMetricsName);
  6.   Iterable<Tag> defaultTags = getEndpoint().getTags();
  7.   Iterable<Tag> headerTags = getTagHeader(in, HEADER_METRIC_TAGS, Tags.empty());
  8.   Iterable<Tag> finalTags = Tags.concat(defaultTags, headerTags).stream()
  9.       .map(tag -> Tag.of(
  10.           simple(exchange, tag.getKey(), String.class),
  11.           simple(exchange, tag.getValue(), String.class)))
  12.       .reduce(Tags.empty(), Tags::and, Tags::and)
  13.       .and(Tags.of(
  14.           CAMEL_CONTEXT_TAG, getEndpoint().getCamelContext().getName()));
  15.   try {
  16.     doProcess(exchange, finalMetricsName, finalTags);
  17.   } catch (Exception e) {
  18.     exchange.setException(e);
  19.   } finally {
  20.     clearMetricsHeaders(in);
  21.   }
  22. }

内容来源于网络，如有侵权，请联系作者删除！

tags

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com