com.endeca.soleng.eac.toolkit.component

Class DgraphComponent

java.lang.Object

com.endeca.soleng.eac.toolkit.base.EacElement

com.endeca.soleng.eac.toolkit.base.Provisionable

com.endeca.soleng.eac.toolkit.component.Component

com.endeca.soleng.eac.toolkit.component.ServerComponent

com.endeca.soleng.eac.toolkit.component.DgraphComponent

public class DgraphComponent
extends com.endeca.soleng.eac.toolkit.component.ServerComponent

Field Summary

Fields inherited from class com.endeca.soleng.eac.toolkit.base.EacElement

appName, dataPrefix, eacHost, eacPort, elementId, lockManager, logDir, sslEnabled, workingDir

Constructor Summary

Constructors

Constructor and Description
DgraphComponent()

Method Summary

Methods

Modifier and Type	Method and Description
void	applyConfigUpdate()
void	applyConfigUpdateFromFiles(String jobId, File configFile, String directoryForFailure) Attempts to send a request to the dgraph server for updates.
void	applyIndex()
void	applyPartialUpdates()
com.endeca.eac.client.ComponentType	buildEacStub()
void	callDgraphConfigUpdateUrl() Shells out to call curl on the dgraph's config?op=update URL to trigger a configuration update.
void	callDgraphReloadServicesUrl() Shells out to call curl on the dgraph's admin?op=reload-services URL to trigger reloading of XQuery modules.
void	callDgraphUpdateUrl() Shells out to call curl on the dgraph's admin?op=update URL to trigger a partial update.
void	cleanDirs()
void	cleanLocalDgraphConfigDir()
void	cleanLocalIndexDir()
void	cleanLocalPartialsDir()
void	cleanLocalXQueryDir()
com.endeca.soleng.eac.toolkit.utility.CopyUtility	constructCopyCumulativePartialsToDgraphInput()
com.endeca.soleng.eac.toolkit.utility.CopyUtility	constructCopyDgraphConfigFromGivenDirectory(String fileDirectory)
com.endeca.soleng.eac.toolkit.utility.CopyUtility	constructCopyDgraphConfigToDgraphInput()
com.endeca.soleng.eac.toolkit.utility.CopyUtility	constructCopyIndexToNewDgraphInputDir() Constructs a utility for copying the dgraph's new index into its temporary dgraph input directory.
com.endeca.soleng.eac.toolkit.utility.perl.CreateDirUtility	constructCreateTempNewDgraphInputDir() Constructs a utility for making the dgraph's temporary dgraph input directory.
com.endeca.soleng.eac.toolkit.utility.DgraphUpdateFromFilesUtility	constructDgraphUpdateFromFileUtility(String jobId, File updateFile)
com.endeca.soleng.eac.toolkit.utility.perl.LocalMoveUtility	constructMoveCurrentDgraphInputToOld() Constructs utility for moving dgraph input (current index) to temp old index directory.
com.endeca.soleng.eac.toolkit.utility.perl.LocalMoveUtility	constructMoveNewDgraphInputToCurrent() Constructs utility for moving temp new index directory to dgraph input (current index).
com.endeca.soleng.eac.toolkit.utility.perl.RemoveDirUtility	constructRemoveTempNewIndexDir() Construct utility to remove the temp new index directory, if it exists.
com.endeca.soleng.eac.toolkit.utility.perl.RemoveDirUtility	constructRemoveTempOldIndexDir() Construct utility to remove the temp old index directory, if it exists.
com.endeca.soleng.eac.toolkit.utility.curl.DgraphConfigUpdateUtility	constructShellCallDgraphConfigUpdateUrl()
com.endeca.soleng.eac.toolkit.utility.curl.DgraphFlushCacheUtility	constructShellCallDgraphFlushCacheUrl()
com.endeca.soleng.eac.toolkit.utility.curl.DgraphReloadServicesUtility	constructShellCallDgraphReloadServicesUrl() Constructs a shell utility to call curl on the dgraph's admin?op=reload-services URL to trigger reloading of XQuery modules.
com.endeca.soleng.eac.toolkit.utility.curl.DgraphUpdateUtility	constructShellCallDgraphUpdateUrl() Constructs a shell utility to call curl on the dgraph's admin?op=update URL to trigger a partial update.
void	copyCumulativePartialsToDgraphInput() Copies cumulative partials to dgraph's update dir.
void	copyDgraphConfigToDgraphInput() Copies dgraph config to dgraph's input dir.
void	copyIndexToDgraphInput()
void	copyIndexToNewDgraphInputDir() Creates a temporary new index directory and fetches a copy of the index to the new directory.
void	copySelectFilesToDgraphInputDirectory(String fileDirectory)
String	getAppConfigDir()
List<String>	getArgs()
String	getCaFile()
String	getCertFile()
String	getCipher()
String	getInputDir()
String	getLocalCumulativePartialsDir()
String	getLocalDgraphConfigDir()
String	getLocalIndexDir()
String	getLocalXQueryDir()
int	getNumCacheWarmupSeconds()
boolean	getOfflineUpdate()
int	getPort()
String	getRestartGroup()
static String	getRestartGroupPropName()
String	getSpellDir()
String	getSrcCumulativePartialsDir()
String	getSrcCumulativePartialsHostId()
String	getSrcDgraphConfigDir()
String	getSrcDgraphConfigHostId()
String	getSrcIndexDir()
String	getSrcIndexHostId()
String	getSrcPartialsDir()
String	getSrcPartialsHostId()
String	getSrcXQueryDir()
String	getSrcXQueryHostId()
String	getTempDir()
protected String	getTempNewIndexDir() Retrieves the absolute path of the temporary new index directory to use when swapping in the new index.
protected String	getTempOldIndexDir() Retrieves the absolute path of the temporary old index directory to use when swapping in the new index.
String	getUpdateDir()
String	getUpdateGroup()
static String	getUpdateGroupPropName()
protected void	initializeEacStub(com.endeca.eac.client.DgraphComponentType stub)
void	reloadXqueryModules()
void	removeNewIndexDir() Removes the temporary new index directory.
void	removeOldIndexDir() Removes the temporary old index directory.
void	setAppConfigDir(String appConfigDir)
void	setArgs(List<String> args)
void	setCaFile(String caFile)
void	setCertFile(String certFile)
void	setCipher(String cipher)
void	setInputDir(String inputDir)
void	setPort(int port)
void	setSpellDir(String spellDir)
void	setTempDir(String tempDir)
void	setUpdateDir(String updateDir)
void	swapInNewIndexDir() Swaps in the temporary new index directory, renaming the current input directory to a temporary old directory and renaming the new directory to the current input directory.
void	updateDgraphFromXMLFile(String xmlFileLocation) Attempts to update this Dgraph using the configuration files contained in the zip file.
void	updateDgraphFromZipFile(String pZipFileLocation) Attempts to update this Dgraph using the configuration files contained in the zip file.

