org.alfresco.solr.tracker

Class MetadataTracker

java.lang.Object

org.alfresco.solr.tracker.AbstractTracker

org.alfresco.solr.tracker.MetadataTracker

All Implemented Interfaces:

Tracker

public class MetadataTracker
extends AbstractTracker
implements Tracker

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log

Fields inherited from class org.alfresco.solr.tracker.AbstractTracker

alfrescoVersion, batchCount, client, coreName, infoSrv, isMaster, isSlave, props, runPostModelLoadInit, shardCount, shardInstance, shardTemplate, storeRef, threadHandler, TIME_STEP_1_HR_IN_MS, TIME_STEP_32_DAYS_IN_MS, trackerStats, transformContent

Constructor Summary

Constructors

Constructor and Description
MetadataTracker(Properties p, org.alfresco.solr.client.SOLRAPIClient client, String coreName, InformationServer informationServer)

Method Summary

Modifier and Type	Method and Description
void	addNodeToIndex(Long nodeId)
void	addNodeToPurge(Long nodeId)
void	addNodeToReindex(Long nodeId)
void	addQueryToReindex(String query)
void	addTransactionToIndex(Long txId)
void	addTransactionToPurge(Long txId)
void	addTransactionToReindex(Long txId)
org.alfresco.solr.tracker.IndexHealthReport	checkIndex(Long toTx, Long toAclTx, Long fromTime, Long toTime)
org.alfresco.solr.NodeReport	checkNode(Long dbid)
org.alfresco.solr.NodeReport	checkNode(org.alfresco.solr.client.Node node)
protected void	doTrack() Subclasses must implement behaviour that completes the following steps, in order: Purge Reindex Index Track repository
List<org.alfresco.solr.client.Node>	getFullNodesForDbTransaction(Long txid)
protected org.alfresco.solr.client.Transactions	getSomeTransactions(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound, Long fromCommitTime, long timeStep, int maxResults, long endTime)
protected Long	getTxFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound, long lastGoodTxCommitTimeInIndex)
protected void	trackTransactions()

Methods inherited from class org.alfresco.solr.tracker.AbstractTracker

checkShutdown, close, getAlfrescoVersion, getMaxLiveSearchers, getTrackerState, isInAclShard, setShutdown, track, waitForAsynchronous

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.alfresco.solr.tracker.Tracker

close, getAlfrescoVersion, getTrackerState, setShutdown, track

Field Detail

log

protected static final org.slf4j.Logger log

Constructor Detail

MetadataTracker

public MetadataTracker(Properties p,
                       org.alfresco.solr.client.SOLRAPIClient client,
                       String coreName,
                       InformationServer informationServer)

Method Detail

doTrack

protected void doTrack()
                throws org.alfresco.httpclient.AuthenticationException,
                       IOException,
                       org.json.JSONException,
                       org.apache.commons.codec.EncoderException

Description copied from class: AbstractTracker

Subclasses must implement behaviour that completes the following steps, in order:

1. Purge
2. Reindex
3. Index
4. Track repository

Specified by:

doTrack in class AbstractTracker

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

org.apache.commons.codec.EncoderException

getTxFromCommitTime

protected Long getTxFromCommitTime(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound,
                                   long lastGoodTxCommitTimeInIndex)

getSomeTransactions

protected org.alfresco.solr.client.Transactions getSomeTransactions(org.alfresco.solr.BoundedDeque<org.alfresco.solr.client.Transaction> txnsFound,
                                                                    Long fromCommitTime,
                                                                    long timeStep,
                                                                    int maxResults,
                                                                    long endTime)
                                                             throws org.alfresco.httpclient.AuthenticationException,
                                                                    IOException,
                                                                    org.json.JSONException,
                                                                    org.apache.commons.codec.EncoderException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

org.apache.commons.codec.EncoderException

trackTransactions

protected void trackTransactions()
                          throws org.alfresco.httpclient.AuthenticationException,
                                 IOException,
                                 org.json.JSONException,
                                 org.apache.commons.codec.EncoderException

Throws:

org.alfresco.httpclient.AuthenticationException

IOException

org.json.JSONException

org.apache.commons.codec.EncoderException

checkNode

public org.alfresco.solr.NodeReport checkNode(Long dbid)

checkNode

public org.alfresco.solr.NodeReport checkNode(org.alfresco.solr.client.Node node)

getFullNodesForDbTransaction

public List<org.alfresco.solr.client.Node> getFullNodesForDbTransaction(Long txid)

checkIndex

public org.alfresco.solr.tracker.IndexHealthReport checkIndex(Long toTx,
                                                              Long toAclTx,
                                                              Long fromTime,
                                                              Long toTime)
                                                       throws IOException,
                                                              org.alfresco.httpclient.AuthenticationException,
                                                              org.json.JSONException,
                                                              org.apache.commons.codec.EncoderException

Throws:

IOException

org.alfresco.httpclient.AuthenticationException

org.json.JSONException

org.apache.commons.codec.EncoderException

addTransactionToPurge

public void addTransactionToPurge(Long txId)

addNodeToPurge

public void addNodeToPurge(Long nodeId)

addTransactionToReindex

public void addTransactionToReindex(Long txId)

addNodeToReindex

public void addNodeToReindex(Long nodeId)

addTransactionToIndex

public void addTransactionToIndex(Long txId)

addNodeToIndex

public void addNodeToIndex(Long nodeId)

addQueryToReindex

public void addQueryToReindex(String query)

Parameters:

query -