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

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

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

Tags.empty介绍

暂无

代码示例

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

  1. public MicrometerModule(TimeUnit timeUnit) {
  2. this(timeUnit, name -> true, Tags.empty());
  3. }

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

  1. Iterable<Tag> getMetricsTag(Map<String, Object> parameters) {
  2. String tagsString = getAndRemoveParameter(parameters, "tags", String.class, "");
  3. if (tagsString != null && !tagsString.isEmpty()) {
  4. String[] tagStrings = tagsString.split("\\s*,\\s*");
  5. return Stream.of(tagStrings)
  6. .map(s -> Tags.of(s.split("\\s*=\\s*")))
  7. .reduce(Tags.empty(), Tags::and);
  8. }
  9. return Tags.empty();
  10. }

代码示例来源:origin: org.eclipse.che.core/che-core-metrics-core

  1. @Override
  2. public TomcatMetrics get() {
  3. return new TomcatMetrics(manager, Tags.empty());
  4. }
  5. }

代码示例来源:origin: io.micrometer/micrometer-registry-new-relic

  1. private String event(Meter.Id id, Attribute... attributes) {
  2. return event(id, Tags.empty(), attributes);
  3. }

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

  1. @Override
  2. public ScheduledExecutorService newScheduledThreadPool(ThreadPoolProfile profile, ThreadFactory threadFactory) {
  3. ScheduledExecutorService executorService = threadPoolFactory.newScheduledThreadPool(profile, threadFactory);
  4. String executorServiceName = name(profile.getId());
  5. return new TimedScheduledExecutorService(meterRegistry, executorService, executorServiceName, Tags.empty());
  6. }

代码示例来源: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. }

代码示例来源:origin: org.eclipse.che.core/che-core-metrics-core

  1. @Override
  2. public void bindTo(MeterRegistry registry) {
  3. for (FileStore fileStore : FileSystems.getDefault().getFileStores()) {
  4. LOG.debug("Add gauge metric for {}", fileStore.name());
  5. Iterable<Tag> tagsWithPath = Tags.concat(Tags.empty(), "path", fileStore.toString());
  6. Gauge.builder("disk.free", fileStore, exceptionToNonWrapper(FileStore::getUnallocatedSpace))
  7. .tags(tagsWithPath)
  8. .description("Unallocated space for file store")
  9. .baseUnit("bytes")
  10. .strongReference(true)
  11. .register(registry);
  12. Gauge.builder("disk.total", fileStore, exceptionToNonWrapper(FileStore::getTotalSpace))
  13. .tags(tagsWithPath)
  14. .description("Total space for file store")
  15. .baseUnit("bytes")
  16. .strongReference(true)
  17. .register(registry);
  18. Gauge.builder("disk.usable", fileStore, exceptionToNonWrapper(FileStore::getUsableSpace))
  19. .tags(tagsWithPath)
  20. .description("Usable space for file store")
  21. .baseUnit("bytes")
  22. .strongReference(true)
  23. .register(registry);
  24. }
  25. }

相关文章