Methods inherited from class com.endeca.soleng.eac.toolkit.component.ServerComponent

cycle, getNumIdleSecondsAfterStop, getPostStartupScript, getPreShutdownScript, getShutdownTimeout, getStartupTimeout, isRunning, isStarting, setPostStartupScript, setPreShutdownScript, setStartupTimeout, start, startAsynchronously, startInParallel, stop, stopAsynchronously, stopInParallel, waitForStarted, waitForStopped

Methods inherited from class com.endeca.soleng.eac.toolkit.component.Component

archiveLogDir, cleanDir, constructArchiveLogDir, constructCleanDir, getCustomDirectories, getDirProperties, getHost, getHostId, getLongPropertyValueOrDefault, getMaxMissedStatusChecksAllowed, getMaxWaitTimeSeconds, getMinWaitTimeSeconds, getNumLogBackups, getNumMissedStatusChecks, getProperties, getProperty, getSlowPollingIntervalMs, getStandardPollingIntervalMs, getStatus, incrementMissedStatusQueries, initializeEacStub, isActive, isDefined, isDefinitionChanged, isFailed, isHotUpdateDefinitionChange, isSkipTestingForFilesDuringCleanup, removeDefinition, setCustomDirectories, setDefinition, setDefinition, setHost, setHostId, setNumMissedStatusChecks, setProperties, updateDefinition, updateEacDefinition, updateEacDefinition, waitForFinished

Methods inherited from class com.endeca.soleng.eac.toolkit.base.Provisionable

getAppDefinitionFromEac, getCachedAppDefinition, getProvisioningPort, invalidateCachedAppDefinition, setCachedAppDefinition

