public class ManifoldCF extends ManifoldCF
Modifier and Type | Class and Description |
---|---|
protected static class |
ManifoldCF.PipelineStage |
ManifoldCF.CachePoll, ManifoldCF.DatabaseConnectionReleaseThread, ManifoldCF.DatabaseShutdown, ManifoldCF.FileTrack, ManifoldCF.OverrideableManifoldCFConfiguration, ManifoldCF.ShutdownThread
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
_rcsid |
protected static java.lang.String |
API_ACTIVITYNODE |
protected static java.lang.String |
API_AUTHORITYCONNECTIONNODE |
protected static java.lang.String |
API_AUTHORITYCONNECTORNODE |
protected static java.lang.String |
API_AUTHORITYGROUPNODE |
protected static java.lang.String |
API_AUTHORIZATIONDOMAINNODE |
protected static java.lang.String |
API_CHECKRESULTNODE |
protected static java.lang.String |
API_COLUMNNODE |
protected static java.lang.String |
API_CONNECTIONNAMENODE |
protected static java.lang.String |
API_JOBIDNODE |
protected static java.lang.String |
API_JOBNODE |
protected static java.lang.String |
API_JOBSTATUSNODE |
protected static java.lang.String |
API_MAPPINGCONNECTIONNODE |
protected static java.lang.String |
API_MAPPINGCONNECTORNODE |
protected static java.lang.String |
API_NAMENODE |
protected static java.lang.String |
API_NOTIFICATIONCONNECTIONNODE |
protected static java.lang.String |
API_NOTIFICATIONCONNECTORNODE |
protected static java.lang.String |
API_OUTPUTCONNECTIONNODE |
protected static java.lang.String |
API_OUTPUTCONNECTORNODE |
protected static java.lang.String |
API_REPOSITORYCONNECTIONNODE |
protected static java.lang.String |
API_REPOSITORYCONNECTORNODE |
protected static java.lang.String |
API_ROWNODE |
protected static java.lang.String |
API_TRANSFORMATIONCONNECTIONNODE |
protected static java.lang.String |
API_TRANSFORMATIONCONNECTORNODE |
protected static java.lang.String |
API_VALUENODE |
protected static java.lang.String |
ATTRIBUTE_CLASS |
protected static java.lang.String |
ATTRIBUTE_DOMAIN |
protected static java.lang.String |
ATTRIBUTE_NAME |
protected static java.lang.String |
AUTHGROUPNODE_DESCRIPTION |
protected static java.lang.String |
AUTHGROUPNODE_ISNEW |
protected static java.lang.String |
AUTHGROUPNODE_NAME |
protected static java.lang.String |
AUTHORIZATIONDOMAINNODE_DESCRIPTION |
protected static java.lang.String |
AUTHORIZATIONDOMAINNODE_DOMAINNAME |
protected static java.lang.String |
cleanupThreadCountProperty |
protected static java.lang.String |
CONNECTIONNODE_ACLAUTHORITY |
protected static java.lang.String |
CONNECTIONNODE_AUTHDOMAIN |
protected static java.lang.String |
CONNECTIONNODE_AUTHGROUP |
protected static java.lang.String |
CONNECTIONNODE_CLASSNAME |
protected static java.lang.String |
CONNECTIONNODE_CONFIGURATION |
protected static java.lang.String |
CONNECTIONNODE_DESCRIPTION |
protected static java.lang.String |
CONNECTIONNODE_ISNEW |
protected static java.lang.String |
CONNECTIONNODE_MATCH |
protected static java.lang.String |
CONNECTIONNODE_MATCHDESCRIPTION |
protected static java.lang.String |
CONNECTIONNODE_MAXCONNECTIONS |
protected static java.lang.String |
CONNECTIONNODE_NAME |
protected static java.lang.String |
CONNECTIONNODE_PREREQUISITE |
protected static java.lang.String |
CONNECTIONNODE_RATE |
protected static java.lang.String |
CONNECTIONNODE_THROTTLE |
protected static java.lang.String |
CONNECTORNODE_CLASSNAME |
protected static java.lang.String |
CONNECTORNODE_DESCRIPTION |
protected static java.lang.String |
connectorsConfigurationFileProperty |
protected static boolean |
crawlerInitialized |
protected static java.lang.String |
databaseSuperuserNameProperty |
protected static java.lang.String |
databaseSuperuserPasswordProperty |
static int |
DELETERESULT_FOUND |
static int |
DELETERESULT_NOTALLOWED |
static int |
DELETERESULT_NOTFOUND |
protected static java.lang.String |
deleteThreadCountProperty |
protected static java.util.Map<java.lang.String,java.lang.Integer> |
docState |
protected static java.util.Map<java.lang.String,java.lang.Integer> |
docStatus |
protected static java.lang.String |
expireThreadCountProperty |
protected static java.lang.String |
JOBNODE_CONNECTIONNAME |
protected static java.lang.String |
JOBNODE_COUNT |
protected static java.lang.String |
JOBNODE_DAYOFMONTH |
protected static java.lang.String |
JOBNODE_DAYOFWEEK |
protected static java.lang.String |
JOBNODE_DESCRIPTION |
protected static java.lang.String |
JOBNODE_DOCUMENTSPECIFICATION |
protected static java.lang.String |
JOBNODE_DURATION |
protected static java.lang.String |
JOBNODE_ENUMVALUE |
protected static java.lang.String |
JOBNODE_EXPIRATIONINTERVAL |
protected static java.lang.String |
JOBNODE_HOPCOUNT |
protected static java.lang.String |
JOBNODE_HOPCOUNTMODE |
protected static java.lang.String |
JOBNODE_HOUROFDAY |
protected static java.lang.String |
JOBNODE_ID |
protected static java.lang.String |
JOBNODE_LINKTYPE |
protected static java.lang.String |
JOBNODE_MAXRECRAWLINTERVAL |
protected static java.lang.String |
JOBNODE_MINUTESOFHOUR |
protected static java.lang.String |
JOBNODE_MONTHOFYEAR |
protected static java.lang.String |
JOBNODE_NOTIFICATIONSTAGE |
protected static java.lang.String |
JOBNODE_PARAMNAME |
protected static java.lang.String |
JOBNODE_PARAMVALUE |
protected static java.lang.String |
JOBNODE_PIPELINESTAGE |
protected static java.lang.String |
JOBNODE_PRIORITY |
protected static java.lang.String |
JOBNODE_RECRAWLINTERVAL |
protected static java.lang.String |
JOBNODE_REQUESTMINIMUM |
protected static java.lang.String |
JOBNODE_RESEEDINTERVAL |
protected static java.lang.String |
JOBNODE_RUNMODE |
protected static java.lang.String |
JOBNODE_SCHEDULE |
protected static java.lang.String |
JOBNODE_STAGECONNECTIONNAME |
protected static java.lang.String |
JOBNODE_STAGEDESCRIPTION |
protected static java.lang.String |
JOBNODE_STAGEID |
protected static java.lang.String |
JOBNODE_STAGEISOUTPUT |
protected static java.lang.String |
JOBNODE_STAGEPREREQUISITE |
protected static java.lang.String |
JOBNODE_STAGESPECIFICATION |
protected static java.lang.String |
JOBNODE_STARTMODE |
protected static java.lang.String |
JOBNODE_TIMEZONE |
protected static java.lang.String |
JOBNODE_YEAR |
protected static java.lang.String |
JOBSTATUSNODE_DOCUMENTSINQUEUE |
protected static java.lang.String |
JOBSTATUSNODE_DOCUMENTSOUTSTANDING |
protected static java.lang.String |
JOBSTATUSNODE_DOCUMENTSPROCESSED |
protected static java.lang.String |
JOBSTATUSNODE_ENDTIME |
protected static java.lang.String |
JOBSTATUSNODE_ERRORTEXT |
protected static java.lang.String |
JOBSTATUSNODE_JOBID |
protected static java.lang.String |
JOBSTATUSNODE_OUTSTANDINGEXACT |
protected static java.lang.String |
JOBSTATUSNODE_PROCESSEDEXACT |
protected static java.lang.String |
JOBSTATUSNODE_QUEUEEXACT |
protected static java.lang.String |
JOBSTATUSNODE_STARTTIME |
protected static java.lang.String |
JOBSTATUSNODE_STATUS |
protected static java.lang.String |
lowWaterFactorProperty |
protected static java.lang.String |
NODE_AUTHORITYCONNECTOR |
protected static java.lang.String |
NODE_AUTHORIZATIONDOMAIN |
protected static java.lang.String |
NODE_MAPPINGCONNECTOR |
protected static java.lang.String |
NODE_NOTIFICATIONCONNECTOR |
protected static java.lang.String |
NODE_OUTPUTCONNECTOR |
protected static java.lang.String |
NODE_REPOSITORYCONNECTOR |
protected static java.lang.String |
NODE_TRANSFORMATIONCONNECTOR |
static int |
POSTRESULT_CREATED |
static int |
POSTRESULT_FOUND |
static int |
POSTRESULT_NOTALLOWED |
static int |
POSTRESULT_NOTFOUND |
static int |
READRESULT_FOUND |
static int |
READRESULT_NOTALLOWED |
static int |
READRESULT_NOTFOUND |
protected static java.lang.String |
stuffAmtFactorProperty |
protected static java.lang.String |
workerThreadCountProperty |
static int |
WRITERESULT_CREATED |
static int |
WRITERESULT_FOUND |
static int |
WRITERESULT_NOTALLOWED |
static int |
WRITERESULT_NOTFOUND |
agentShutdownSignal, agentsInitialized, API_ERRORNODE, API_SERVICEINTERRUPTIONNODE
alreadyClosed, alreadyShutdown, applicationName, ATTRIBUTE_PATH, authImplementation, cleanupHooks, configSignalCommandProperty, databaseConnectionTrackingProperty, databaseHandleMaxcountProperty, databaseHandleTimeoutProperty, databaseImplementation, databaseQueryMaxTimeProperty, dbShutdown, fileResourcesProperty, initializeFlagLock, initializeLevel, IV_LENGTH, lcfConfigFileProperty, localConfiguration, lockManagerImplementation, logConfigFileProperty, maintenanceFileSignalProperty, masterDatabaseName, masterDatabaseNameProperty, masterDatabasePassword, masterDatabasePasswordProperty, masterDatabaseUsername, masterDatabaseUsernameProperty, mcfVersion, NODE_LIBDIR, pollingHooks, processID, processIDProperty, propertyFilelastMod, propertyFilePath, resourceLoader, saltProperty, shutdownThread, tracker, versionProperty, workingDirectory
Constructor and Description |
---|
ManifoldCF() |
Modifier and Type | Method and Description |
---|---|
protected static void |
addStage(java.lang.String stageName,
java.util.List<java.lang.String> orderedStageNames,
java.util.Set<java.lang.String> keysSeen,
java.util.Map<java.lang.String,ManifoldCF.PipelineStage> pipelineStages) |
protected static int |
apiDeleteAuthorityConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Delete authority connection.
|
protected static int |
apiDeleteAuthorityGroup(IThreadContext tc,
Configuration output,
java.lang.String groupName,
IAuthorizer authorizer)
Delete authority group.
|
protected static int |
apiDeleteJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Delete a job.
|
protected static int |
apiDeleteMappingConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Delete mapping connection.
|
protected static int |
apiDeleteNotificationConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Delete notification connection.
|
protected static int |
apiDeleteOutputConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Delete output connection.
|
protected static int |
apiDeleteRepositoryConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Delete repository connection.
|
protected static int |
apiDeleteTransformationConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Delete transformation connection.
|
protected static int |
apiPostJob(IThreadContext tc,
Configuration output,
Configuration input,
IAuthorizer authorizer)
Post job.
|
protected static int |
apiReadAuthorityConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read authority connection
|
protected static int |
apiReadAuthorityConnections(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get authority connections
|
protected static int |
apiReadAuthorityConnectionStatus(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read an authority connection status
|
protected static int |
apiReadAuthorityConnectors(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List authority connectors
|
protected static int |
apiReadAuthorityGroup(IThreadContext tc,
Configuration output,
java.lang.String groupName,
IAuthorizer authorizer)
Read authority group
|
protected static int |
apiReadAuthorityGroups(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get authority groups
|
protected static int |
apiReadAuthorizationDomains(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List authorization domains
|
protected static int |
apiReadJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Read a job
|
protected static int |
apiReadJobs(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Read jobs
|
protected static int |
apiReadJobStatus(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
IAuthorizer authorizer)
Get api job status
|
protected static int |
apiReadJobStatuses(IThreadContext tc,
Configuration output,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
IAuthorizer authorizer)
Get api job statuses
|
protected static int |
apiReadJobStatusesNoCounts(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get api job statuses
|
protected static int |
apiReadJobStatusNoCounts(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Get api job status with no counts
|
protected static int |
apiReadMappingConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read mapping connection
|
protected static int |
apiReadMappingConnections(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get mapping connections
|
protected static int |
apiReadMappingConnectionStatus(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read a mapping connection status
|
protected static int |
apiReadMappingConnectors(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List mapping connectors
|
protected static int |
apiReadNotificationConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read notification connection
|
protected static int |
apiReadNotificationConnectionInfo(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
java.lang.String command,
IAuthorizer authorizer)
Read a notification connection's info
|
protected static int |
apiReadNotificationConnections(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get notification connections
|
protected static int |
apiReadNotificationConnectionStatus(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read a notification connection status
|
protected static int |
apiReadNotificationConnectors(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List notification connectors
|
protected static int |
apiReadOutputConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read output connection
|
protected static int |
apiReadOutputConnectionInfo(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
java.lang.String command,
IAuthorizer authorizer)
Read an output connection's info
|
protected static int |
apiReadOutputConnections(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get output connections
|
protected static int |
apiReadOutputConnectionStatus(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read an output connection status
|
protected static int |
apiReadOutputConnectors(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List output connectors
|
protected static int |
apiReadRepositoryConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read repository connection
|
protected static int |
apiReadRepositoryConnectionActivities(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read the activity list for a given connection name.
|
protected static int |
apiReadRepositoryConnectionHistory(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
IAuthorizer authorizer)
History reports
|
protected static int |
apiReadRepositoryConnectionInfo(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
java.lang.String command,
IAuthorizer authorizer)
Read a repository connection's info
|
protected static int |
apiReadRepositoryConnectionJobs(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Get jobs for connection
|
protected static int |
apiReadRepositoryConnectionQueue(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
IAuthorizer authorizer)
Queue reports
|
protected static int |
apiReadRepositoryConnections(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get repository connections
|
protected static int |
apiReadRepositoryConnectionStatus(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read a repository connection status
|
protected static int |
apiReadRepositoryConnectors(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List repository connectors
|
protected static int |
apiReadTransformationConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read transformation connection
|
protected static int |
apiReadTransformationConnectionInfo(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
java.lang.String command,
IAuthorizer authorizer)
Read a transformation connection's info
|
protected static int |
apiReadTransformationConnections(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
Get transformation connections
|
protected static int |
apiReadTransformationConnectionStatus(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Read a transformation connection status
|
protected static int |
apiReadTransformationConnectors(IThreadContext tc,
Configuration output,
IAuthorizer authorizer)
List transformation connectors
|
protected static int |
apiWriteAbortJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Abort a job.
|
protected static int |
apiWriteAuthorityConnection(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String connectionName,
IAuthorizer authorizer)
Write authority connection.
|
protected static int |
apiWriteAuthorityGroup(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String groupName,
IAuthorizer authorizer)
Write authority group.
|
protected static int |
apiWriteClearHistoryRepositoryConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Clear repository connection history.
|
protected static int |
apiWriteClearOutputConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Clear output connection (remove all recorded documents).
|
protected static int |
apiWriteClearVersionsOutputConnection(IThreadContext tc,
Configuration output,
java.lang.String connectionName,
IAuthorizer authorizer)
Reset output connection (reset version of all recorded documents).
|
protected static int |
apiWriteJob(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.Long jobID,
IAuthorizer authorizer)
Write job.
|
protected static int |
apiWriteMappingConnection(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String connectionName,
IAuthorizer authorizer)
Write mapping connection.
|
protected static int |
apiWriteNotificationConnection(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String connectionName,
IAuthorizer authorizer)
Write notification connection.
|
protected static int |
apiWriteOutputConnection(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String connectionName,
IAuthorizer authorizer)
Write output connection.
|
protected static int |
apiWritePauseJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Pause a job.
|
protected static int |
apiWriteRepositoryConnection(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String connectionName,
IAuthorizer authorizer)
Write repository connection.
|
protected static int |
apiWriteReseedJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Reset incremental seeding for a job.
|
protected static int |
apiWriteRestartJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
boolean requestMinimum,
IAuthorizer authorizer)
Restart a job.
|
protected static int |
apiWriteResumeJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
IAuthorizer authorizer)
Resume a job.
|
protected static int |
apiWriteStartJob(IThreadContext tc,
Configuration output,
java.lang.Long jobID,
boolean requestMinimum,
IAuthorizer authorizer)
Start a job.
|
protected static int |
apiWriteTransformationConnection(IThreadContext tc,
Configuration output,
Configuration input,
java.lang.String connectionName,
IAuthorizer authorizer)
Write transformation connection.
|
static java.lang.String[] |
calculateBins(IRepositoryConnector connector,
java.lang.String documentIdentifier)
Given a connector object and a document identifier, calculate its bins.
|
static void |
cleanUpEnvironment(IThreadContext tc) |
static java.lang.String |
colonStuff(java.lang.String input)
Stuff colons so we can't have conflicts.
|
static java.lang.String |
createConnectionSpecificString(java.lang.String connectionName,
java.lang.String simpleString)
Create a connection-specific string
|
static java.lang.String |
createGlobalString(java.lang.String simpleString)
Create a global string
|
static java.lang.String |
createJobSpecificString(java.lang.Long jobID,
java.lang.String simpleString)
Create a job-specific string
|
protected static void |
createResultsetNode(Configuration output,
IResultSet result,
java.lang.String[] resultColumns)
Add a resultset node to the output.
|
static void |
createSystemDatabase(IThreadContext threadContext)
Create system database using superuser properties from properties.xml.
|
static java.lang.String |
decodeAPIPathElement(java.lang.String startingPathElement)
Decode path element.
|
static void |
deinstallSystemTables(IThreadContext threadcontext)
Uninstall all the crawler system tables.
|
static int |
executeDeleteCommand(IThreadContext tc,
Configuration output,
java.lang.String path,
IAuthorizer authorizer)
Execute specified delete command.
|
static int |
executePostCommand(IThreadContext tc,
Configuration output,
java.lang.String path,
Configuration input,
IAuthorizer authorizer)
Execute specified post command.
|
static int |
executeReadCommand(IThreadContext tc,
Configuration output,
java.lang.String path,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters,
IAuthorizer authorizer)
Execute specified read command.
|
static int |
executeWriteCommand(IThreadContext tc,
Configuration output,
java.lang.String path,
Configuration input,
IAuthorizer authorizer)
Execute specified write command.
|
static void |
exportConfiguration(IThreadContext threadContext,
java.lang.String exportFilename,
java.lang.String passCode)
Atomically export the crawler configuration
|
protected static void |
formatAuthorityConnection(ConfigurationNode connectionNode,
IAuthorityConnection connection)
Format an authority connection.
|
protected static void |
formatAuthorityGroup(ConfigurationNode groupNode,
IAuthorityGroup group)
Format an authority group.
|
protected static void |
formatEnumeratedValues(ConfigurationNode recordNode,
java.lang.String childType,
EnumeratedValues value) |
protected static void |
formatJobDescription(ConfigurationNode jobNode,
IJobDescription job)
Convert a job description into a ConfigurationNode.
|
protected static void |
formatJobStatus(ConfigurationNode jobStatusNode,
JobStatus jobStatus)
Format a job status.
|
protected static void |
formatMappingConnection(ConfigurationNode connectionNode,
IMappingConnection connection)
Format a mapping connection.
|
protected static void |
formatNotificationConnection(ConfigurationNode connectionNode,
INotificationConnection connection)
Format a notification connection.
|
protected static void |
formatOutputConnection(ConfigurationNode connectionNode,
IOutputConnection connection)
Format an output connection.
|
protected static void |
formatRepositoryConnection(ConfigurationNode connectionNode,
IRepositoryConnection connection)
Format a repository connection.
|
protected static void |
formatTransformationConnection(ConfigurationNode connectionNode,
ITransformationConnection connection)
Format a transformation connection.
|
static java.lang.String[] |
getActivitiesList(IThreadContext threadContext,
java.lang.String connectionName)
Get the activities list for a given repository connection.
|
static int |
getMaxCleanupThreads(IThreadContext threadContext)
Get the maximum number of cleanup threads.
|
static int |
getMaxDeleteThreads(IThreadContext threadContext)
Get the maximum number of delete threads.
|
static int |
getMaxExpireThreads(IThreadContext threadContext)
Get the maximum number of expire threads.
|
static int |
getMaxWorkerThreads(IThreadContext threadContext)
Get the maximum number of worker threads.
|
protected static java.lang.String |
hopcountModeMap(int mode) |
static void |
importConfiguration(IThreadContext threadContext,
java.lang.String importFilename,
java.lang.String passCode)
Atomically import a crawler configuration
|
static void |
initializeEnvironment(IThreadContext tc)
Initialize environment.
|
static void |
installSystemTables(IThreadContext threadcontext)
Install all the crawler system tables.
|
protected static java.lang.Long |
interpretInterval(java.lang.String interval) |
static void |
localCleanup(IThreadContext tc) |
static void |
localInitialize(IThreadContext tc) |
protected static int |
mapToHopcountMode(java.lang.String mode) |
protected static int |
mapToRunMode(java.lang.String mode) |
protected static int |
mapToStartMode(java.lang.String startMethod) |
protected static java.lang.String |
presentInterval(java.lang.Long interval) |
protected static void |
processAuthorityConnection(AuthorityConnection connection,
ConfigurationNode connectionNode)
Convert input hierarchy into an AuthorityConnection object.
|
protected static void |
processAuthorityGroup(AuthorityGroup group,
ConfigurationNode groupNode)
Convert input hierarchy into an AuthorityGroup object.
|
protected static EnumeratedValues |
processEnumeratedValues(ConfigurationNode fieldNode) |
protected static void |
processJobDescription(JobDescription jobDescription,
ConfigurationNode jobNode)
Convert a node into a job description.
|
protected static void |
processMappingConnection(MappingConnection connection,
ConfigurationNode connectionNode)
Convert input hierarchy into an MappingConnection object.
|
protected static void |
processNotificationConnection(NotificationConnection connection,
ConfigurationNode connectionNode)
Convert input hierarchy into a NotificationConnection object.
|
protected static void |
processOutputConnection(OutputConnection connection,
ConfigurationNode connectionNode)
Convert input hierarchy into an OutputConnection object.
|
protected static void |
processRepositoryConnection(RepositoryConnection connection,
ConfigurationNode connectionNode)
Convert input hierarchy into a RepositoryConnection object.
|
protected static void |
processTransformationConnection(TransformationConnection connection,
ConfigurationNode connectionNode)
Convert input hierarchy into a TransformationConnection object.
|
static Connectors |
readConnectorDeclarations(java.io.File connectorConfigFile)
Read connectors configuration file.
|
static void |
registerConnectors(IThreadContext tc,
Connectors c)
Register all connectors as specified by a Connectors structure, usually read from the connectors.xml file.
|
static void |
registerThisAgent(IThreadContext tc)
Register this agent
|
static void |
requeueDocumentsDueToCarrydown(IJobManager jobManager,
DocumentDescription[] requeueCandidates,
IRepositoryConnector connector,
IRepositoryConnection connection,
IReprioritizationTracker rt,
long currentTime)
Requeue documents due to carrydown.
|
static void |
reregisterAllConnectors(IThreadContext tc)
Register or re-register all connectors, based on a connectors.xml file.
|
static void |
resetAllDocumentPriorities(IThreadContext threadContext,
java.lang.String processID)
Reset all (active) document priorities.
|
protected static java.lang.String |
runModeMap(int type) |
protected static java.lang.String |
startModeMap(int startMethod) |
protected static java.lang.String |
statusMap(int status) |
static void |
unregisterAllConnectors(IThreadContext tc)
Unregister all connectors.
|
static void |
unregisterAllConnectors(IThreadContext tc,
Connectors c)
Unregister all connectors which don't match a specified connector list.
|
static void |
writeDocumentPriorities(IThreadContext threadContext,
DocumentDescription[] descs,
java.util.Map<java.lang.String,IRepositoryConnection> connectionMap,
java.util.Map<java.lang.Long,IJobDescription> jobDescriptionMap)
Write a set of document priorities, based on the current queue tracker.
|
createErrorNode, createErrorNode, createServiceInterruptionNode, deinstallTables, findConfigurationNode, getRootArgument, installTables, qualifyOutputActivityName, qualifyTransformationActivityName, resetEnvironment, signalOutputConnectionRedo, signalOutputConnectionRemoved
addFile, addPollingHook, addShutdownHook, addToHash, checkMaintenanceUnderway, checkProperties, cleanUpEnvironment, createResourceLoader, createSystemDatabase, createTempDir, decrypt, deleteFile, deleteFolder, deobfuscate, dropSystemDatabase, encrypt, ensureFolder, findClass, getBooleanProperty, getChildDatabaseName, getCipher, getCipher, getConfiguration, getDoubleProperty, getFileProperty, getHashValue, getIntProperty, getLongProperty, getMasterDatabaseName, getMasterDatabasePassword, getMasterDatabaseUsername, getMcfVersion, getProcessID, getProperty, getSaltValue, getSecureRandom, getStringProperty, hash, initializeEnvironment, isFolder, noteConfigurationChange, obfuscate, pollAll, readByte, readByteArray, readBytes, readDword, readfloat, readLong, readNibble, readSdword, readString, readWord, recursiveDelete, registerConnectorServices, resetEnvironment, resolvePath, safeFileName, sleep, startHash, systemExit, writeByte, writeByteArray, writeBytes, writeDword, writefloat, writeLong, writeNibble, writeSdword, writeString, writeWord
public static final java.lang.String _rcsid
protected static boolean crawlerInitialized
protected static final java.lang.String workerThreadCountProperty
protected static final java.lang.String deleteThreadCountProperty
protected static final java.lang.String cleanupThreadCountProperty
protected static final java.lang.String expireThreadCountProperty
protected static final java.lang.String lowWaterFactorProperty
protected static final java.lang.String stuffAmtFactorProperty
protected static final java.lang.String connectorsConfigurationFileProperty
protected static final java.lang.String databaseSuperuserNameProperty
protected static final java.lang.String databaseSuperuserPasswordProperty
protected static final java.lang.String NODE_AUTHORIZATIONDOMAIN
protected static final java.lang.String NODE_OUTPUTCONNECTOR
protected static final java.lang.String NODE_TRANSFORMATIONCONNECTOR
protected static final java.lang.String NODE_MAPPINGCONNECTOR
protected static final java.lang.String NODE_AUTHORITYCONNECTOR
protected static final java.lang.String NODE_NOTIFICATIONCONNECTOR
protected static final java.lang.String NODE_REPOSITORYCONNECTOR
protected static final java.lang.String ATTRIBUTE_NAME
protected static final java.lang.String ATTRIBUTE_CLASS
protected static final java.lang.String ATTRIBUTE_DOMAIN
protected static final java.lang.String API_JOBNODE
protected static final java.lang.String API_JOBSTATUSNODE
protected static final java.lang.String API_AUTHORIZATIONDOMAINNODE
protected static final java.lang.String API_AUTHORITYGROUPNODE
protected static final java.lang.String API_REPOSITORYCONNECTORNODE
protected static final java.lang.String API_NOTIFICATIONCONNECTORNODE
protected static final java.lang.String API_OUTPUTCONNECTORNODE
protected static final java.lang.String API_TRANSFORMATIONCONNECTORNODE
protected static final java.lang.String API_AUTHORITYCONNECTORNODE
protected static final java.lang.String API_MAPPINGCONNECTORNODE
protected static final java.lang.String API_REPOSITORYCONNECTIONNODE
protected static final java.lang.String API_NOTIFICATIONCONNECTIONNODE
protected static final java.lang.String API_OUTPUTCONNECTIONNODE
protected static final java.lang.String API_TRANSFORMATIONCONNECTIONNODE
protected static final java.lang.String API_AUTHORITYCONNECTIONNODE
protected static final java.lang.String API_MAPPINGCONNECTIONNODE
protected static final java.lang.String API_CHECKRESULTNODE
protected static final java.lang.String API_JOBIDNODE
protected static final java.lang.String API_CONNECTIONNAMENODE
protected static final java.lang.String API_ROWNODE
protected static final java.lang.String API_COLUMNNODE
protected static final java.lang.String API_NAMENODE
protected static final java.lang.String API_VALUENODE
protected static final java.lang.String API_ACTIVITYNODE
protected static final java.lang.String CONNECTORNODE_DESCRIPTION
protected static final java.lang.String CONNECTORNODE_CLASSNAME
protected static final java.lang.String AUTHORIZATIONDOMAINNODE_DESCRIPTION
protected static final java.lang.String AUTHORIZATIONDOMAINNODE_DOMAINNAME
public static final int READRESULT_NOTFOUND
public static final int READRESULT_FOUND
public static final int READRESULT_NOTALLOWED
protected static final java.util.Map<java.lang.String,java.lang.Integer> docState
protected static final java.util.Map<java.lang.String,java.lang.Integer> docStatus
public static final int POSTRESULT_NOTFOUND
public static final int POSTRESULT_FOUND
public static final int POSTRESULT_CREATED
public static final int POSTRESULT_NOTALLOWED
public static final int WRITERESULT_NOTFOUND
public static final int WRITERESULT_FOUND
public static final int WRITERESULT_CREATED
public static final int WRITERESULT_NOTALLOWED
public static final int DELETERESULT_NOTFOUND
public static final int DELETERESULT_FOUND
public static final int DELETERESULT_NOTALLOWED
protected static final java.lang.String JOBNODE_ID
protected static final java.lang.String JOBNODE_DESCRIPTION
protected static final java.lang.String JOBNODE_CONNECTIONNAME
protected static final java.lang.String JOBNODE_DOCUMENTSPECIFICATION
protected static final java.lang.String JOBNODE_STARTMODE
protected static final java.lang.String JOBNODE_RUNMODE
protected static final java.lang.String JOBNODE_HOPCOUNTMODE
protected static final java.lang.String JOBNODE_PRIORITY
protected static final java.lang.String JOBNODE_RECRAWLINTERVAL
protected static final java.lang.String JOBNODE_MAXRECRAWLINTERVAL
protected static final java.lang.String JOBNODE_EXPIRATIONINTERVAL
protected static final java.lang.String JOBNODE_RESEEDINTERVAL
protected static final java.lang.String JOBNODE_HOPCOUNT
protected static final java.lang.String JOBNODE_SCHEDULE
protected static final java.lang.String JOBNODE_LINKTYPE
protected static final java.lang.String JOBNODE_COUNT
protected static final java.lang.String JOBNODE_REQUESTMINIMUM
protected static final java.lang.String JOBNODE_TIMEZONE
protected static final java.lang.String JOBNODE_DURATION
protected static final java.lang.String JOBNODE_DAYOFWEEK
protected static final java.lang.String JOBNODE_MONTHOFYEAR
protected static final java.lang.String JOBNODE_DAYOFMONTH
protected static final java.lang.String JOBNODE_YEAR
protected static final java.lang.String JOBNODE_HOUROFDAY
protected static final java.lang.String JOBNODE_MINUTESOFHOUR
protected static final java.lang.String JOBNODE_ENUMVALUE
protected static final java.lang.String JOBNODE_PARAMNAME
protected static final java.lang.String JOBNODE_PARAMVALUE
protected static final java.lang.String JOBNODE_PIPELINESTAGE
protected static final java.lang.String JOBNODE_STAGEID
protected static final java.lang.String JOBNODE_STAGEPREREQUISITE
protected static final java.lang.String JOBNODE_STAGEISOUTPUT
protected static final java.lang.String JOBNODE_STAGECONNECTIONNAME
protected static final java.lang.String JOBNODE_STAGEDESCRIPTION
protected static final java.lang.String JOBNODE_STAGESPECIFICATION
protected static final java.lang.String JOBNODE_NOTIFICATIONSTAGE
protected static final java.lang.String JOBSTATUSNODE_JOBID
protected static final java.lang.String JOBSTATUSNODE_STATUS
protected static final java.lang.String JOBSTATUSNODE_ERRORTEXT
protected static final java.lang.String JOBSTATUSNODE_STARTTIME
protected static final java.lang.String JOBSTATUSNODE_ENDTIME
protected static final java.lang.String JOBSTATUSNODE_DOCUMENTSINQUEUE
protected static final java.lang.String JOBSTATUSNODE_DOCUMENTSOUTSTANDING
protected static final java.lang.String JOBSTATUSNODE_DOCUMENTSPROCESSED
protected static final java.lang.String JOBSTATUSNODE_QUEUEEXACT
protected static final java.lang.String JOBSTATUSNODE_OUTSTANDINGEXACT
protected static final java.lang.String JOBSTATUSNODE_PROCESSEDEXACT
protected static final java.lang.String AUTHGROUPNODE_ISNEW
protected static final java.lang.String AUTHGROUPNODE_NAME
protected static final java.lang.String AUTHGROUPNODE_DESCRIPTION
protected static final java.lang.String CONNECTIONNODE_ISNEW
protected static final java.lang.String CONNECTIONNODE_NAME
protected static final java.lang.String CONNECTIONNODE_CLASSNAME
protected static final java.lang.String CONNECTIONNODE_MAXCONNECTIONS
protected static final java.lang.String CONNECTIONNODE_DESCRIPTION
protected static final java.lang.String CONNECTIONNODE_PREREQUISITE
protected static final java.lang.String CONNECTIONNODE_CONFIGURATION
protected static final java.lang.String CONNECTIONNODE_ACLAUTHORITY
protected static final java.lang.String CONNECTIONNODE_THROTTLE
protected static final java.lang.String CONNECTIONNODE_MATCH
protected static final java.lang.String CONNECTIONNODE_MATCHDESCRIPTION
protected static final java.lang.String CONNECTIONNODE_RATE
protected static final java.lang.String CONNECTIONNODE_AUTHDOMAIN
protected static final java.lang.String CONNECTIONNODE_AUTHGROUP
public static void initializeEnvironment(IThreadContext tc) throws ManifoldCFException
ManifoldCFException
public static void cleanUpEnvironment(IThreadContext tc)
public static void localInitialize(IThreadContext tc) throws ManifoldCFException
ManifoldCFException
public static void localCleanup(IThreadContext tc)
public static void createSystemDatabase(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static void registerThisAgent(IThreadContext tc) throws ManifoldCFException
ManifoldCFException
public static void reregisterAllConnectors(IThreadContext tc) throws ManifoldCFException
ManifoldCFException
public static Connectors readConnectorDeclarations(java.io.File connectorConfigFile) throws ManifoldCFException
ManifoldCFException
public static void unregisterAllConnectors(IThreadContext tc) throws ManifoldCFException
ManifoldCFException
public static void unregisterAllConnectors(IThreadContext tc, Connectors c) throws ManifoldCFException
ManifoldCFException
public static void registerConnectors(IThreadContext tc, Connectors c) throws ManifoldCFException
ManifoldCFException
public static void installSystemTables(IThreadContext threadcontext) throws ManifoldCFException
threadcontext
- is the thread context.ManifoldCFException
public static void deinstallSystemTables(IThreadContext threadcontext) throws ManifoldCFException
threadcontext
- is the thread context.ManifoldCFException
public static void exportConfiguration(IThreadContext threadContext, java.lang.String exportFilename, java.lang.String passCode) throws ManifoldCFException
ManifoldCFException
public static void importConfiguration(IThreadContext threadContext, java.lang.String importFilename, java.lang.String passCode) throws ManifoldCFException
ManifoldCFException
public static int getMaxWorkerThreads(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static int getMaxDeleteThreads(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static int getMaxExpireThreads(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static int getMaxCleanupThreads(IThreadContext threadContext) throws ManifoldCFException
ManifoldCFException
public static void requeueDocumentsDueToCarrydown(IJobManager jobManager, DocumentDescription[] requeueCandidates, IRepositoryConnector connector, IRepositoryConnection connection, IReprioritizationTracker rt, long currentTime) throws ManifoldCFException
ManifoldCFException
public static java.lang.String colonStuff(java.lang.String input)
public static java.lang.String createGlobalString(java.lang.String simpleString)
public static java.lang.String createConnectionSpecificString(java.lang.String connectionName, java.lang.String simpleString)
public static java.lang.String createJobSpecificString(java.lang.Long jobID, java.lang.String simpleString)
public static java.lang.String[] calculateBins(IRepositoryConnector connector, java.lang.String documentIdentifier)
public static void resetAllDocumentPriorities(IThreadContext threadContext, java.lang.String processID) throws ManifoldCFException
ManifoldCFException
public static void writeDocumentPriorities(IThreadContext threadContext, DocumentDescription[] descs, java.util.Map<java.lang.String,IRepositoryConnection> connectionMap, java.util.Map<java.lang.Long,IJobDescription> jobDescriptionMap) throws ManifoldCFException
ManifoldCFException
public static java.lang.String[] getActivitiesList(IThreadContext threadContext, java.lang.String connectionName) throws ManifoldCFException
ManifoldCFException
public static java.lang.String decodeAPIPathElement(java.lang.String startingPathElement) throws ManifoldCFException
ManifoldCFException
protected static int apiReadJobs(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadOutputConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadTransformationConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorityConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadMappingConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadNotificationConnectionStatus(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadOutputConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadTransformationConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadNotificationConnectionInfo(IThreadContext tc, Configuration output, java.lang.String connectionName, java.lang.String command, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadJobStatuses(IThreadContext tc, Configuration output, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadJobStatusesNoCounts(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadJobStatus(IThreadContext tc, Configuration output, java.lang.Long jobID, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadJobStatusNoCounts(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorityGroups(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorityGroup(IThreadContext tc, Configuration output, java.lang.String groupName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadOutputConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadTransformationConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadTransformationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorityConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadMappingConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorityConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadMappingConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadNotificationConnections(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadNotificationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadOutputConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadTransformationConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorityConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadMappingConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadAuthorizationDomains(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadNotificationConnectors(IThreadContext tc, Configuration output, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectionQueue(IThreadContext tc, Configuration output, java.lang.String connectionName, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectionJobs(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectionHistory(IThreadContext tc, Configuration output, java.lang.String connectionName, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static void createResultsetNode(Configuration output, IResultSet result, java.lang.String[] resultColumns) throws ManifoldCFException
ManifoldCFException
protected static int apiReadRepositoryConnectionActivities(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
public static int executeReadCommand(IThreadContext tc, Configuration output, java.lang.String path, java.util.Map<java.lang.String,java.util.List<java.lang.String>> queryParameters, IAuthorizer authorizer) throws ManifoldCFException
tc
- is the thread context.output
- is the output object, to be filled in.path
- is the object path.ManifoldCFException
protected static int apiPostJob(IThreadContext tc, Configuration output, Configuration input, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
public static int executePostCommand(IThreadContext tc, Configuration output, java.lang.String path, Configuration input, IAuthorizer authorizer) throws ManifoldCFException
tc
- is the thread context.output
- is the output object, to be filled in.path
- is the object path.input
- is the input object.ManifoldCFException
protected static int apiWriteStartJob(IThreadContext tc, Configuration output, java.lang.Long jobID, boolean requestMinimum, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteAbortJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteRestartJob(IThreadContext tc, Configuration output, java.lang.Long jobID, boolean requestMinimum, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWritePauseJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteResumeJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteReseedJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteJob(IThreadContext tc, Configuration output, Configuration input, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteAuthorityGroup(IThreadContext tc, Configuration output, Configuration input, java.lang.String groupName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteOutputConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteTransformationConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteAuthorityConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteMappingConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteRepositoryConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteClearHistoryRepositoryConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteNotificationConnection(IThreadContext tc, Configuration output, Configuration input, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteClearVersionsOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiWriteClearOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
public static int executeWriteCommand(IThreadContext tc, Configuration output, java.lang.String path, Configuration input, IAuthorizer authorizer) throws ManifoldCFException
tc
- is the thread context.output
- is the output object, to be filled in.path
- is the object path.input
- is the input object.ManifoldCFException
protected static int apiDeleteJob(IThreadContext tc, Configuration output, java.lang.Long jobID, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteAuthorityGroup(IThreadContext tc, Configuration output, java.lang.String groupName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteOutputConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteAuthorityConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteMappingConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteTransformationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteRepositoryConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
protected static int apiDeleteNotificationConnection(IThreadContext tc, Configuration output, java.lang.String connectionName, IAuthorizer authorizer) throws ManifoldCFException
ManifoldCFException
public static int executeDeleteCommand(IThreadContext tc, Configuration output, java.lang.String path, IAuthorizer authorizer) throws ManifoldCFException
tc
- is the thread context.output
- is the output object, to be filled in.path
- is the object path.ManifoldCFException
protected static void processJobDescription(JobDescription jobDescription, ConfigurationNode jobNode) throws ManifoldCFException
jobDescription
- is the job to be filled in.jobNode
- is the configuration node corresponding to the whole job itself.ManifoldCFException
protected static void addStage(java.lang.String stageName, java.util.List<java.lang.String> orderedStageNames, java.util.Set<java.lang.String> keysSeen, java.util.Map<java.lang.String,ManifoldCF.PipelineStage> pipelineStages) throws ManifoldCFException
ManifoldCFException
protected static void formatJobDescription(ConfigurationNode jobNode, IJobDescription job)
jobNode
- is the node to be filled in.job
- is the job description.protected static void formatEnumeratedValues(ConfigurationNode recordNode, java.lang.String childType, EnumeratedValues value)
protected static EnumeratedValues processEnumeratedValues(ConfigurationNode fieldNode) throws ManifoldCFException
ManifoldCFException
protected static java.lang.String presentInterval(java.lang.Long interval)
protected static java.lang.Long interpretInterval(java.lang.String interval) throws ManifoldCFException
ManifoldCFException
protected static java.lang.String startModeMap(int startMethod)
protected static int mapToStartMode(java.lang.String startMethod) throws ManifoldCFException
ManifoldCFException
protected static java.lang.String runModeMap(int type)
protected static int mapToRunMode(java.lang.String mode) throws ManifoldCFException
ManifoldCFException
protected static java.lang.String hopcountModeMap(int mode)
protected static int mapToHopcountMode(java.lang.String mode) throws ManifoldCFException
ManifoldCFException
protected static void formatJobStatus(ConfigurationNode jobStatusNode, JobStatus jobStatus)
protected static java.lang.String statusMap(int status)
protected static void processAuthorityGroup(AuthorityGroup group, ConfigurationNode groupNode) throws ManifoldCFException
ManifoldCFException
protected static void formatAuthorityGroup(ConfigurationNode groupNode, IAuthorityGroup group)
protected static void processOutputConnection(OutputConnection connection, ConfigurationNode connectionNode) throws ManifoldCFException
ManifoldCFException
protected static void formatOutputConnection(ConfigurationNode connectionNode, IOutputConnection connection)
protected static void processTransformationConnection(TransformationConnection connection, ConfigurationNode connectionNode) throws ManifoldCFException
ManifoldCFException
protected static void formatTransformationConnection(ConfigurationNode connectionNode, ITransformationConnection connection)
protected static void processAuthorityConnection(AuthorityConnection connection, ConfigurationNode connectionNode) throws ManifoldCFException
ManifoldCFException
protected static void formatAuthorityConnection(ConfigurationNode connectionNode, IAuthorityConnection connection)
protected static void processMappingConnection(MappingConnection connection, ConfigurationNode connectionNode) throws ManifoldCFException
ManifoldCFException
protected static void formatMappingConnection(ConfigurationNode connectionNode, IMappingConnection connection)
protected static void processRepositoryConnection(RepositoryConnection connection, ConfigurationNode connectionNode) throws ManifoldCFException
ManifoldCFException
protected static void formatRepositoryConnection(ConfigurationNode connectionNode, IRepositoryConnection connection)
protected static void processNotificationConnection(NotificationConnection connection, ConfigurationNode connectionNode) throws ManifoldCFException
ManifoldCFException
protected static void formatNotificationConnection(ConfigurationNode connectionNode, INotificationConnection connection)