com.attivio.platform.store

Class MockConnectorHistory

java.lang.Object

com.attivio.platform.store.MockConnectorHistory

All Implemented Interfaces:

ConnectorHistoryApi

public class MockConnectorHistory
extends Object
implements ConnectorHistoryApi

Field Summary

Fields inherited from interface com.attivio.sdk.client.ConnectorHistoryApi

CONNECTOR_ABANDONMENT_DELAY, CONNECTOR_HISTORY_RECORD_EMPTY_EXECUTIONS

Constructor Summary

Constructors

Constructor and Description
MockConnectorHistory()

Method Summary

Modifier and Type	Method and Description
void	clearHistory(String connectorName) Removes all history associated with the connector.
void	connectorCompleted(String connectorName, long finalDocCount) The connector has completed -- all documents have been fully processed.
void	connectorCompleting(String connectorName) The connector is completing -- all documents have been sent but have not finished being processed.
void	connectorPaused(String connectorName) A node has paused the connector.
void	connectorQueued(String connectorName, UUID clientId, String workflow, List<String> extraRunInfo, boolean external) The connector has been submitted for execution on an AIE node.
void	connectorReset(String connectorName) Indicates that the incremental state of the connector has been reset.
void	connectorResumed(String connectorName) A node has resumed a paused connector.
void	connectorStarted(String connectorName, long timestamp) A node has started executing the connector.
ConnectorExecutionRecord	getCurrentExecutionRecord(String connectorName) Note, the connector does not have to be defined.
Iterable<ConnectorExecutionRecord>	getHistory(String connectorName)
ConnectorExecutionRecord	getLatestHistory(String connectorName)
void	reset()
void	updateExtraRunInfo(String connectorName, List<String> extraRunInfo) Updates the extraRunInfo for connectorName.
void	updateSentCount(String connectorName, long docCount) Updates the number of documents sent by connectorName.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.attivio.sdk.client.ConnectorHistoryApi

delayBeforeCheckingAbandonment

Constructor Detail

MockConnectorHistory

public MockConnectorHistory()

Method Detail

connectorQueued

public void connectorQueued(String connectorName,
                            UUID clientId,
                            String workflow,
                            List<String> extraRunInfo,
                            boolean external)
                     throws AttivioException

The connector has been submitted for execution on an AIE node. Indicates a transition from NOT_RUNNING to WAITING_TO_START.

Specified by:

connectorQueued in interface ConnectorHistoryApi

clientId - the clientId to associate with this iteration of the connector

extraRunInfo - additional metadata to associate with the new execution

external - true if the connector is an external connector

Throws:

AttivioException - with if connector is already executing

connectorStarted

public void connectorStarted(String connectorName,
                             long timestamp)
                      throws AttivioException

A node has started executing the connector. Indicates a transition from WAITING_TO_START to RUNNING. The timestamp parameter is used to associate a connector execution and subsequent incremental executions with each other. It will generally be the start time of the baseline connector execution.

Specified by:

connectorStarted in interface ConnectorHistoryApi

timestamp - the timestamp associated with this connector execution.

Throws:

AttivioException

connectorPaused

public void connectorPaused(String connectorName)
                     throws AttivioException

A node has paused the connector. Indicates a transition from RUNNING to PAUSED

Specified by:

connectorPaused in interface ConnectorHistoryApi

Throws:

AttivioException

connectorResumed

public void connectorResumed(String connectorName)
                      throws AttivioException

A node has resumed a paused connector. Indicates a transition from PAUSED to RUNNING

Specified by:

connectorResumed in interface ConnectorHistoryApi

Throws:

AttivioException

connectorCompleting

public void connectorCompleting(String connectorName)
                         throws AttivioException

The connector is completing -- all documents have been sent but have not finished being processed. Indicates a transition from RUNNING to COMPLETING.

Specified by:

connectorCompleting in interface ConnectorHistoryApi

Throws:

AttivioException

connectorCompleted

public void connectorCompleted(String connectorName,
                               long finalDocCount)
                        throws AttivioException

The connector has completed -- all documents have been fully processed. Indicates a transition from COMPLETING to NOT_RUNNING. The current time becomes the time returned by ConnectorExecutionRecord.getFinishTime() for the history record.

Specified by:

connectorCompleted in interface ConnectorHistoryApi

Throws:

AttivioException

updateSentCount

public void updateSentCount(String connectorName,
                            long docCount)
                     throws AttivioException

Updates the number of documents sent by connectorName.

Specified by:

updateSentCount in interface ConnectorHistoryApi

Throws:

AttivioException

clearHistory

public void clearHistory(String connectorName)
                  throws AttivioException

Removes all history associated with the connector. If the connector is currently running the current history is not removed.

Specified by:

clearHistory in interface ConnectorHistoryApi

Throws:

AttivioException

getLatestHistory

public ConnectorExecutionRecord getLatestHistory(String connectorName)

Specified by:

getLatestHistory in interface ConnectorHistoryApi

Returns:

the ConnectorExecutionRecord with the latest finish time or null if the connector has never completed an execution.

getHistory

public Iterable<ConnectorExecutionRecord> getHistory(String connectorName)

Specified by:

getHistory in interface ConnectorHistoryApi

Returns:

all the history records for this connector.

getCurrentExecutionRecord

public ConnectorExecutionRecord getCurrentExecutionRecord(String connectorName)

Note, the connector does not have to be defined.

Specified by:

getCurrentExecutionRecord in interface ConnectorHistoryApi

Returns:

the ConnectorExecutionRecord of the currently executing connector connectorName or null if the connector is not currently executing.

reset

public void reset()

connectorReset

public void connectorReset(String connectorName)
                    throws AttivioException

Indicates that the incremental state of the connector has been reset. Invalid to call while a connector is currently executing. After this call, the latest history for the connector will have a status of ConnectorExecutionStatus.RESET.

Specified by:

connectorReset in interface ConnectorHistoryApi

Throws:

AttivioException

updateExtraRunInfo

public void updateExtraRunInfo(String connectorName,
                               List<String> extraRunInfo)
                        throws AttivioException

Updates the extraRunInfo for connectorName. The existing run information is replaced with extraRunInfo.

Specified by:

updateExtraRunInfo in interface ConnectorHistoryApi

Throws:

AttivioException