Methods inherited from class com.endeca.soleng.eac.toolkit.base.EacElement

getAppName, getDataPrefix, getEacHost, getEacPort, getElementId, getLockManager, getLogDir, getWorkingDir, isSslEnabled, setAppName, setDataPrefix, setEacHost, setEacPort, setElementId, setLockManager, setLogDir, setSslEnabled, setWorkingDir

Methods inherited from class java.lang.Object

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

Constructor Detail

DgraphComponent

public DgraphComponent()

Method Detail

callDgraphUpdateUrl

public void callDgraphUpdateUrl()
                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                InterruptedException

Shells out to call curl on the dgraph's admin?op=update URL to trigger a partial update.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

constructShellCallDgraphUpdateUrl

public com.endeca.soleng.eac.toolkit.utility.curl.DgraphUpdateUtility constructShellCallDgraphUpdateUrl()
                                                                                                 throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Constructs a shell utility to call curl on the dgraph's admin?op=update URL to trigger a partial update.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

callDgraphConfigUpdateUrl

public void callDgraphConfigUpdateUrl()
                               throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                      com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                      com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                      InterruptedException

Shells out to call curl on the dgraph's config?op=update URL to trigger a configuration update. This method will then call dgraph's admin?op=flush URL to flush the dgraph's cache so that new config is properly picked up.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

constructShellCallDgraphConfigUpdateUrl

public com.endeca.soleng.eac.toolkit.utility.curl.DgraphConfigUpdateUtility constructShellCallDgraphConfigUpdateUrl()
                                                                                                             throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

constructShellCallDgraphFlushCacheUrl

public com.endeca.soleng.eac.toolkit.utility.curl.DgraphFlushCacheUtility constructShellCallDgraphFlushCacheUrl()
                                                                                                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

callDgraphReloadServicesUrl

public void callDgraphReloadServicesUrl()
                                 throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                        com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                        com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                        InterruptedException

Shells out to call curl on the dgraph's admin?op=reload-services URL to trigger reloading of XQuery modules.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

constructShellCallDgraphReloadServicesUrl

public com.endeca.soleng.eac.toolkit.utility.curl.DgraphReloadServicesUtility constructShellCallDgraphReloadServicesUrl()
                                                                                                                 throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Constructs a shell utility to call curl on the dgraph's admin?op=reload-services URL to trigger reloading of XQuery modules.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

constructDgraphUpdateFromFileUtility

public com.endeca.soleng.eac.toolkit.utility.DgraphUpdateFromFilesUtility constructDgraphUpdateFromFileUtility(String jobId,
                                                                                                      File updateFile)
                                                                                                        throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

cleanDirs

public void cleanDirs()
               throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                      com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                      com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                      InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

cleanLocalIndexDir

public void cleanLocalIndexDir()
                        throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                               com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                               com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                               InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

cleanLocalPartialsDir

public void cleanLocalPartialsDir()
                           throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                  com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                  com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                  InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

cleanLocalDgraphConfigDir

public void cleanLocalDgraphConfigDir()
                               throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                      com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                      com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                      InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

cleanLocalXQueryDir

public void cleanLocalXQueryDir()
                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

copyIndexToDgraphInput

public void copyIndexToDgraphInput()
                            throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                   com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                   InterruptedException,
                                   com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

applyIndex

public void applyIndex()
                throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                       com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                       InterruptedException,
                       com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

applyPartialUpdates

public void applyPartialUpdates()
                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

applyConfigUpdate

public void applyConfigUpdate()
                       throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                              com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                              com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                              InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

applyConfigUpdateFromFiles

public void applyConfigUpdateFromFiles(String jobId,
                              File configFile,
                              String directoryForFailure)
                                throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                       com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                       com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                       com.endeca.soleng.eac.toolkit.exception.EacInputValidationException,
                                       InterruptedException

Attempts to send a request to the dgraph server for updates. If the update fails, we check the response code. Based on the response code, three different actions could be taken. If a 200 is returned, that means it was successful update, no further action required. If a 500 code is returned, that means there was probably a problem with the SOAP xml. So instead of trying to copy the files where 4 of 6 files are actually valid, throw an exception and expect the user to fix the problem by checking the logs instead of copying the files over that failed. Otherwise any other response code code will invoke a copy call, which will copy the files from the directoryForFailure parameter to the dgraph's input directory

