org.waarp.openr66.elasticsearch

Class ElasticsearchMonitoringExporterClientImpl

java.lang.Object

org.waarp.openr66.elasticsearch.ElasticsearchMonitoringExporterClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, ElasticsearchMonitoringExporterClient

public class ElasticsearchMonitoringExporterClientImpl
extends Object
implements ElasticsearchMonitoringExporterClient

Elasticsearch client for Waarp

Field Summary

Fields

Modifier and Type	Field and Description
protected org.elasticsearch.client.RestClientBuilder	builder
protected co.elastic.clients.elasticsearch.ElasticsearchClient	client
protected String	index
protected co.elastic.clients.transport.ElasticsearchTransport	transport

Constructor Summary

Constructors

Constructor and Description
ElasticsearchMonitoringExporterClientImpl(String username, String pwd, String token, String apiKey, String prefix, String index, boolean compression, org.apache.http.HttpHost... httpHosts) Note that only one among (username/pwd, token, apikey) is allowed and will be taken into account.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	createClient()
boolean	post(com.fasterxml.jackson.databind.node.ObjectNode monitoredTransfers, org.joda.time.DateTime start, org.joda.time.DateTime stop, String serverId) Will use a "bulk" request to upsert data into ElasticSearch

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

index

protected final String index

builder

protected final org.elasticsearch.client.RestClientBuilder builder

transport

protected co.elastic.clients.transport.ElasticsearchTransport transport

client

protected co.elastic.clients.elasticsearch.ElasticsearchClient client

Constructor Detail

ElasticsearchMonitoringExporterClientImpl

public ElasticsearchMonitoringExporterClientImpl(String username,
                                                 String pwd,
                                                 String token,
                                                 String apiKey,
                                                 String prefix,
                                                 String index,
                                                 boolean compression,
                                                 org.apache.http.HttpHost... httpHosts)

Note that only one among (username/pwd, token, apikey) is allowed and will be taken into account.

Parameters:

username - username to connect to Elasticsearch if any (Basic authentication) (nullable)

pwd - password to connect to Elasticsearch if any (Basic authentication) (nullable)

token - access token (Bearer Token authorization by Header) (nullable)

apiKey - API Key (Base64 of 'apiId:apiKey') (ApiKey authorization by Header) (nullable)

prefix - as '/prefix' or null if none

index - as 'waarpr66monitor' as the index name within Elasticsearch, including extra dynamic information

compression - True to compress REST exchanges between the client and the Elasticsearch server

httpHosts - array of HttpHost

Method Detail

createClient

protected void createClient()

post

public final boolean post(com.fasterxml.jackson.databind.node.ObjectNode monitoredTransfers,
                          org.joda.time.DateTime start,
                          org.joda.time.DateTime stop,
                          String serverId)

Description copied from interface: ElasticsearchMonitoringExporterClient

Will use a "bulk" request to upsert data into ElasticSearch

Specified by:

post in interface ElasticsearchMonitoringExporterClient

Parameters:

monitoredTransfers - the Json objet to push as POST

start - the DateTime for the 'from' interval

stop - the DateTime for the 'to' interval

serverId - the serverId that is sending this monitoring information

Returns:

True if the Bulk upsert succeeded

close

public final void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable