Package gov.nasa.pds.registry.common.connection.es

Class RestClientWrapper

java.lang.Object

gov.nasa.pds.registry.common.connection.es.RestClientWrapper

All Implemented Interfaces:

RestClient, Closeable, AutoCloseable

public class RestClientWrapper
extends Object
implements RestClient

Utility class to build Elasticsearch rest client.

Author:

karpenko

Constructor Summary

Constructors

Constructor	Description
RestClientWrapper(ConnectionFactory conFact)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	close()
Response.CreatedIndex	create(String indexName, String configAsJSON)
Request.Bulk	createBulkRequest()
Request.Count	createCountRequest()
Request.Delete	createDelete()
Request.DeleteByQuery	createDeleteByQuery()
Request.Get	createGetRequest()
Request.Mapping	createMappingRequest()
Request.MGet	createMGetRequest()
Request.Search	createSearchRequest()
Request.Setting	createSettingRequest()
void	delete(String indexName)
boolean	exists(String indexName)
Response.Bulk	performRequest(Request.Bulk request)
long	performRequest(Request.Count request)
long	performRequest(Request.Delete request)
long	performRequest(Request.DeleteByQuery request)
Response.Get	performRequest(Request.Get request)
Response.Mapping	performRequest(Request.Mapping request)
Response.Search	performRequest(Request.Search request)
Response.Settings	performRequest(Request.Setting request)

Methods inherited from class java.lang.Object

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

Constructor Details

RestClientWrapper

public RestClientWrapper(ConnectionFactory conFact)
                  throws Exception

Constructor.

Throws:

Exception - an exception

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

createBulkRequest

public Request.Bulk createBulkRequest()

Specified by:

createBulkRequest in interface RestClient

createCountRequest

public Request.Count createCountRequest()

Specified by:

createCountRequest in interface RestClient

createGetRequest

public Request.Get createGetRequest()

Specified by:

createGetRequest in interface RestClient

createMappingRequest

public Request.Mapping createMappingRequest()

Specified by:

createMappingRequest in interface RestClient

createMGetRequest

public Request.MGet createMGetRequest()

Specified by:

createMGetRequest in interface RestClient

createSearchRequest

public Request.Search createSearchRequest()

Specified by:

createSearchRequest in interface RestClient

createSettingRequest

public Request.Setting createSettingRequest()

Specified by:

createSettingRequest in interface RestClient

create

public Response.CreatedIndex create(String indexName,
 String configAsJSON)
                             throws IOException,
ResponseException

Specified by:

create in interface RestClient

Throws:

IOException

ResponseException

delete

public void delete(String indexName)
            throws IOException,
ResponseException

Specified by:

delete in interface RestClient

Throws:

IOException

ResponseException

exists

public boolean exists(String indexName)
               throws IOException,
ResponseException

Specified by:

exists in interface RestClient

Throws:

IOException

ResponseException

performRequest

public Response.Bulk performRequest(Request.Bulk request)
                             throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

performRequest

public long performRequest(Request.Count request)
                    throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

performRequest

public Response.Get performRequest(Request.Get request)
                            throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

performRequest

public Response.Mapping performRequest(Request.Mapping request)
                                throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

performRequest

public Response.Search performRequest(Request.Search request)
                               throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

performRequest

public Response.Settings performRequest(Request.Setting request)
                                 throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

createDeleteByQuery

public Request.DeleteByQuery createDeleteByQuery()

Specified by:

createDeleteByQuery in interface RestClient

performRequest

public long performRequest(Request.DeleteByQuery request)
                    throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException

createDelete

public Request.Delete createDelete()

Specified by:

createDelete in interface RestClient

performRequest

public long performRequest(Request.Delete request)
                    throws IOException,
ResponseException

Specified by:

performRequest in interface RestClient

Throws:

IOException

ResponseException