org.stagemonitor.core.util.JsonUtils.toJson()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(86)

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

JsonUtils.toJson介绍

暂无

代码示例

代码示例来源:origin: stagemonitor/stagemonitor

private String spanAsJson() {
  return JsonUtils.toJson(span, SpanUtils.CALL_TREE_ASCII);
}

代码示例来源:origin: stagemonitor/stagemonitor

private void writeSpansToResponse(HttpServletResponse response, Collection<Pair<Long, SpanWrapper>> spans)
    throws IOException {
  if (spans == null) {
    spans = Collections.emptyList();
  }
  response.setContentType("application/json");
  response.setHeader("Pragma", "no-cache");
  response.setHeader("Cache-Control", "max-age=0, no-cache, no-store, must-revalidate");
  response.setHeader("Expires", "0");
  response.setCharacterEncoding("UTF-8");
  final ArrayList<String> jsonResponse = new ArrayList<String>(spans.size());
  for (Pair<Long, SpanWrapper> spanPair : spans) {
    logger.debug("writeSpansToResponse {}", spanPair);
    jsonResponse.add(JsonUtils.toJson(spanPair.getB(), SpanUtils.CALL_TREE_ASCII));
  }
  response.getWriter().print(jsonResponse.toString());
  response.getWriter().close();
}

代码示例来源:origin: stagemonitor/stagemonitor

@Override
  public void injectHtml(HtmlInjector.InjectArguments injectArguments) {
    final List<String> pathsOfWidgetTabPlugins = new ArrayList<String>();
    for (String path : Stagemonitor.getPathsOfWidgetTabPlugins()) {
      pathsOfWidgetTabPlugins.add(contextPath + path);
    }

    final List<String> pathsOfWidgetMetricTabPlugins = new ArrayList<String>();
    for (String path : Stagemonitor.getPathsOfWidgetMetricTabPlugins()) {
      pathsOfWidgetMetricTabPlugins.add(contextPath + path);
    }
    final SpanWrapper span = injectArguments.getSpanWrapper();
    injectArguments.setContentToInjectBeforeClosingBody(widgetTemplate
        .replace("@@JSON_REQUEST_TRACE_PLACEHOLDER@@", span != null ? JsonUtils.toJson(span, SpanUtils.CALL_TREE_ASCII) : "null")
        .replace("@@CONFIGURATION_OPTIONS@@", JsonUtils.toJson(configuration.getConfigurationOptionsByCategory()))
        .replace("@@CONFIGURATION_PWD_SET@@", Boolean.toString(servletPlugin.getConfigurationPasswordChecker().isPasswordSet()))
        .replace("@@CONFIGURATION_SOURCES@@", JsonUtils.toJson(configuration.getNamesOfConfigurationSources()))
        .replace("@@MEASUREMENT_SESSION@@", JsonUtils.toJson(Stagemonitor.getMeasurementSession()))
        .replace("@@PATHS_OF_TAB_PLUGINS@@", JsonUtils.toJson(pathsOfWidgetTabPlugins))
        .replace("@@PATHS_OF_WIDGET_METRIC_TAB_PLUGINS@@", JsonUtils.toJson(pathsOfWidgetMetricTabPlugins))
        .replace("@@CONNECTION_ID@@", UUID.randomUUID().toString()));
  }
}

代码示例来源:origin: stagemonitor/stagemonitor

private void assertIncidentEquals(Incident expected, Incident actual) {
  assertEquals(JsonUtils.toJson(expected), JsonUtils.toJson(actual));
}

代码示例来源:origin: stagemonitor/stagemonitor

@Override
public void report(SpanContextInformation spanContext, final SpanWrapper spanWrapper) {
  logger.debug("Reporting span");
  if (elasticsearchTracingPlugin.isOnlyLogElasticsearchSpanReports()) {
    final String spansIndex = "stagemonitor-spans-" + StringUtils.getLogstashStyleDate();
    spanLogger.info(ElasticsearchClient.getBulkHeader("index", spansIndex, SPANS_TYPE) + JsonUtils.toJson(spanWrapper));
  } else {
    scheduleSendBulk(new SpanBulkIndexOutputStreamHandler(spanWrapper));
  }
}

代码示例来源:origin: stagemonitor/stagemonitor

