Package io.meeds.analytics.elasticsearch.storage

Class ElasticsearchAnalyticsStorage

java.lang.Object
io.meeds.analytics.elasticsearch.storage.ElasticsearchAnalyticsStorage
@Component public class ElasticsearchAnalyticsStorage extends Object

  • Field Details

  • Constructor Details

    • ElasticsearchAnalyticsStorage

      public ElasticsearchAnalyticsStorage()

  • Method Details

    • init

      @PostConstruct public void init()

    • getIndexPrefix

      public String getIndexPrefix()
      Returns:
      the configured weekly index name prefix (analytics.es.index.prefix), which the mapping reader needs to recognise the indices behind the alias

    • sendCreateBulkDocumentsRequest

      public void sendCreateBulkDocumentsRequest(List<io.meeds.analytics.model.StatisticDataQueueEntry> dataQueueEntries, Set<io.meeds.analytics.model.StatisticFieldMapping> esMappings)

    • search

      public String search(String esQuery)

    • retrieveAllAnalyticsIndexesMapping

      public String retrieveAllAnalyticsIndexesMapping()

    • sendGetRequest

      public ElasticsearchResponse sendGetRequest(String uri)

    • sendGetRequest

      public ElasticsearchResponse sendGetRequest(String uri, boolean handleResponse)

    • sendHeadRequest

      public ElasticsearchResponse sendHeadRequest(String uri)

    • sendPutRequest

      public ElasticsearchResponse sendPutRequest(String uri, String content)

    • sendDeleteRequest

      public ElasticsearchResponse sendDeleteRequest(String uri)

    • sendPostRequest

      public ElasticsearchResponse sendPostRequest(String uri, String content)