Parameters:

jobId -

configFile - - decorated SOAP file used to transmit

directoryForFailure - - location of the extracted files to copy over if the http request fails

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException - - problem copying the files

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException - - problem copying the files

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException - - problem copying the files

com.endeca.soleng.eac.toolkit.exception.EacInputValidationException - - if a 500 error occurs

InterruptedException

reloadXqueryModules

public void reloadXqueryModules()
                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

copyIndexToNewDgraphInputDir

public void copyIndexToNewDgraphInputDir()
                                  throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                         com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                         com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                         InterruptedException

Creates a temporary new index directory and fetches a copy of the index to the new directory.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

constructCreateTempNewDgraphInputDir

public com.endeca.soleng.eac.toolkit.utility.perl.CreateDirUtility constructCreateTempNewDgraphInputDir()
                                                                                                 throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Constructs a utility for making the dgraph's temporary dgraph input directory.

Returns:

CreateDirUtility for creating temp dgraph input directory.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

constructCopyIndexToNewDgraphInputDir

public com.endeca.soleng.eac.toolkit.utility.CopyUtility constructCopyIndexToNewDgraphInputDir()
                                                                                        throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Constructs a utility for copying the dgraph's new index into its temporary dgraph input directory.

Returns:

CopyUtility for copying the new index into the temp dgraph input directory.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

copyCumulativePartialsToDgraphInput

public void copyCumulativePartialsToDgraphInput()
                                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                                com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                                com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                                InterruptedException

Copies cumulative partials to dgraph's update dir.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

constructCopyCumulativePartialsToDgraphInput

public com.endeca.soleng.eac.toolkit.utility.CopyUtility constructCopyCumulativePartialsToDgraphInput()
                                                                                               throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

copySelectFilesToDgraphInputDirectory

public void copySelectFilesToDgraphInputDirectory(String fileDirectory)
                                           throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                                  com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                                  com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                                  InterruptedException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

InterruptedException

constructCopyDgraphConfigFromGivenDirectory

public com.endeca.soleng.eac.toolkit.utility.CopyUtility constructCopyDgraphConfigFromGivenDirectory(String fileDirectory)
                                                                                              throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

copyDgraphConfigToDgraphInput

public void copyDgraphConfigToDgraphInput()
                                   throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                          com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                                          com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                                          InterruptedException

Copies dgraph config to dgraph's input dir.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

constructCopyDgraphConfigToDgraphInput

public com.endeca.soleng.eac.toolkit.utility.CopyUtility constructCopyDgraphConfigToDgraphInput()
                                                                                         throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

swapInNewIndexDir

public void swapInNewIndexDir()
                       throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                              com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                              com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

Swaps in the temporary new index directory, renaming the current input directory to a temporary old directory and renaming the new directory to the current input directory.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

constructMoveCurrentDgraphInputToOld

public com.endeca.soleng.eac.toolkit.utility.perl.LocalMoveUtility constructMoveCurrentDgraphInputToOld()
                                                                                                 throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Constructs utility for moving dgraph input (current index) to temp old index directory.

Returns:

LocalMoveUtility for moving dgraph input to temp old index dir.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

constructMoveNewDgraphInputToCurrent

public com.endeca.soleng.eac.toolkit.utility.perl.LocalMoveUtility constructMoveNewDgraphInputToCurrent()
                                                                                                 throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

Constructs utility for moving temp new index directory to dgraph input (current index).

Returns:

LocalMoveUtility for moving temp new index dir to graph input.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

removeOldIndexDir

public void removeOldIndexDir()
                       throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                              com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                              com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                              InterruptedException

Removes the temporary old index directory.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

constructRemoveTempOldIndexDir

public com.endeca.soleng.eac.toolkit.utility.perl.RemoveDirUtility constructRemoveTempOldIndexDir()
                                                                                           throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                                                                                  com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

Construct utility to remove the temp old index directory, if it exists.

Returns:

RemoveDirUtility to remove temp old index directory, or null if the directory doesn't exist.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

removeNewIndexDir

public void removeNewIndexDir()
                       throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                              com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
                              com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
                              InterruptedException

Removes the temporary new index directory.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

InterruptedException

