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

JsonUtils.getMapper介绍

暂无

代码示例

代码示例来源：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

ObjectNode getDashboardForElasticsearch(String dashboardPath) throws IOException {
  final ObjectMapper mapper = JsonUtils.getMapper();
  final ObjectNode dashboard = (ObjectNode) mapper.readTree(IOUtils.getResourceAsStream(dashboardPath));
  dashboard.put("editable", false);
  ObjectNode dashboardElasticsearchFormat = mapper.createObjectNode();
  dashboardElasticsearchFormat.put("user", "guest");
  dashboardElasticsearchFormat.put("group", "guest");
  dashboardElasticsearchFormat.set(TITLE, dashboard.get(TITLE));
  dashboardElasticsearchFormat.set("tags", dashboard.get("tags"));
  dashboardElasticsearchFormat.put("dashboard", dashboard.toString());
  return dashboardElasticsearchFormat;
}

代码示例来源：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 JsonNode handleResponse(HttpRequest<?> httpRequest, InputStream is, Integer statusCode, IOException e) throws IOException {
    if (statusCode == 200) {
      return JsonUtils.getMapper().readTree(is);
    } else {
      IOUtils.consumeAndClose(is);
      return null;
    }
  }
}

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

private JsonNode fetchCurrentKibanaIndexPatternConfiguration(String elasticsearchKibanaIndexPatternPath) throws IOException {
  final JsonNode json = getJson(elasticsearchKibanaIndexPatternPath);
  if (json != null) {
    return json.get("_source");
  } else {
    // kibana returned 404 -> document does not yet exist -> merge stagemonitor configuration with empty object
    return JsonUtils.getMapper().createObjectNode();
  }
}

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

@Override
public Void handleResponse(HttpRequest<?> httpRequest, InputStream is, Integer statusCode, IOException e) throws IOException {
  if (is == null) {
    return null;
  }
  final JsonNode bulkResponse = JsonUtils.getMapper().readTree(is);
  final JsonNode errors = bulkResponse.get("errors");
  if (errors != null && errors.booleanValue()) {
    reportBulkErrors(bulkResponse.get("items"));
  }
  return null;
}

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

public static void writeWithoutClosingStream(OutputStream os, Object pojo) throws IOException {
  final JsonGenerator generator = JsonUtils.getMapper().getFactory().createGenerator(os);
  generator.disable(JsonGenerator.Feature.AUTO_CLOSE_JSON_CONTENT);
  generator.disable(JsonGenerator.Feature.AUTO_CLOSE_TARGET);
  generator.writeObject(pojo);
  generator.close();
}

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

@Override
public void reload() throws IOException {
  final JsonNode json = elasticsearchClient.getJson(path, true);
  if (json != null) {
    final JsonNode source = json.get("_source").get("configuration");
    List<EsConfigurationDto> configAsList = JsonUtils.getMapper().readValue(source.traverse(), new TypeReference<List<EsConfigurationDto>>() {
    });
    configuration = EsConfigurationDto.toMap(configAsList);
  }
}

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

@Override
  protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    final CheckResult.Status status = CheckResult.Status.valueOf(req.getParameter("status"));
    final Subscription subscription = JsonUtils.getMapper().readValue(req.getInputStream(), Subscription.class);

    alertingPlugin.getAlertSender().sendTestAlert(subscription, status);
  }
}

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

ObjectNode getGrafanaDashboard(String classPathLocation) throws IOException {
  final ObjectNode dashboard = (ObjectNode) JsonUtils.getMapper().readTree(IOUtils.getResourceAsStream(classPathLocation));
  dashboard.put("editable", false);
  addMinIntervalToPanels(dashboard, corePlugin.getElasticsearchReportingInterval() + "s");
  return dashboard;
}

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

@SuppressWarnings("unchecked")
  private Map<String, Object> asMap(String json) throws java.io.IOException {
    final TreeMap<String, Object> result = new TreeMap<String, Object>();
    result.putAll(JsonUtils.getMapper().readValue(json, Map.class));
    return result;
  }
}

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

public StagemonitorMetricsServlet() {
  this(Stagemonitor.getMetric2Registry(), Stagemonitor.getPlugin(ServletPlugin.class), JsonUtils.getMapper());
}

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

@Test
public void testSetShards() throws Exception {
  final String indexTemplate = modifyIndexTemplate("stagemonitor-elasticsearch-metrics-index-template.json", 0, -1, 1);
  assertFalse(indexTemplate.contains("hot"));
  assertEquals(1, JsonUtils.getMapper().readTree(indexTemplate).get("settings").get("index").get("number_of_shards").asInt());
  assertFalse(indexTemplate.contains("number_of_replicas"));
}

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

@Test
public void testSetReplicas() throws Exception {
  final String indexTemplate = modifyIndexTemplate("stagemonitor-elasticsearch-metrics-index-template.json", 0, 0, 0);
  assertFalse(indexTemplate.contains("hot"));
  assertEquals(0, JsonUtils.getMapper().readTree(indexTemplate).get("settings").get("index").get("number_of_replicas").asInt());
  assertFalse(indexTemplate.contains("number_of_shards"));
}

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

@Before
public void setUp() throws Exception {
  registry = new Metric2Registry();
  servlet = new StagemonitorMetricsServlet(registry, mock(ServletPlugin.class), JsonUtils.getMapper());
}

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

@Before
public void setUp() throws Exception {
  mapper = JsonUtils.getMapper().copy().registerModule(new Metric2RegistryModule(TimeUnit.SECONDS, TimeUnit.MILLISECONDS));
  registry = new Metric2Registry();
}

代码示例来源：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 getMeter() throws Exception {
  registry.meter(name("foo").tag("bar", "baz").build()).mark();
  final MockHttpServletResponse resp = new MockHttpServletResponse();
  servlet.doGet(new MockHttpServletRequest(), resp);
  final double mean_rate = JsonUtils.getMapper().readTree(resp.getContentAsString()).get(0).get("values").get("mean_rate").doubleValue();
  assertTrue("Expected m1 rate of > 0, but got " + mean_rate, mean_rate > 0);
}

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

private ElasticsearchReporter(Builder builder) {
  super(builder);
  this.elasticsearchMetricsLogger = builder.getElasticsearchMetricsLogger();
  this.globalTags = builder.getGlobalTags();
  this.httpClient = builder.getHttpClient();
  this.jfactory.setCodec(JsonUtils.getMapper());
  this.metric2RegistryModule = new Metric2RegistryModule(builder.getRateUnit(), builder.getDurationUnit());
  this.corePlugin = builder.getCorePlugin();
  this.elasticsearchClient = corePlugin.getElasticsearchClient();
}

代码示例来源：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());
  }
}