public static void main(String[] args) throws IOException {
    final String json = JsonUtils.toJson(ConfigurationRegistry.builder()
        .optionProviders(ServiceLoader.load(StagemonitorPlugin.class, ConfigurationRegistry.class.getClassLoader()))
        .build()
        .getConfigurationOptionsByCategory());
    System.out.println(json);
    File stagemonitorWidgetDevHtml = new File("stagemonitor-web-servlet/src/test/resources/stagemonitorWidgetDev.html");
    String content = FileUtils.readFileToString(stagemonitorWidgetDevHtml);
    content = content.replaceAll("configurationOptions .*", "configurationOptions = " + json.replace("$", "\\$").replace("\\\"", "\\\\\"") + ";");

    FileUtils.writeStringToFile(stagemonitorWidgetDevHtml, content);
  }
}

代码示例来源:origin: stagemonitor/stagemonitor

private void addCallTreeToSpan(SpanContextInformation info, Span span, String operationName) {
    final CallStackElement callTree = info.getCallTree();
    callTree.setSignature(operationName);
    final double minExecutionTimeMultiplier = tracingPlugin.getMinExecutionTimePercent() / 100;
    if (minExecutionTimeMultiplier > 0d) {
      callTree.removeCallsFasterThan((long) (callTree.getExecutionTime() * minExecutionTimeMultiplier));
    }
    if (!tracingPlugin.getExcludedTags().contains(SpanUtils.CALL_TREE_JSON)) {
      span.setTag(SpanUtils.CALL_TREE_JSON, JsonUtils.toJson(callTree));
    }
    if (!tracingPlugin.getExcludedTags().contains(SpanUtils.CALL_TREE_ASCII)) {
      span.setTag(SpanUtils.CALL_TREE_ASCII, callTree.toString(true, tracingPlugin.getCallTreeAsciiFormatter()));
    }
  }
}

代码示例来源:origin: stagemonitor/stagemonitor

@Test
  public void testJson() throws Exception {
    final String json = JsonUtils.toJson(new Threshold("value", Threshold.Operator.GREATER, 0));
    assertEquals(Threshold.Operator.GREATER, JsonUtils.getMapper().readValue(json, Threshold.class).getOperator());
  }
}

代码示例来源:origin: stagemonitor/stagemonitor

@Test
public void testGetIncidents() throws Exception {
  MockHttpServletResponse response = new MockHttpServletResponse();
  incidentServlet.service(new MockHttpServletRequest("GET", "/stagemonitor/incidents"), response);
  String expected = JsonUtils.toJson(new HashMap<String, Object>() {{
    put("status", CheckResult.Status.CRITICAL);
    put("incidents", Arrays.asList(incident));
  }});
  Assert.assertEquals(expected, response.getContentAsString());
}

代码示例来源:origin: stagemonitor/stagemonitor

assertTrue(containsTestHost2);
System.out.println(storedIncident);
System.out.println(JsonUtils.toJson(storedIncident));

代码示例来源:origin: stagemonitor/stagemonitor

@Test
  public void testJson() throws Exception {
    Check check = new Check();
    check.setName("Test Timer");
    check.setTarget(name("timer").tag("foo", "bar").tag("qux", "quux").build());
    check.setAlertAfterXFailures(2);
    check.getWarn().add(new Threshold("mean", Threshold.Operator.GREATER_EQUAL, 3));

    final String json = JsonUtils.toJson(check);
    final Check checkFromJson = JsonUtils.getMapper().readValue(json, Check.class);
    assertEquals("Test Timer", checkFromJson.getName());
    assertEquals(name("timer").tag("foo", "bar").tag("qux", "quux").build(), checkFromJson.getTarget());
    assertEquals(2, checkFromJson.getAlertAfterXFailures());
    assertEquals(1, checkFromJson.getWarn().size());
    assertEquals(MetricValueType.MEAN, checkFromJson.getWarn().get(0).getValueType());
    assertEquals(Threshold.Operator.GREATER_EQUAL, checkFromJson.getWarn().get(0).getOperator());
    assertEquals(3, checkFromJson.getWarn().get(0).getThresholdValue(), 0);
    assertEquals(0, checkFromJson.getError().size());
    assertEquals(0, checkFromJson.getCritical().size());
    assertEquals(json, JsonUtils.toJson(checkFromJson));
  }
}

代码示例来源:origin: stagemonitor/stagemonitor

