com.lucidworks.apollo.component

Class SolrHistoryStore

java.lang.Object

com.lucidworks.apollo.component.HistoryStore

com.lucidworks.apollo.component.SolrHistoryStore

public class SolrHistoryStore
extends HistoryStore

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_HISTORY_CLUSTER_NAME
static java.lang.String	DEFAULT_HISTORY_COLLECTION_NAME
static java.lang.String	DEFAULT_TIME_RANGE
static java.lang.String	ITEM_FIELD
static java.lang.String	ITEM_LEVEL
static java.lang.String	LEVEL_FIELD
static java.lang.String	SERVICE_FIELD
static java.lang.String	SERVICE_LEVEL
static java.lang.String	TIMESTAMP_FIELD

Constructor Summary

Constructors

Constructor and Description
SolrHistoryStore(ConfigurationComponent configurationComponent, CollectionManager collectionManager, CollectionComponent collectionComponent, CuratorComponent curatorComponent, SearchClusterComponent searchClusterComponent, ObjectMapper mapper, com.lucidworks.apollo.links.LinkManager linkManager)

Method Summary

Modifier and Type	Method and Description
void	addItemHistory(java.lang.String service, java.lang.String item, com.lucidworks.apollo.common.models.HistoryEvent event)
void	addItemHistory(java.lang.String service, java.lang.String item, com.lucidworks.apollo.common.models.HistoryEvent event, java.lang.Boolean commit)
void	addServiceHistory(java.lang.String service, com.lucidworks.apollo.common.models.HistoryEvent event)
void	clearAllItemHistory(java.lang.String service)
void	clearAllServiceHistory()
void	clearItemHistory(java.lang.String service, java.lang.String item)
void	clearServiceHistory(java.lang.String service)
void	flushBuffers()
com.lucidworks.apollo.common.models.History	getItemHistory(java.lang.String service, java.lang.String item, java.lang.String timeRange, int maxLength)
com.lucidworks.apollo.common.models.History	getServiceHistory(java.lang.String service, java.lang.String timeRange, int maxLength)
void	init(CuratorComponent curatorComponent, SearchClusterComponent searchClusterComponent, CollectionComponent collectionComponent, com.lucidworks.apollo.links.LinkManager linkManager)
java.util.List<java.lang.String>	listAllItems(java.lang.String service)
java.util.List<java.lang.String>	listAllItems(java.lang.String service, java.lang.String timeRange)
java.util.List<java.lang.String>	listAllServices(java.lang.String timeRange)

Methods inherited from class com.lucidworks.apollo.component.HistoryStore

listAllServices

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_HISTORY_COLLECTION_NAME

public static final java.lang.String DEFAULT_HISTORY_COLLECTION_NAME

See Also:

Constant Field Values

DEFAULT_HISTORY_CLUSTER_NAME

public static final java.lang.String DEFAULT_HISTORY_CLUSTER_NAME

See Also:

Constant Field Values

SERVICE_FIELD

public static final java.lang.String SERVICE_FIELD

See Also:

Constant Field Values

ITEM_FIELD

public static final java.lang.String ITEM_FIELD

See Also:

Constant Field Values

LEVEL_FIELD

public static final java.lang.String LEVEL_FIELD

See Also:

Constant Field Values

SERVICE_LEVEL

public static final java.lang.String SERVICE_LEVEL

See Also:

Constant Field Values

ITEM_LEVEL

public static final java.lang.String ITEM_LEVEL

See Also:

Constant Field Values

TIMESTAMP_FIELD

public static final java.lang.String TIMESTAMP_FIELD

See Also:

Constant Field Values

DEFAULT_TIME_RANGE

public static final java.lang.String DEFAULT_TIME_RANGE

See Also:

Constant Field Values

Constructor Detail

SolrHistoryStore

public SolrHistoryStore(ConfigurationComponent configurationComponent,
                        CollectionManager collectionManager,
                        CollectionComponent collectionComponent,
                        CuratorComponent curatorComponent,
                        SearchClusterComponent searchClusterComponent,
                        ObjectMapper mapper,
                        com.lucidworks.apollo.links.LinkManager linkManager)

Method Detail

init

@WhenReady
public void init(CuratorComponent curatorComponent,
                            SearchClusterComponent searchClusterComponent,
                            CollectionComponent collectionComponent,
                            com.lucidworks.apollo.links.LinkManager linkManager)

flushBuffers

public void flushBuffers()

Specified by:

flushBuffers in class HistoryStore

addServiceHistory

public void addServiceHistory(java.lang.String service,
                              com.lucidworks.apollo.common.models.HistoryEvent event)
                       throws java.io.IOException

Specified by:

addServiceHistory in class HistoryStore

Throws:

java.io.IOException

addItemHistory

public void addItemHistory(java.lang.String service,
                           java.lang.String item,
                           com.lucidworks.apollo.common.models.HistoryEvent event)
                    throws java.io.IOException

Specified by:

addItemHistory in class HistoryStore

Throws:

java.io.IOException

getServiceHistory

public com.lucidworks.apollo.common.models.History getServiceHistory(java.lang.String service,
                                                                     java.lang.String timeRange,
                                                                     int maxLength)
                                                              throws java.io.IOException

Specified by:

getServiceHistory in class HistoryStore

Throws:

java.io.IOException

getItemHistory

public com.lucidworks.apollo.common.models.History getItemHistory(java.lang.String service,
                                                                  java.lang.String item,
                                                                  java.lang.String timeRange,
                                                                  int maxLength)
                                                           throws java.io.IOException

Specified by:

getItemHistory in class HistoryStore

Throws:

java.io.IOException

listAllServices

public java.util.List<java.lang.String> listAllServices(java.lang.String timeRange)
                                                 throws java.io.IOException

Specified by:

listAllServices in class HistoryStore

Throws:

java.io.IOException

listAllItems

public java.util.List<java.lang.String> listAllItems(java.lang.String service)
                                              throws java.io.IOException

Specified by:

listAllItems in class HistoryStore

Throws:

java.io.IOException

listAllItems

public java.util.List<java.lang.String> listAllItems(java.lang.String service,
                                                     java.lang.String timeRange)
                                              throws java.io.IOException

Specified by:

listAllItems in class HistoryStore

Throws:

java.io.IOException

clearServiceHistory

public void clearServiceHistory(java.lang.String service)
                         throws java.io.IOException

Specified by:

clearServiceHistory in class HistoryStore

Throws:

java.io.IOException

clearAllServiceHistory

public void clearAllServiceHistory()
                            throws java.io.IOException

Specified by:

clearAllServiceHistory in class HistoryStore

Throws:

java.io.IOException

clearItemHistory

public void clearItemHistory(java.lang.String service,
                             java.lang.String item)
                      throws java.io.IOException

Specified by:

clearItemHistory in class HistoryStore

Throws:

java.io.IOException

clearAllItemHistory

public void clearAllItemHistory(java.lang.String service)
                         throws java.io.IOException

Specified by:

clearAllItemHistory in class HistoryStore

Throws:

java.io.IOException

addItemHistory

public void addItemHistory(java.lang.String service,
                           java.lang.String item,
                           com.lucidworks.apollo.common.models.HistoryEvent event,
                           java.lang.Boolean commit)
                    throws java.io.IOException

Specified by:

addItemHistory in class HistoryStore

Throws:

java.io.IOException