test_class.declarator: testAppender
test_class.modifier: private
test_class.original_string: private ListAppender<ILoggingEvent> testAppender;
test_class.type: ListAppender<ILoggingEvent>
test_class.var_name: testAppender
test_class.file: stagemonitor-core/src/test/java/org/stagemonitor/core/elasticsearch/ElasticsearchClientTest.java
test_class.identifier: ElasticsearchClientTest
test_class.superclass: extends AbstractElasticsearchTest
test_case.body: @Test
  	public void testCreateEmptyIndex() throws Exception {
  		elasticsearchClient.createEmptyIndex("test");
  		assertThat(elasticsearchClient.getJson("/test").get("test")).isNotNull();
  	}
test_case.class_method_signature: ElasticsearchClientTest.testCreateEmptyIndex()
test_case.full_signature: @Test public void testCreateEmptyIndex()
test_case.identifier: testCreateEmptyIndex
test_case.invocations: createEmptyIndex isNotNull assertThat get getJson
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCreateEmptyIndex()
focal_class.declarator: CONTENT_TYPE_NDJSON = Collections.singletonMap("Content-Type", "application/x-ndjson")
focal_class.modifier: public static final
focal_class.original_string: public static final Map<String, String> CONTENT_TYPE_NDJSON = Collections.singletonMap("Content-Type", "application/x-ndjson");
focal_class.type: Map<String, String>
focal_class.var_name: CONTENT_TYPE_NDJSON
focal_class.declarator: BULK = "/_bulk"
focal_class.modifier: private static final
focal_class.original_string: private static final String BULK = "/_bulk";
focal_class.type: String
focal_class.var_name: BULK
focal_class.declarator: logger = LoggerFactory.getLogger(ElasticsearchClient.class)
focal_class.modifier: private final
focal_class.original_string: private final Logger logger = LoggerFactory.getLogger(ElasticsearchClient.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: TITLE = "title"
focal_class.modifier: private final
focal_class.original_string: private final String TITLE = "title";
focal_class.type: String
focal_class.var_name: TITLE
focal_class.declarator: httpClient
focal_class.modifier: private final
focal_class.original_string: private final HttpClient httpClient;
focal_class.type: HttpClient
focal_class.var_name: httpClient
focal_class.declarator: corePlugin
focal_class.modifier: private final
focal_class.original_string: private final CorePlugin corePlugin;
focal_class.type: CorePlugin
focal_class.var_name: corePlugin
focal_class.declarator: elasticsearchAvailable = new AtomicBoolean(false)
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean elasticsearchAvailable = new AtomicBoolean(false);
focal_class.type: AtomicBoolean
focal_class.var_name: elasticsearchAvailable
focal_class.declarator: checkEsAvailability
focal_class.modifier: private final
focal_class.original_string: private final CheckEsAvailability checkEsAvailability;
focal_class.type: CheckEsAvailability
focal_class.var_name: checkEsAvailability
focal_class.declarator: esMajorVersion
focal_class.modifier: private
focal_class.original_string: private Integer esMajorVersion;
focal_class.type: Integer
focal_class.var_name: esMajorVersion
focal_class.declarator: asyncESPool
focal_class.modifier: private final
focal_class.original_string: private final ThreadPoolExecutor asyncESPool;
focal_class.type: ThreadPoolExecutor
focal_class.var_name: asyncESPool
focal_class.declarator: timer
focal_class.modifier: private
focal_class.original_string: private Timer timer;
focal_class.type: Timer
focal_class.var_name: timer
focal_class.file: stagemonitor-core/src/main/java/org/stagemonitor/core/elasticsearch/ElasticsearchClient.java
focal_class.identifier: ElasticsearchClient
focal_class.class_method_signature: ElasticsearchClient.ElasticsearchClient(final CorePlugin corePlugin, final HttpClient httpClient, int esAvailabilityCheckIntervalSec, List<ElasticsearchAvailabilityObserver> elasticsearchAvailabilityObservers)
focal_class.full_signature: public  ElasticsearchClient(final CorePlugin corePlugin, final HttpClient httpClient, int esAvailabilityCheckIntervalSec, List<ElasticsearchAvailabilityObserver> elasticsearchAvailabilityObservers)
focal_class.identifier: ElasticsearchClient
focal_class.modifiers: public
focal_class.parameters: (final CorePlugin corePlugin, final HttpClient httpClient, int esAvailabilityCheckIntervalSec, List<ElasticsearchAvailabilityObserver> elasticsearchAvailabilityObservers)
focal_class.signature:  ElasticsearchClient(final CorePlugin corePlugin, final HttpClient httpClient, int esAvailabilityCheckIntervalSec, List<ElasticsearchAvailabilityObserver> elasticsearchAvailabilityObservers)
focal_class.class_method_signature: ElasticsearchClient.isElasticsearch7Compatible()
focal_class.full_signature: public boolean isElasticsearch7Compatible()
focal_class.identifier: isElasticsearch7Compatible
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isElasticsearch7Compatible()
focal_class.class_method_signature: ElasticsearchClient.isElasticsearch6Compatible()
focal_class.full_signature: public boolean isElasticsearch6Compatible()
focal_class.identifier: isElasticsearch6Compatible
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isElasticsearch6Compatible()
focal_class.class_method_signature: ElasticsearchClient.getElasticSearchTemplateResourcePath()
focal_class.full_signature: public String getElasticSearchTemplateResourcePath()
focal_class.identifier: getElasticSearchTemplateResourcePath
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getElasticSearchTemplateResourcePath()
focal_class.class_method_signature: ElasticsearchClient.getKibanaResourcePath()
focal_class.full_signature: public String getKibanaResourcePath()
focal_class.identifier: getKibanaResourcePath
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getKibanaResourcePath()
focal_class.class_method_signature: ElasticsearchClient.getJson(final String path)
focal_class.full_signature: public JsonNode getJson(final String path)
focal_class.identifier: getJson
focal_class.modifiers: public
focal_class.parameters: (final String path)
focal_class.return: JsonNode
focal_class.signature: JsonNode getJson(final String path)
focal_class.class_method_signature: ElasticsearchClient.getJson(final String path, final boolean suppressWarning)
focal_class.full_signature: public JsonNode getJson(final String path, final boolean suppressWarning)
focal_class.identifier: getJson
focal_class.modifiers: public
focal_class.parameters: (final String path, final boolean suppressWarning)
focal_class.return: JsonNode
focal_class.signature: JsonNode getJson(final String path, final boolean suppressWarning)
focal_class.class_method_signature: ElasticsearchClient.getObject(final String path, Class<T> type)
focal_class.full_signature: public T getObject(final String path, Class<T> type)
focal_class.identifier: getObject
focal_class.modifiers: public
focal_class.parameters: (final String path, Class<T> type)
focal_class.return: T
focal_class.signature: T getObject(final String path, Class<T> type)
focal_class.class_method_signature: ElasticsearchClient.getAll(String path, int limit, Class<T> clazz)
focal_class.full_signature: public Collection<T> getAll(String path, int limit, Class<T> clazz)
focal_class.identifier: getAll
focal_class.modifiers: public
focal_class.parameters: (String path, int limit, Class<T> clazz)
focal_class.return: Collection<T>
focal_class.signature: Collection<T> getAll(String path, int limit, Class<T> clazz)
focal_class.class_method_signature: ElasticsearchClient.delete(final String path)
focal_class.full_signature: public int delete(final String path)
focal_class.identifier: delete
focal_class.modifiers: public
focal_class.parameters: (final String path)
focal_class.return: int
focal_class.signature: int delete(final String path)
focal_class.class_method_signature: ElasticsearchClient.sendAsJson(final String method, final String path, final Object requestBody)
focal_class.full_signature: public int sendAsJson(final String method, final String path, final Object requestBody)
focal_class.identifier: sendAsJson
focal_class.modifiers: public
focal_class.parameters: (final String method, final String path, final Object requestBody)
focal_class.return: int
focal_class.signature: int sendAsJson(final String method, final String path, final Object requestBody)
focal_class.class_method_signature: ElasticsearchClient.updateKibanaIndexPattern(final String indexName, final String indexPatternLocation)
focal_class.full_signature: public void updateKibanaIndexPattern(final String indexName, final String indexPatternLocation)
focal_class.identifier: updateKibanaIndexPattern
focal_class.modifiers: public
focal_class.parameters: (final String indexName, final String indexPatternLocation)
focal_class.return: void
focal_class.signature: void updateKibanaIndexPattern(final String indexName, final String indexPatternLocation)
focal_class.class_method_signature: ElasticsearchClient.fetchCurrentKibanaIndexPatternConfiguration(String elasticsearchKibanaIndexPatternPath)
focal_class.full_signature: private JsonNode fetchCurrentKibanaIndexPatternConfiguration(String elasticsearchKibanaIndexPatternPath)
focal_class.identifier: fetchCurrentKibanaIndexPatternConfiguration
focal_class.modifiers: private
focal_class.parameters: (String elasticsearchKibanaIndexPatternPath)
focal_class.return: JsonNode
focal_class.signature: JsonNode fetchCurrentKibanaIndexPatternConfiguration(String elasticsearchKibanaIndexPatternPath)
focal_class.class_method_signature: ElasticsearchClient.getFields(String fieldsJsonPath)
focal_class.full_signature: private String getFields(String fieldsJsonPath)
focal_class.identifier: getFields
focal_class.modifiers: private
focal_class.parameters: (String fieldsJsonPath)
focal_class.return: String
focal_class.signature: String getFields(String fieldsJsonPath)
focal_class.class_method_signature: ElasticsearchClient.sendMappingTemplate(String mappingJson, String templateName)
focal_class.full_signature: public void sendMappingTemplate(String mappingJson, String templateName)
focal_class.identifier: sendMappingTemplate
focal_class.modifiers: public
focal_class.parameters: (String mappingJson, String templateName)
focal_class.return: void
focal_class.signature: void sendMappingTemplate(String mappingJson, String templateName)
focal_class.class_method_signature: ElasticsearchClient.modifyIndexTemplate(String templatePath, int moveToColdNodesAfterDays, Integer numberOfReplicas, Integer numberOfShards)
focal_class.full_signature: public static String modifyIndexTemplate(String templatePath, int moveToColdNodesAfterDays, Integer numberOfReplicas, Integer numberOfShards)
focal_class.identifier: modifyIndexTemplate
focal_class.modifiers: public static
focal_class.parameters: (String templatePath, int moveToColdNodesAfterDays, Integer numberOfReplicas, Integer numberOfShards)
focal_class.return: String
focal_class.signature: String modifyIndexTemplate(String templatePath, int moveToColdNodesAfterDays, Integer numberOfReplicas, Integer numberOfShards)
focal_class.class_method_signature: ElasticsearchClient.sendMetricDashboardBulkAsync(final String resource)
focal_class.full_signature: public void sendMetricDashboardBulkAsync(final String resource)
focal_class.identifier: sendMetricDashboardBulkAsync
focal_class.modifiers: public
focal_class.parameters: (final String resource)
focal_class.return: void
focal_class.signature: void sendMetricDashboardBulkAsync(final String resource)
focal_class.class_method_signature: ElasticsearchClient.sendSpanDashboardBulkAsync(final String resource, boolean logBulkErrors)
focal_class.full_signature: public void sendSpanDashboardBulkAsync(final String resource, boolean logBulkErrors)
focal_class.identifier: sendSpanDashboardBulkAsync
focal_class.modifiers: public
focal_class.parameters: (final String resource, boolean logBulkErrors)
focal_class.return: void
focal_class.signature: void sendSpanDashboardBulkAsync(final String resource, boolean logBulkErrors)
focal_class.class_method_signature: ElasticsearchClient.sendClassPathRessourceBulkAsync(final String resource, boolean logBulkErrors)
focal_class.full_signature: private void sendClassPathRessourceBulkAsync(final String resource, boolean logBulkErrors)
focal_class.identifier: sendClassPathRessourceBulkAsync
focal_class.modifiers: private
focal_class.parameters: (final String resource, boolean logBulkErrors)
focal_class.return: void
focal_class.signature: void sendClassPathRessourceBulkAsync(final String resource, boolean logBulkErrors)
focal_class.class_method_signature: ElasticsearchClient.sendBulkAsync(final HttpClient.OutputStreamHandler outputStreamHandler, final boolean logBulkErrors)
focal_class.full_signature: private void sendBulkAsync(final HttpClient.OutputStreamHandler outputStreamHandler, final boolean logBulkErrors)
focal_class.identifier: sendBulkAsync
focal_class.modifiers: private
focal_class.parameters: (final HttpClient.OutputStreamHandler outputStreamHandler, final boolean logBulkErrors)
focal_class.return: void
focal_class.signature: void sendBulkAsync(final HttpClient.OutputStreamHandler outputStreamHandler, final boolean logBulkErrors)
focal_class.class_method_signature: ElasticsearchClient.sendBulk(HttpClient.OutputStreamHandler outputStreamHandler)
focal_class.full_signature:  void sendBulk(HttpClient.OutputStreamHandler outputStreamHandler)
focal_class.identifier: sendBulk
focal_class.parameters: (HttpClient.OutputStreamHandler outputStreamHandler)
focal_class.return: void
focal_class.signature: void sendBulk(HttpClient.OutputStreamHandler outputStreamHandler)
focal_class.class_method_signature: ElasticsearchClient.sendBulk(HttpClient.OutputStreamHandler outputStreamHandler, boolean logBulkErrors)
focal_class.full_signature: private void sendBulk(HttpClient.OutputStreamHandler outputStreamHandler, boolean logBulkErrors)
focal_class.identifier: sendBulk
focal_class.modifiers: private
focal_class.parameters: (HttpClient.OutputStreamHandler outputStreamHandler, boolean logBulkErrors)
focal_class.return: void
focal_class.signature: void sendBulk(HttpClient.OutputStreamHandler outputStreamHandler, boolean logBulkErrors)
focal_class.class_method_signature: ElasticsearchClient.deleteIndices(String indexPattern)
focal_class.full_signature: public void deleteIndices(String indexPattern)
focal_class.identifier: deleteIndices
focal_class.modifiers: public
focal_class.parameters: (String indexPattern)
focal_class.return: void
focal_class.signature: void deleteIndices(String indexPattern)
focal_class.class_method_signature: ElasticsearchClient.forceMergeIndices(String indexPattern)
focal_class.full_signature: public void forceMergeIndices(String indexPattern)
focal_class.identifier: forceMergeIndices
focal_class.modifiers: public
focal_class.parameters: (String indexPattern)
focal_class.return: void
focal_class.signature: void forceMergeIndices(String indexPattern)
focal_class.class_method_signature: ElasticsearchClient.updateIndexSettings(String indexPattern, final Map<String, ?> settings)
focal_class.full_signature: public void updateIndexSettings(String indexPattern, final Map<String, ?> settings)
focal_class.identifier: updateIndexSettings
focal_class.modifiers: public
focal_class.parameters: (String indexPattern, final Map<String, ?> settings)
focal_class.return: void
focal_class.signature: void updateIndexSettings(String indexPattern, final Map<String, ?> settings)
focal_class.class_method_signature: ElasticsearchClient.execute(String method, String path, String logMessage)
focal_class.full_signature: private void execute(String method, String path, String logMessage)
focal_class.identifier: execute
focal_class.modifiers: private
focal_class.parameters: (String method, String path, String logMessage)
focal_class.return: void
focal_class.signature: void execute(String method, String path, String logMessage)
focal_class.class_method_signature: ElasticsearchClient.getDashboardForElasticsearch(String dashboardPath)
focal_class.full_signature:  ObjectNode getDashboardForElasticsearch(String dashboardPath)
focal_class.identifier: getDashboardForElasticsearch
focal_class.parameters: (String dashboardPath)
focal_class.return: ObjectNode
focal_class.signature: ObjectNode getDashboardForElasticsearch(String dashboardPath)
focal_class.class_method_signature: ElasticsearchClient.waitForCompletion()
focal_class.full_signature: public void waitForCompletion()
focal_class.identifier: waitForCompletion
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void waitForCompletion()
focal_class.class_method_signature: ElasticsearchClient.close()
focal_class.full_signature: public void close()
focal_class.identifier: close
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: ElasticsearchClient.scheduleIndexManagement(String indexPrefix, int optimizeAndMoveIndicesToColdNodesOlderThanDays, int deleteIndicesOlderThanDays)
focal_class.full_signature: public void scheduleIndexManagement(String indexPrefix, int optimizeAndMoveIndicesToColdNodesOlderThanDays, int deleteIndicesOlderThanDays)
focal_class.identifier: scheduleIndexManagement
focal_class.modifiers: public
focal_class.parameters: (String indexPrefix, int optimizeAndMoveIndicesToColdNodesOlderThanDays, int deleteIndicesOlderThanDays)
focal_class.return: void
focal_class.signature: void scheduleIndexManagement(String indexPrefix, int optimizeAndMoveIndicesToColdNodesOlderThanDays, int deleteIndicesOlderThanDays)
focal_class.class_method_signature: ElasticsearchClient.getBulkHeader(String action, String index, String type)
focal_class.full_signature: public static String getBulkHeader(String action, String index, String type)
focal_class.identifier: getBulkHeader
focal_class.modifiers: public static
focal_class.parameters: (String action, String index, String type)
focal_class.return: String
focal_class.signature: String getBulkHeader(String action, String index, String type)
focal_class.class_method_signature: ElasticsearchClient.isElasticsearchAvailable()
focal_class.full_signature: public boolean isElasticsearchAvailable()
focal_class.identifier: isElasticsearchAvailable
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isElasticsearchAvailable()
focal_class.class_method_signature: ElasticsearchClient.getHttpClient()
focal_class.full_signature: public HttpClient getHttpClient()
focal_class.identifier: getHttpClient
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: HttpClient
focal_class.signature: HttpClient getHttpClient()
focal_class.class_method_signature: ElasticsearchClient.getElasticsearchUrl()
focal_class.full_signature: public URL getElasticsearchUrl()
focal_class.identifier: getElasticsearchUrl
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: URL
focal_class.signature: URL getElasticsearchUrl()
focal_class.class_method_signature: ElasticsearchClient.createIndexAndSendMapping(final String index, final String type, final InputStream mapping)
focal_class.full_signature: public void createIndexAndSendMapping(final String index, final String type, final InputStream mapping)
focal_class.identifier: createIndexAndSendMapping
focal_class.modifiers: public
focal_class.parameters: (final String index, final String type, final InputStream mapping)
focal_class.return: void
focal_class.signature: void createIndexAndSendMapping(final String index, final String type, final InputStream mapping)
focal_class.class_method_signature: ElasticsearchClient.createIndexIfNotExists(String indexName)
focal_class.full_signature: private void createIndexIfNotExists(String indexName)
focal_class.identifier: createIndexIfNotExists
focal_class.modifiers: private
focal_class.parameters: (String indexName)
focal_class.return: void
focal_class.signature: void createIndexIfNotExists(String indexName)
focal_class.class_method_signature: ElasticsearchClient.sendMapping(String index, String type, InputStream mapping)
focal_class.full_signature: private void sendMapping(String index, String type, InputStream mapping)
focal_class.identifier: sendMapping
focal_class.modifiers: private
focal_class.parameters: (String index, String type, InputStream mapping)
focal_class.return: void
focal_class.signature: void sendMapping(String index, String type, InputStream mapping)
focal_class.class_method_signature: ElasticsearchClient.createEmptyIndex(String indexName)
focal_class.full_signature: public void createEmptyIndex(String indexName)
focal_class.identifier: createEmptyIndex
focal_class.modifiers: public
focal_class.parameters: (String indexName)
focal_class.return: void
focal_class.signature: void createEmptyIndex(String indexName)
focal_class.class_method_signature: ElasticsearchClient.checkEsAvailability()
focal_class.full_signature: public void checkEsAvailability()
focal_class.identifier: checkEsAvailability
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void checkEsAvailability()
focal_method.body: public void createEmptyIndex(String indexName) {
  		httpClient.send(HttpRequestBuilder.of("PUT", getElasticsearchUrl() + "/" + indexName)
  				.noopForStatus(400) // ignore index exists
  				.build());
  	}
focal_method.class_method_signature: ElasticsearchClient.createEmptyIndex(String indexName)
focal_method.full_signature: public void createEmptyIndex(String indexName)
focal_method.identifier: createEmptyIndex
focal_method.invocations: send build noopForStatus of getElasticsearchUrl
focal_method.modifiers: public
focal_method.parameters: (String indexName)
focal_method.return: void
focal_method.signature: void createEmptyIndex(String indexName)