@Test
  public void testToJson() throws Exception {
    MeasurementSession measurementSession = new MeasurementSession("app", "host", "instance");
    final MeasurementSession jsonSession = JsonUtils.getMapper().readValue(JsonUtils.toJson(measurementSession), MeasurementSession.class);
    assertEquals(measurementSession.getApplicationName(), jsonSession.getApplicationName());
    assertEquals(measurementSession.getHostName(), jsonSession.getHostName());
    assertEquals(measurementSession.getInstanceName(), jsonSession.getInstanceName());
    assertEquals(measurementSession.getInstanceName(), jsonSession.getInstanceName());
    assertEquals(measurementSession.getId(), jsonSession.getId());
    assertEquals(measurementSession.getStart(), jsonSession.getStart());
  }
}

代码示例来源:origin: org.stagemonitor/stagemonitor-requestmonitor

public String getCallStackJson() {
  return JsonUtils.toJson(callStack);
}

代码示例来源:origin: org.stagemonitor/stagemonitor-requestmonitor

public String toJson() {
  return JsonUtils.toJson(this, "callStack");
}

代码示例来源:origin: org.stagemonitor/stagemonitor-web

@Override
  public void injectHtml(HtmlInjector.InjectArguments injectArguments) {
    HttpRequestTrace requestTrace = null;
    if (injectArguments.getRequestInformation() != null) {
      requestTrace = injectArguments.getRequestInformation().getRequestTrace();
    }
    final List<String> pathsOfWidgetTabPlugins = new ArrayList<String>();
    for (String path : Stagemonitor.getPathsOfWidgetTabPlugins()) {
      pathsOfWidgetTabPlugins.add(contextPath + path);
    }

    final List<String> pathsOfWidgetMetricTabPlugins = new ArrayList<String>();
    for (String path : Stagemonitor.getPathsOfWidgetMetricTabPlugins()) {
      pathsOfWidgetMetricTabPlugins.add(contextPath + path);
    }

    injectArguments.setContentToInjectBeforeClosingBody(widgetTemplate
        .replace("@@JSON_REQUEST_TACE_PLACEHOLDER@@", requestTrace != null ? requestTrace.toJson() : "null")
        .replace("@@CONFIGURATION_OPTIONS@@", JsonUtils.toJson(configuration.getConfigurationOptionsByCategory()))
        .replace("@@CONFIGURATION_PWD_SET@@", Boolean.toString(configuration.isPasswordSet()))
        .replace("@@CONFIGURATION_SOURCES@@", JsonUtils.toJson(configuration.getNamesOfConfigurationSources()))
        .replace("@@MEASUREMENT_SESSION@@", JsonUtils.toJson(Stagemonitor.getMeasurementSession()))
        .replace("@@PATHS_OF_TAB_PLUGINS@@", JsonUtils.toJson(pathsOfWidgetTabPlugins))
        .replace("@@PATHS_OF_WIDGET_METRIC_TAB_PLUGINS@@", JsonUtils.toJson(pathsOfWidgetMetricTabPlugins)));
  }
}

代码示例来源:origin: org.stagemonitor/stagemonitor-tracing-elasticsearch

@Override
public void report(SpanContextInformation spanContext, final SpanWrapper spanWrapper) {
  logger.debug("Reporting span");
  if (elasticsearchTracingPlugin.isOnlyLogElasticsearchSpanReports()) {
    final String spansIndex = "stagemonitor-spans-" + StringUtils.getLogstashStyleDate();
    spanLogger.info(ElasticsearchClient.getBulkHeader("index", spansIndex, SPANS_TYPE) + JsonUtils.toJson(spanWrapper));
  } else {
    scheduleSendBulk(new SpanBulkIndexOutputStreamHandler(spanWrapper));
  }
}

代码示例来源:origin: org.stagemonitor/stagemonitor-requestmonitor

@Override
protected <T extends RequestTrace> void doReport(T requestTrace, PostExecutionInterceptorContext context) {
  final String index = "stagemonitor-requests-" + StringUtils.getLogstashStyleDate();
  final String type = "requests";
  if (!requestMonitorPlugin.isOnlyLogElasticsearchRequestTraceReports()) {
    if (context.getExcludedProperties().isEmpty()) {
      elasticsearchClient.index(index, type, requestTrace);
    } else {
      elasticsearchClient
          .index(index, type, JsonUtils.toObjectNode(requestTrace).remove(context.getExcludedProperties()));
    }
  } else {
    requestTraceLogger.info(ElasticsearchClient.getBulkHeader("index", index, type) + JsonUtils.toJson(requestTrace));
  }
}

相关文章