net.bluemind.lib.elasticsearch

Class ESearchActivator

java.lang.Object

net.bluemind.lib.elasticsearch.ESearchActivator

All Implemented Interfaces:

org.osgi.framework.BundleActivator

public final class ESearchActivator
extends java.lang.Object
implements org.osgi.framework.BundleActivator

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BM_MAINTENANCE_STATE_META_KEY key for putMeta(String, String, String).

Constructor Summary

Constructors

Constructor and Description
ESearchActivator()

Method Summary

Modifier and Type	Method and Description
static void	addAliasTo(java.lang.String aliasName, java.lang.String indexName, boolean isWriteIndex)
static void	asyncIndex(java.lang.String index, java.lang.String kind, java.lang.String id, java.util.Map<java.lang.String,java.lang.Object> obj)
static void	clearClientCache()
static org.elasticsearch.client.Client	createClient(java.util.Collection<java.lang.String> hosts)
static void	delete(java.lang.String index, java.lang.String kind, java.lang.String id)
static void	deleteByQuery(java.lang.String index, org.elasticsearch.index.query.QueryBuilder query)
static void	deleteByQuery(java.lang.String index, java.lang.String query)
static void	disableFlush(java.lang.String... indexes)
static void	enableFlush(java.lang.String... indexes)
static void	flush(java.lang.String index)
static long	fsAvailable(java.lang.String indexName)
static long	fsAvailableOnNode(java.lang.String nodeId)
static org.elasticsearch.client.Client	getClient()
static org.elasticsearch.client.Client	getClient(java.lang.String tag)
static byte[]	getIndexSchema(java.lang.String indexName)
static java.lang.String	getMeta(java.lang.String index, java.lang.String key)
static RewritableIndex	getRewritableIndex(java.lang.String indexName)
static void	index(java.lang.String index, java.lang.String kind, java.lang.String id, java.util.Map<java.lang.String,java.lang.Object> obj)
static void	initClasspath()
static void	initClient(org.elasticsearch.client.Client client)
static void	initIndex(org.elasticsearch.client.Client client, java.lang.String index)
static java.util.Optional<java.lang.String>	initIndexIfNotExists(org.elasticsearch.client.Client client, java.lang.String index)
static java.util.Optional<java.lang.String>	initIndexIfNotExists(java.lang.String index)
static MailspoolStats	mailspoolStats()
static java.lang.String	nodeId(java.lang.String indexName)
static org.elasticsearch.action.search.SearchRequestBuilder	prepareSearch(java.lang.String index, org.elasticsearch.index.query.QueryBuilder query)
static org.elasticsearch.action.search.SearchRequestBuilder	prepareSearch(java.lang.String index, java.lang.String query)
static void	putMeta(java.lang.String index, java.lang.String k, java.lang.String v)
static void	refreshIndex(java.lang.String index)
static void	resetAll()
static void	resetIndex(java.lang.String index)
static void	resetIndexes()
static org.elasticsearch.search.SearchHits	search(java.lang.String index, java.lang.String query)
static org.elasticsearch.search.SearchHits	search(java.lang.String index, java.lang.String query, int from, int size)
static org.elasticsearch.search.SearchHits	search(java.lang.String index, java.lang.String query, int from, int size, java.lang.String field)
void	start(org.osgi.framework.BundleContext bundleContext)
void	stop(org.osgi.framework.BundleContext bundleContext)
static void	update(java.lang.String index, java.lang.String kind, java.lang.String id, java.lang.String field, java.lang.Object value)

Methods inherited from class java.lang.Object

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

Field Detail

BM_MAINTENANCE_STATE_META_KEY

public static final java.lang.String BM_MAINTENANCE_STATE_META_KEY

key for putMeta(String, String, String). Indices with this prop will be ignored when allocating new aliases

See Also:

Constant Field Values

Constructor Detail

ESearchActivator

public ESearchActivator()

Method Detail

start

public void start(org.osgi.framework.BundleContext bundleContext)
           throws java.lang.Exception

Specified by:

