本文整理了Java中org.stagemonitor.core.util.JsonUtils
类的一些代码示例,展示了JsonUtils
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JsonUtils
类的具体详情如下:
包路径:org.stagemonitor.core.util.JsonUtils
类名称:JsonUtils
暂无
代码示例来源:origin: stagemonitor/stagemonitor
private Map<String, Number> asMap(Metric metric) {
return JsonUtils.getMapper().convertValue(metric, Map.class);
}
代码示例来源:origin: stagemonitor/stagemonitor
private String spanAsJson() {
return JsonUtils.toJson(span, SpanUtils.CALL_TREE_ASCII);
}
代码示例来源:origin: stagemonitor/stagemonitor
@Override
public void withHttpURLConnection(OutputStream os) throws IOException {
JsonUtils.writeJsonToOutputStream(requestBody, os);
}
};
代码示例来源: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: 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));
}
}
代码示例来源:origin: stagemonitor/stagemonitor
@Test
public void testParameters() {
final SpanWrapper span = createTestSpan(1, s -> SpanUtils.setParameters(s, Collections.singletonMap("foo", "bar")));
final ObjectNode jsonSpan = JsonUtils.toObjectNode(span);
assertThat(jsonSpan.get("parameters")).isNotNull();
assertThat(jsonSpan.get("parameters").get(0)).isNotNull();
assertThat(jsonSpan.get("parameters").get(0).get("key").asText()).isEqualTo("foo");
assertThat(jsonSpan.get("parameters").get(0).get("value").asText()).isEqualTo("bar");
}
代码示例来源:origin: stagemonitor/stagemonitor
@Override
public void withHttpURLConnection(OutputStream os) throws IOException {
os.write(indexHeader);
JsonUtils.writeWithoutClosingStream(os, spanWrapper);
os.write('\n');
}
}
代码示例来源: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
@Ignore
public void testNestDottedTagKeys() {
final SpanWrapper span = createTestSpan(1, s -> {
s.setTag("a.b.c.d1", "1");
s.setTag("a.b.c.d2", "2");
});
final ObjectNode jsonSpan = JsonUtils.toObjectNode(span);
System.out.println(jsonSpan);
assertEquals("1", jsonSpan.get("a").get("b").get("c").get("d1").asText());
assertEquals("2", jsonSpan.get("a").get("b").get("c").get("d2").asText());
}
代码示例来源:origin: stagemonitor/stagemonitor
@Override
public void withHttpURLConnection(OutputStream os) throws IOException {
os.write("{\"update\":{\"_id\":\"".getBytes(ElasticsearchSpanReporter.UTF_8));
os.write(id.getBytes(ElasticsearchSpanReporter.UTF_8));
os.write("\"}}\n".getBytes(ElasticsearchSpanReporter.UTF_8));
os.write("{\"doc\":".getBytes(ElasticsearchSpanReporter.UTF_8));
JsonUtils.writeWithoutClosingStream(os, partialDocument);
os.write('}');
os.write('\n');
}
}
代码示例来源:origin: stagemonitor/stagemonitor
private String getFields(String fieldsJsonPath) throws IOException {
final JsonNode fields = JsonUtils.getMapper().readTree(IOUtils.getResourceAsStream(fieldsJsonPath));
for (JsonNode field : fields) {
if (!field.has("readFromDocValues")) {
// if a field mapping does not contain readFromDocValues (previously named doc_values)
// kibana refreshes the mapping based on the contents of the index
// if the index is empty or contains documents which don't have all possible properties set (like username)
// the value for readFromDocValues can't be determined
// thus these field mappings are "deleted" (or rather can't be recreated)
logger.warn("Field {} in {} does not have property readFromDocValues", field.get("name"), fieldsJsonPath);
}
}
return JsonUtils.getMapper().writeValueAsString(fields);
}
代码示例来源: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
@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: stagemonitor/stagemonitor
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
JsonUtils.writeJsonToOutputStream(healthCheckRegistry.runHealthChecks(), resp.getOutputStream());
}
}
代码示例来源:origin: stagemonitor/stagemonitor
@Test
public void testIgnoreInternalTags() {
final SpanWrapper span = createTestSpan(1, s -> s.setTag("internal_foo", "bar"));
final ObjectNode jsonSpan = JsonUtils.toObjectNode(span);
assertThat(jsonSpan.get("internal_foo")).isNull();
}
代码示例来源:origin: org.stagemonitor/stagemonitor-tracing-elasticsearch
@Override
public void withHttpURLConnection(OutputStream os) throws IOException {
os.write(indexHeader);
JsonUtils.writeWithoutClosingStream(os, spanWrapper);
os.write('\n');
}
}
代码示例来源:origin: stagemonitor/stagemonitor
public static <T> ObjectReader getObjectReader(Class<T> type) {
final ObjectReader objectReader;
if (getMapper().version().compareTo(new Version(2, 6, 0, null, "com.fasterxml.jackson.core", "jackson-databind")) >= 0) {
objectReader = getMapper().readerFor(type);
} else {
objectReader = getMapper().reader(type);
}
return objectReader;
}
private static class AfterburnerModuleRegisterer {
代码示例来源: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
/**
* Returns all available alerters
*/
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
if (alertingPlugin.getAlertSender() != null) {
JsonUtils.writeJsonToOutputStream(alertingPlugin.getAlertSender().getAvailableAlerters(),
resp.getOutputStream());
} else {
JsonUtils.writeJsonToOutputStream(Collections.emptyList(), resp.getOutputStream());
}
}
代码示例来源:origin: stagemonitor/stagemonitor
@Test
public void testSetReservedTagName() {
final SpanWrapper span = createTestSpan(1, s -> s.setTag("duration_ms", "foo"));
final ObjectNode jsonSpan = JsonUtils.toObjectNode(span);
assertEquals(jsonSpan.toString(), 1, jsonSpan.get("duration_ms").intValue());
}
内容来源于网络,如有侵权,请联系作者删除!