com.endeca.soleng.eac.toolkit.exception.EacComponentControlException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

constructRemoveTempNewIndexDir

public com.endeca.soleng.eac.toolkit.utility.perl.RemoveDirUtility constructRemoveTempNewIndexDir()
                                                                                           throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
                                                                                                  com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

Construct utility to remove the temp new index directory, if it exists.

Returns:

RemoveDirUtility to remove temp new index directory, or null if the directory doesn't exist.

Throws:

com.endeca.soleng.eac.toolkit.exception.AppConfigurationException

com.endeca.soleng.eac.toolkit.exception.EacCommunicationException

getTempNewIndexDir

protected String getTempNewIndexDir()

Retrieves the absolute path of the temporary new index directory to use when swapping in the new index.

Returns:

Returns the absolute path of the temp new index directory.

getTempOldIndexDir

protected String getTempOldIndexDir()

Retrieves the absolute path of the temporary old index directory to use when swapping in the new index.

Returns:

Returns the absolute path of the temp old index directory.

buildEacStub

public com.endeca.eac.client.ComponentType buildEacStub()

Overrides:

buildEacStub in class com.endeca.soleng.eac.toolkit.component.Component

initializeEacStub

protected void initializeEacStub(com.endeca.eac.client.DgraphComponentType stub)

updateDgraphFromZipFile

public void updateDgraphFromZipFile(String pZipFileLocation)

Attempts to update this Dgraph using the configuration files contained in the zip file. The zip file is extracted and the xml documents contained inside are wrapped in SOAP tags. The resulting documents are pushed to the dgraph using the /ws/config servlet

Parameters:

pZipFileLocation -

updateDgraphFromXMLFile

public void updateDgraphFromXMLFile(String xmlFileLocation)

Attempts to update this Dgraph using the configuration files contained in the zip file. The zip file is extracted and the xml documents contained inside are wrapped in SOAP tags. The resulting documents are pushed to the dgraph using the /ws/config servlet

Parameters:

xmlFileLocation -

getRestartGroupPropName

public static String getRestartGroupPropName()

getUpdateGroupPropName

public static String getUpdateGroupPropName()

getRestartGroup

public String getRestartGroup()

getUpdateGroup

public String getUpdateGroup()

getSrcIndexDir

public String getSrcIndexDir()

getSrcIndexHostId

public String getSrcIndexHostId()

getLocalIndexDir

public String getLocalIndexDir()

getSrcPartialsDir

public String getSrcPartialsDir()

getSrcPartialsHostId

public String getSrcPartialsHostId()

getSrcCumulativePartialsDir

public String getSrcCumulativePartialsDir()

getSrcCumulativePartialsHostId

public String getSrcCumulativePartialsHostId()

getLocalCumulativePartialsDir

public String getLocalCumulativePartialsDir()

getSrcDgraphConfigDir

public String getSrcDgraphConfigDir()

getSrcDgraphConfigHostId

public String getSrcDgraphConfigHostId()

getLocalDgraphConfigDir

public String getLocalDgraphConfigDir()

getSrcXQueryDir

public String getSrcXQueryDir()

getSrcXQueryHostId

public String getSrcXQueryHostId()

getLocalXQueryDir

public String getLocalXQueryDir()

getOfflineUpdate

public boolean getOfflineUpdate()

getNumCacheWarmupSeconds

public int getNumCacheWarmupSeconds()

getAppConfigDir

public String getAppConfigDir()

setAppConfigDir

public void setAppConfigDir(String appConfigDir)

getArgs

public List<String> getArgs()

setArgs

public void setArgs(List<String> args)

getInputDir

public String getInputDir()

setInputDir

public void setInputDir(String inputDir)

getPort

public int getPort()

setPort

public void setPort(int port)

getSpellDir

public String getSpellDir()

setSpellDir

public void setSpellDir(String spellDir)

getTempDir

public String getTempDir()

setTempDir

public void setTempDir(String tempDir)

getUpdateDir

public String getUpdateDir()

setUpdateDir

public void setUpdateDir(String updateDir)

getCaFile

public String getCaFile()

setCaFile

public void setCaFile(String caFile)

getCertFile

public String getCertFile()

setCertFile

public void setCertFile(String certFile)

getCipher

public String getCipher()

setCipher

public void setCipher(String cipher)