start in interface org.osgi.framework.BundleActivator

Throws:

java.lang.Exception

stop

public void stop(org.osgi.framework.BundleContext bundleContext)
          throws java.lang.Exception

Specified by:

stop in interface org.osgi.framework.BundleActivator

Throws:

java.lang.Exception

initClient

public static final void initClient(org.elasticsearch.client.Client client)

initClasspath

public static final void initClasspath()

index

public static final void index(java.lang.String index,
                               java.lang.String kind,
                               java.lang.String id,
                               java.util.Map<java.lang.String,java.lang.Object> obj)

asyncIndex

public static final void asyncIndex(java.lang.String index,
                                    java.lang.String kind,
                                    java.lang.String id,
                                    java.util.Map<java.lang.String,java.lang.Object> obj)

delete

public static final void delete(java.lang.String index,
                                java.lang.String kind,
                                java.lang.String id)

deleteByQuery

public static final void deleteByQuery(java.lang.String index,
                                       java.lang.String query)

deleteByQuery

public static final void deleteByQuery(java.lang.String index,
                                       org.elasticsearch.index.query.QueryBuilder query)

search

public static final org.elasticsearch.search.SearchHits search(java.lang.String index,
                                                               java.lang.String query)

search

public static final org.elasticsearch.search.SearchHits search(java.lang.String index,
                                                               java.lang.String query,
                                                               int from,
                                                               int size)

search

public static final org.elasticsearch.search.SearchHits search(java.lang.String index,
                                                               java.lang.String query,
                                                               int from,
                                                               int size,
                                                               java.lang.String field)

prepareSearch

public static org.elasticsearch.action.search.SearchRequestBuilder prepareSearch(java.lang.String index,
                                                                                 java.lang.String query)

prepareSearch

public static org.elasticsearch.action.search.SearchRequestBuilder prepareSearch(java.lang.String index,
                                                                                 org.elasticsearch.index.query.QueryBuilder query)

update

public static final void update(java.lang.String index,
                                java.lang.String kind,
                                java.lang.String id,
                                java.lang.String field,
                                java.lang.Object value)

getClient

public static org.elasticsearch.client.Client getClient(java.lang.String tag)

getClient

public static org.elasticsearch.client.Client getClient()

putMeta

public static void putMeta(java.lang.String index,
                           java.lang.String k,
                           java.lang.String v)

getMeta

public static java.lang.String getMeta(java.lang.String index,
                                       java.lang.String key)

createClient

public static org.elasticsearch.client.Client createClient(java.util.Collection<java.lang.String> hosts)

refreshIndex

public static void refreshIndex(java.lang.String index)

disableFlush

public static void disableFlush(java.lang.String... indexes)

enableFlush

public static void enableFlush(java.lang.String... indexes)

flush

public static void flush(java.lang.String index)

resetAll

public static void resetAll()

resetIndex

public static void resetIndex(java.lang.String index)

addAliasTo

public static void addAliasTo(java.lang.String aliasName,
                              java.lang.String indexName,
                              boolean isWriteIndex)

initIndexIfNotExists

public static java.util.Optional<java.lang.String> initIndexIfNotExists(java.lang.String index)

initIndexIfNotExists

public static java.util.Optional<java.lang.String> initIndexIfNotExists(org.elasticsearch.client.Client client,
                                                                        java.lang.String index)

initIndex

public static void initIndex(org.elasticsearch.client.Client client,
                             java.lang.String index)

getIndexSchema

public static byte[] getIndexSchema(java.lang.String indexName)

getRewritableIndex

public static RewritableIndex getRewritableIndex(java.lang.String indexName)

resetIndexes

public static void resetIndexes()

clearClientCache

public static void clearClientCache()

mailspoolStats

public static MailspoolStats mailspoolStats()

nodeId

public static java.lang.String nodeId(java.lang.String indexName)

fsAvailableOnNode

public static long fsAvailableOnNode(java.lang.String nodeId)

fsAvailable

public static long fsAvailable(java.lang.String indexName)