Modifier and Type | Method and Description |
---|---|
void |
AgentRun.AgentRunShutdownRunner.doCleanup(IThreadContext tc) |
protected void |
AgentRun.doExecute(IThreadContext tc) |
protected void |
AgentStop.doExecute(IThreadContext tc) |
protected abstract void |
BaseAgentsInitializationCommand.doExecute(IThreadContext tc) |
protected void |
Install.doExecute(IThreadContext tc) |
protected void |
Register.doExecute(IThreadContext tc) |
protected void |
RegisterOutput.doExecute(IThreadContext tc) |
protected void |
RegisterTransformation.doExecute(IThreadContext tc) |
protected void |
SynchronizeAll.doExecute(IThreadContext tc) |
protected void |
SynchronizeOutputs.doExecute(IThreadContext tc) |
protected void |
SynchronizeTransformations.doExecute(IThreadContext tc) |
protected abstract void |
TransactionalAgentsInitializationCommand.doExecute(IThreadContext tc) |
protected void |
UnRegister.doExecute(IThreadContext tc) |
protected void |
UnRegisterAll.doExecute(IThreadContext tc) |
protected void |
UnRegisterAllOutputs.doExecute(IThreadContext tc) |
protected void |
UnRegisterAllTransformations.doExecute(IThreadContext tc) |
protected void |
UnRegisterOutput.doExecute(IThreadContext tc) |
protected void |
UnRegisterTransformation.doExecute(IThreadContext tc) |
protected void |
Uninstall.doExecute(IThreadContext tc) |
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
AgentManager.threadContext |
Constructor and Description |
---|
AgentManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
IncrementalIngester.threadContext |
Constructor and Description |
---|
IncrementalIngester(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
IAgent.cleanUp(IThreadContext threadContext)
Tear down agent environment.
|
void |
IAgent.cleanUpAgentData(IThreadContext threadContext,
String currentProcessID,
String cleanupProcessID)
Cleanup after agents process.
|
void |
IAgent.cleanUpAllAgentData(IThreadContext threadContext,
String currentProcessID)
Cleanup after ALL agents processes.
|
void |
IAgent.clusterInit(IThreadContext threadContext)
Called ONLY when no other active services of this kind are running.
|
void |
IAgent.deinstall(IThreadContext threadContext)
Uninstall agent.
|
static void |
OutputConnectorFactory.deinstall(IThreadContext threadContext,
String className)
Uninstall connector.
|
static void |
TransformationConnectorFactory.deinstall(IThreadContext threadContext,
String className)
Uninstall connector.
|
static String[] |
OutputConnectorFactory.getActivitiesList(IThreadContext threadContext,
String className)
Get the activities supported by this connector.
|
static String[] |
TransformationConnectorFactory.getActivitiesList(IThreadContext threadContext,
String className)
Get the activities supported by this connector.
|
static String[] |
OutputConnectionManagerFactory.getAllOutputActivities(IThreadContext tc)
Compile a list of all pertinent activities, across all existing output connections.
|
static String[] |
TransformationConnectionManagerFactory.getAllTransformationActivities(IThreadContext tc)
Compile a list of all pertinent activities, across all existing transformation connections.
|
String[] |
OutputConnectorFactory.getThisActivitiesList(IThreadContext threadContext,
String className)
Get the activities supported by this connector.
|
String[] |
TransformationConnectorFactory.getThisActivitiesList(IThreadContext threadContext,
String className)
Get the activities supported by this connector.
|
void |
IAgent.initialize(IThreadContext threadContext)
Initialize agent environment.
|
void |
IAgent.install(IThreadContext threadContext)
Install agent.
|
static void |
OutputConnectorFactory.install(IThreadContext threadContext,
String className)
Install connector.
|
static void |
TransformationConnectorFactory.install(IThreadContext threadContext,
String className)
Install connector.
|
static IAgent[] |
AgentManagerFactory.instantiateAllAgents(IThreadContext threadContext)
Instantiate the complete set of IAgent objects.
|
protected boolean |
OutputConnectorFactory.isInstalled(IThreadContext tc,
String className) |
protected boolean |
TransformationConnectorFactory.isInstalled(IThreadContext tc,
String className) |
static boolean |
AgentManagerFactory.isOutputConnectionInUse(IThreadContext threadContext,
String connName)
Request permission from all registered agents to delete an output connection.
|
boolean |
IAgent.isOutputConnectionInUse(IThreadContext threadContext,
String connName)
Request permission from agent to delete an output connection.
|
static boolean |
AgentManagerFactory.isTransformationConnectionInUse(IThreadContext threadContext,
String connName)
Request permission from all registered agents to delete a transformation connection.
|
boolean |
IAgent.isTransformationConnectionInUse(IThreadContext threadContext,
String connName)
Request permission from agent to delete a transformation connection.
|
static IAgentManager |
AgentManagerFactory.make(IThreadContext threadContext)
Make an agent manager instance.
|
static IIncrementalIngester |
IncrementalIngesterFactory.make(IThreadContext threadContext)
Get an appropriate incremental ingest manager handle.
|
static IOutputConnectionManager |
OutputConnectionManagerFactory.make(IThreadContext tc)
Make an output connection manager handle.
|
static IOutputConnectorManager |
OutputConnectorManagerFactory.make(IThreadContext tc)
Construct an output connector manager.
|
static IOutputConnectorPool |
OutputConnectorPoolFactory.make(IThreadContext tc)
Make an output connector pool handle.
|
static ITransformationConnectionManager |
TransformationConnectionManagerFactory.make(IThreadContext tc)
Make a transformation connection manager handle.
|
static ITransformationConnectorManager |
TransformationConnectorManagerFactory.make(IThreadContext tc)
Construct an output connector manager.
|
static ITransformationConnectorPool |
TransformationConnectorPoolFactory.make(IThreadContext tc)
Make a transformation connector pool handle.
|
static void |
AgentManagerFactory.noteOutputConnectionChange(IThreadContext threadContext,
String connectionName)
Note to all registered agents the change of configuration of an output connection.
|
void |
IAgent.noteOutputConnectionChange(IThreadContext threadContext,
String connectionName)
Note a change in configuration for an output connection.
|
static void |
AgentManagerFactory.noteOutputConnectorDeregistration(IThreadContext threadContext,
String[] connectionNames)
Note to all registered agents the deregistration of an output connector used by the specified connections.
|
void |
IAgent.noteOutputConnectorDeregistration(IThreadContext threadContext,
String[] connectionNames)
Note the deregistration of a set of output connections.
|
static void |
AgentManagerFactory.noteOutputConnectorRegistration(IThreadContext threadContext,
String[] connectionNames)
Note to all registered agents the registration of an output connector used by the specified connections.
|
void |
IAgent.noteOutputConnectorRegistration(IThreadContext threadContext,
String[] connectionNames)
Note the registration of a set of output connections.
|
static void |
AgentManagerFactory.noteTransformationConnectionChange(IThreadContext threadContext,
String connectionName)
Note to all registered agents the change of configuration of a transformation connection.
|
void |
IAgent.noteTransformationConnectionChange(IThreadContext threadContext,
String connectionName)
Note a change in configuration for a transformation connection.
|
static void |
AgentManagerFactory.noteTransformationConnectorDeregistration(IThreadContext threadContext,
String[] connectionNames)
Note to all registered agents the deregistration of a transformation connector used by the specified connections.
|
void |
IAgent.noteTransformationConnectorDeregistration(IThreadContext threadContext,
String[] connectionNames)
Note the deregistration of a set of transformation connections.
|
static void |
AgentManagerFactory.noteTransformationConnectorRegistration(IThreadContext threadContext,
String[] connectionNames)
Note to all registered agents the registration of a transformation connector used by the specified connections.
|
void |
IAgent.noteTransformationConnectorRegistration(IThreadContext threadContext,
String[] connectionNames)
Note the registration of a set of transformation connections.
|
static void |
OutputConnectorFactory.outputConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
static void |
TransformationConnectorFactory.outputConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
static void |
OutputConnectorFactory.outputConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
static void |
TransformationConnectorFactory.outputConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
static String |
OutputConnectorFactory.processConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
static String |
TransformationConnectorFactory.processConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
void |
IAgent.startAgent(IThreadContext threadContext,
String processID)
Start the agent.
|
void |
IAgent.stopAgent(IThreadContext threadContext)
Stop the agent.
|
static void |
OutputConnectorFactory.viewConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
static void |
TransformationConnectorFactory.viewConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
OutputConnectionManager.threadContext |
Constructor and Description |
---|
OutputConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
OutputConnectorPool.threadContext
Thread context
|
Modifier and Type | Method and Description |
---|---|
IOutputConnector[] |
OutputConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
protected boolean |
OutputConnectorPool.LocalPool.isConnectionNameValid(IThreadContext tc,
String connectionName) |
protected boolean |
OutputConnectorPool.LocalPool.isInstalled(IThreadContext tc,
String className) |
Constructor and Description |
---|
OutputConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
OutputConnectorManager.threadContext |
Constructor and Description |
---|
OutputConnectorManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
AgentsDaemon.CleanupAgent.threadContext |
Modifier and Type | Method and Description |
---|---|
static void |
AgentsDaemon.assertAgentsShutdownSignal(IThreadContext threadContext)
Assert shutdown signal for the current agents daemon.
|
protected void |
AgentsDaemon.checkAgents(IThreadContext threadContext)
Start all not-running agents.
|
static void |
ManifoldCF.cleanUpEnvironment(IThreadContext threadContext)
Clean up environment.
|
static void |
AgentsDaemon.clearAgentsShutdownSignal(IThreadContext threadContext)
Clear shutdown signal for the current agents daemon.
|
static void |
ManifoldCF.deinstallTables(IThreadContext threadcontext)
Uninstall all the crawler system tables.
|
void |
AgentsDaemon.AgentsShutdownHook.doCleanup(IThreadContext threadContext) |
static void |
ManifoldCF.initializeEnvironment(IThreadContext threadContext)
Initialize environment.
|
static void |
ManifoldCF.installTables(IThreadContext threadcontext)
Install the agent tables.
|
static void |
ManifoldCF.localCleanup(IThreadContext threadContext) |
static void |
ManifoldCF.localInitialize(IThreadContext threadContext) |
void |
AgentsDaemon.registerAgentsShutdownHook(IThreadContext threadContext)
Register agents shutdown hook.
|
static void |
ManifoldCF.resetEnvironment(IThreadContext threadContext)
Reset the environment.
|
void |
AgentsDaemon.runAgents(IThreadContext threadContext)
Run agents process.
|
static void |
ManifoldCF.signalOutputConnectionRedo(IThreadContext threadContext,
String connectionName)
Signal output connection needs redoing.
|
static void |
ManifoldCF.signalOutputConnectionRemoved(IThreadContext threadContext,
String connectionName)
Signal output connection has been deleted.
|
void |
AgentsDaemon.startAgents(IThreadContext threadContext)
Start agents thread for this agents daemon object.
|
void |
AgentsDaemon.stopAgents(IThreadContext threadContext)
Stop all started agents running under this agents daemon.
|
Constructor and Description |
---|
AgentsDaemon.CleanupAgent(IThreadContext threadContext,
IAgent agent,
String processID) |
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
TransformationConnectionManager.threadContext |
Constructor and Description |
---|
TransformationConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
TransformationConnectorPool.threadContext
Thread context
|
Modifier and Type | Method and Description |
---|---|
ITransformationConnector[] |
TransformationConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
protected boolean |
TransformationConnectorPool.LocalPool.isConnectionNameValid(IThreadContext tc,
String connectionName) |
protected boolean |
TransformationConnectorPool.LocalPool.isInstalled(IThreadContext tc,
String className) |
Constructor and Description |
---|
TransformationConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
TransformationConnectorManager.threadContext |
Constructor and Description |
---|
TransformationConnectorManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
AuthorityConnectorManager.threadContext |
Constructor and Description |
---|
AuthorityConnectorManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
AuthorizationDomainManager.threadContext |
Constructor and Description |
---|
AuthorizationDomainManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Constructor and Description |
---|
AuthorityGroupManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
AuthorityConnectionManager.threadContext |
Constructor and Description |
---|
AuthorityConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
AuthorityConnectorPool.threadContext
Thread context
|
Modifier and Type | Method and Description |
---|---|
IAuthorityConnector[] |
AuthorityConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
protected boolean |
AuthorityConnectorPool.LocalPool.isConnectionNameValid(IThreadContext tc,
String connectionName) |
protected boolean |
AuthorityConnectorPool.LocalPool.isInstalled(IThreadContext tc,
String className) |
Constructor and Description |
---|
AuthorityConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Method and Description |
---|---|
static void |
AuthorityConnectorFactory.deinstall(IThreadContext threadContext,
String className)
Uninstall connector.
|
static void |
MappingConnectorFactory.deinstall(IThreadContext threadContext,
String className)
Uninstall connector.
|
static AuthorizationResponse |
AuthorityConnectorFactory.getDefaultAuthorizationResponse(IThreadContext threadContext,
String className,
String userName)
Get the default response from a connector.
|
AuthorizationResponse |
AuthorityConnectorFactory.getThisDefaultAuthorizationResponse(IThreadContext threadContext,
String className,
String userName)
Get the default response from a connector.
|
static void |
AuthorityConnectorFactory.install(IThreadContext threadContext,
String className)
Install connector.
|
static void |
MappingConnectorFactory.install(IThreadContext threadContext,
String className)
Install connector.
|
protected boolean |
AuthorityConnectorFactory.isInstalled(IThreadContext tc,
String className) |
protected boolean |
MappingConnectorFactory.isInstalled(IThreadContext tc,
String className) |
static IAuthorityConnectionManager |
AuthorityConnectionManagerFactory.make(IThreadContext tc)
Make an authority connection manager handle.
|
static IAuthorityConnectorManager |
AuthorityConnectorManagerFactory.make(IThreadContext tc)
Construct a connector manager.
|
static IAuthorityConnectorPool |
AuthorityConnectorPoolFactory.make(IThreadContext tc)
Make an output connector pool handle.
|
static IAuthorityGroupManager |
AuthorityGroupManagerFactory.make(IThreadContext tc)
Make an authority connection manager handle.
|
static IAuthorizationDomainManager |
AuthorizationDomainManagerFactory.make(IThreadContext tc)
Construct a connector manager.
|
static IMappingConnectionManager |
MappingConnectionManagerFactory.make(IThreadContext tc)
Make an authority connection manager handle.
|
static IMappingConnectorManager |
MappingConnectorManagerFactory.make(IThreadContext tc)
Construct a connector manager.
|
static IMappingConnectorPool |
MappingConnectorPoolFactory.make(IThreadContext tc)
Make a mapping connector pool handle.
|
static void |
AuthorityConnectorFactory.outputConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
static void |
MappingConnectorFactory.outputConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
static void |
AuthorityConnectorFactory.outputConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
static void |
MappingConnectorFactory.outputConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
static String |
AuthorityConnectorFactory.processConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
static String |
MappingConnectorFactory.processConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
static void |
AuthorityConnectorFactory.viewConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
static void |
MappingConnectorFactory.viewConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
MappingConnectorManager.threadContext |
Constructor and Description |
---|
MappingConnectorManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
MappingConnectionManager.threadContext |
Constructor and Description |
---|
MappingConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
MappingConnectorPool.threadContext
Thread context
|
Modifier and Type | Method and Description |
---|---|
IMappingConnector[] |
MappingConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
protected boolean |
MappingConnectorPool.LocalPool.isConnectionNameValid(IThreadContext tc,
String connectionName) |
protected boolean |
MappingConnectorPool.LocalPool.isInstalled(IThreadContext tc,
String className) |
Constructor and Description |
---|
MappingConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Method and Description |
---|---|
static void |
ManifoldCF.cleanUpEnvironment(IThreadContext tc) |
static void |
ManifoldCF.deinstallSystemTables(IThreadContext threadcontext)
Uninstall all the authority manager system tables.
|
static void |
ManifoldCF.initializeEnvironment(IThreadContext tc)
Initialize environment.
|
static void |
ManifoldCF.installSystemTables(IThreadContext threadcontext)
Install all the authority manager system tables.
|
static void |
ManifoldCF.localCleanup(IThreadContext tc) |
static void |
ManifoldCF.localInitialize(IThreadContext tc) |
static void |
ManifoldCF.startSystem(IThreadContext threadContext)
Start the authority system.
|
static void |
ManifoldCF.stopSystem(IThreadContext threadContext)
Shut down the authority system.
|
Modifier and Type | Method and Description |
---|---|
void |
DBCreate.doExecute(IThreadContext tc) |
protected void |
DBDrop.doExecute(IThreadContext tc) |
protected abstract void |
DBInitializationCommand.doExecute(IThreadContext tc) |
Constructor and Description |
---|
CacheManager(IThreadContext context) |
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
BaseConnector.currentContext |
Modifier and Type | Method and Description |
---|---|
void |
BaseConnector.deinstall(IThreadContext threadContext)
Uninstall the connector.
|
void |
BaseConnector.install(IThreadContext threadContext)
Install the connector.
|
void |
BaseConnector.outputConfigurationBody(IThreadContext threadContext,
IHTTPOutput out,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
void |
BaseConnector.outputConfigurationBody(IThreadContext threadContext,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
void |
BaseConnector.outputConfigurationHeader(IThreadContext threadContext,
IHTTPOutput out,
ConfigParams parameters,
ArrayList<Object> tabsArray) |
void |
BaseConnector.outputConfigurationHeader(IThreadContext threadContext,
IHTTPOutput out,
ConfigParams parameters,
List<String> tabsArray)
Output the configuration header section.
|
void |
BaseConnector.outputConfigurationHeader(IThreadContext threadContext,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
List<String> tabsArray)
Output the configuration header section.
|
String |
BaseConnector.processConfigurationPost(IThreadContext threadContext,
IPostParameters variableContext,
ConfigParams parameters)
Process a configuration post.
|
String |
BaseConnector.processConfigurationPost(IThreadContext threadContext,
IPostParameters variableContext,
Locale locale,
ConfigParams parameters)
Process a configuration post.
|
void |
BaseConnector.setThreadContext(IThreadContext threadContext)
Attach to a new thread.
|
void |
BaseConnector.viewConfiguration(IThreadContext threadContext,
IHTTPOutput out,
ConfigParams parameters)
View configuration.
|
void |
BaseConnector.viewConfiguration(IThreadContext threadContext,
IHTTPOutput out,
Locale locale,
ConfigParams parameters)
View configuration.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectorPool.closeAllConnectors(IThreadContext threadContext)
Clean up all open output connector handles.
|
protected T |
ConnectorPool.createConnectorInstance(IThreadContext threadContext,
String className)
Get a connector instance.
|
void |
ConnectorPool.Pool.flushUnused(IThreadContext threadContext)
Flush unused connectors.
|
void |
ConnectorPool.flushUnusedConnectors(IThreadContext threadContext)
Flush only those connector handles that are currently unused.
|
T |
ConnectorPool.Pool.getConnector(IThreadContext threadContext,
String className,
ConfigParams configParams)
Grab a connector.
|
T |
ConnectorPool.grab(IThreadContext threadContext,
String connectionName,
String className,
ConfigParams configInfo,
int maxPoolSize)
Get a connector.
|
T[] |
ConnectorPool.grabMultiple(IThreadContext threadContext,
Class<T> clazz,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes)
Get multiple connectors, all at once.
|
protected abstract boolean |
ConnectorPool.isConnectionNameValid(IThreadContext tc,
String connectionName)
Override this method to check if a connection name is still valid.
|
protected abstract boolean |
ConnectorPool.isInstalled(IThreadContext tc,
String className)
Override this method to hook into a connector manager.
|
void |
ConnectorPool.Pool.pollAll(IThreadContext threadContext)
Notify all free connectors.
|
void |
ConnectorPool.pollAllConnectors(IThreadContext threadContext)
Idle notification for inactive output connector handles.
|
void |
ConnectorPool.release(IThreadContext threadContext,
String connectionName,
T connector)
Release an output connector.
|
void |
ConnectorPool.Pool.releaseAll(IThreadContext threadContext)
Release all free connectors.
|
void |
ConnectorPool.Pool.releaseConnector(IThreadContext threadContext,
T connector)
Release a connector to the pool.
|
void |
ConnectorPool.releaseMultiple(IThreadContext threadContext,
String[] connectionNames,
T[] connectors)
Release multiple output connectors.
|
void |
ConnectorPool.Pool.updateMaximumPoolSize(IThreadContext threadContext,
int maxPoolSize)
Update the maximum pool size.
|
Constructor and Description |
---|
ConnectorPool.Pool(IThreadContext threadContext,
int maxCount,
String connectionName)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
Database.context |
Modifier and Type | Method and Description |
---|---|
protected static String |
DBInterfaceHSQLDB.getDatabaseString(IThreadContext tc,
String databaseName) |
protected static String |
DBInterfaceHSQLDB.getJDBCString(IThreadContext tc,
String databaseName) |
Constructor and Description |
---|
Database(IThreadContext context,
String jdbcUrl,
String jdbcDriverClass,
String databaseName,
String userName,
String password) |
DBInterfaceDerby(IThreadContext tc,
String databaseName) |
DBInterfaceDerby(IThreadContext tc,
String databaseName,
String userName,
String password) |
DBInterfaceHSQLDB(IThreadContext tc,
String databaseName,
String userName,
String password) |
DBInterfaceMariaDB(IThreadContext tc,
String databaseName,
String userName,
String password) |
DBInterfaceMySQL(IThreadContext tc,
String databaseName,
String userName,
String password) |
DBInterfaceMySQL(IThreadContext tc,
String jdbcDriverClass,
String databaseName,
String userName,
String password) |
DBInterfacePostgreSQL(IThreadContext tc,
String databaseName,
String userName,
String password) |
TransactionHandle(IThreadContext tc,
TransactionHandle previousTransaction,
int transactionType) |
Modifier and Type | Method and Description |
---|---|
static IThreadContext |
ThreadContextFactory.make()
Make a thread context.
|
Modifier and Type | Method and Description |
---|---|
void |
IConnector.deinstall(IThreadContext threadContext)
Uninstall the connector.
|
protected void |
ConnectorFactory.deinstallThis(IThreadContext threadContext,
String className)
Uninstall connector.
|
void |
IShutdownHook.doCleanup(IThreadContext threadContext)
Do the requisite cleanup.
|
void |
IPollingHook.doPoll(IThreadContext threadContext)
Do the requisite cleanup.
|
static boolean |
LockManagerFactory.getBooleanProperty(IThreadContext tc,
String s,
boolean defaultValue) |
static double |
LockManagerFactory.getDoubleProperty(IThreadContext tc,
String s,
double defaultValue) |
static int |
LockManagerFactory.getIntProperty(IThreadContext tc,
String s,
int defaultValue) |
static long |
LockManagerFactory.getLongProperty(IThreadContext tc,
String s,
long defaultValue) |
static String |
LockManagerFactory.getPossiblyObfuscatedStringProperty(IThreadContext tc,
String s,
String defaultValue) |
static String |
LockManagerFactory.getProperty(IThreadContext tc,
String s) |
static String |
LockManagerFactory.getStringProperty(IThreadContext tc,
String s,
String defaultValue) |
protected T |
ConnectorFactory.getThisConnector(IThreadContext threadContext,
String className)
Get a connector instance.
|
void |
IConnector.install(IThreadContext threadContext)
Install the connector.
|
protected void |
ConnectorFactory.installThis(IThreadContext threadContext,
String className)
Install connector.
|
protected abstract boolean |
ConnectorFactory.isInstalled(IThreadContext tc,
String className)
Override this method to hook into a connector manager.
|
static ICacheManager |
CacheManagerFactory.make(IThreadContext context)
Return a cache manager instance that any client can use to obtain cache management services.
|
static String |
IDFactory.make(IThreadContext tc) |
static ILockManager |
LockManagerFactory.make(IThreadContext context)
Instantiate a lock manager.
|
static IThrottleGroups |
ThrottleGroupsFactory.make(IThreadContext tc)
Make a connection throttle handle.
|
static IDBInterface |
DBInterfaceFactory.make(IThreadContext context,
String databaseName,
String userName,
String password) |
void |
IConnector.outputConfigurationBody(IThreadContext threadContext,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
void |
IConnector.outputConfigurationHeader(IThreadContext threadContext,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
List<String> tabsArray)
Output the configuration header section.
|
protected void |
ConnectorFactory.outputThisConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
protected void |
ConnectorFactory.outputThisConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
String |
IConnector.processConfigurationPost(IThreadContext threadContext,
IPostParameters variableContext,
Locale locale,
ConfigParams parameters)
Process a configuration post.
|
protected String |
ConnectorFactory.processThisConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
void |
IConnector.setThreadContext(IThreadContext threadContext)
Attach to a new thread.
|
void |
IConnector.viewConfiguration(IThreadContext threadContext,
IHTTPOutput out,
Locale locale,
ConfigParams parameters)
View configuration.
|
protected void |
ConnectorFactory.viewThisConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperLockManager.ZooKeeperShutdown.doCleanup(IThreadContext threadContext)
Do the requisite cleanup.
|
Modifier and Type | Method and Description |
---|---|
static void |
ManifoldCF.cleanUpEnvironment(IThreadContext threadContext)
Perform system shutdown, using the registered shutdown hooks.
|
static void |
ManifoldCF.createSystemDatabase(IThreadContext threadcontext,
String masterUsername,
String masterPassword)
Install system database.
|
void |
ManifoldCF.FileTrack.doCleanup(IThreadContext threadContext)
Delete all remaining files
|
void |
ManifoldCF.ThrottlerShutdown.doCleanup(IThreadContext threadContext) |
void |
ManifoldCF.DatabaseShutdown.doCleanup(IThreadContext threadContext) |
void |
ManifoldCF.ThrottlerPoll.doPoll(IThreadContext threadContext) |
void |
ManifoldCF.CachePoll.doPoll(IThreadContext threadContext) |
static void |
ManifoldCF.dropSystemDatabase(IThreadContext threadcontext,
String masterUsername,
String masterPassword)
Drop system database.
|
static void |
ManifoldCF.initializeEnvironment(IThreadContext threadContext)
Initialize environment.
|
static void |
ManifoldCF.pollAll(IThreadContext threadContext)
Poll all the registered polling services.
|
static void |
ManifoldCF.resetEnvironment(IThreadContext threadContext)
Reset environment.
|
static void |
Logging.setLogLevels(IThreadContext threadContext)
Reset all loggers
|
static boolean |
ManifoldCF.verifyAPILogin(IThreadContext threadContext,
String userID,
String userPassword)
Verify API login.
|
static boolean |
ManifoldCF.verifyLogin(IThreadContext threadContext,
String userID,
String userPassword)
Verify login.
|
Modifier and Type | Class and Description |
---|---|
class |
ThreadContext
Thread context implementation
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
ThrottleGroups.threadContext
The thread context
|
Modifier and Type | Method and Description |
---|---|
void |
Throttler.ThrottlingGroups.createOrUpdateThrottleGroup(IThreadContext threadContext,
String throttleGroup,
IThrottleSpec throttleSpec)
Update throttle specification
|
void |
Throttler.createOrUpdateThrottleGroup(IThreadContext threadContext,
String throttleGroupType,
String throttleGroup,
IThrottleSpec throttleSpec)
Set or update throttle specification for a throttle group.
|
void |
Throttler.destroy(IThreadContext threadContext)
Shut down all throttlers and deregister them.
|
void |
Throttler.ThrottlingGroups.destroy(IThreadContext threadContext)
Destroy and shutdown all
|
void |
Throttler.ThrottlingGroup.destroy(IThreadContext threadContext)
Destroy this pool.
|
void |
Throttler.freeUnusedResources(IThreadContext threadContext)
Free unused resources.
|
void |
Throttler.ThrottlingGroups.freeUnusedResources(IThreadContext threadContext)
Free unused resources
|
void |
Throttler.ThrottlingGroup.freeUnusedResources(IThreadContext threadContext)
Free unused resources.
|
Set<String> |
Throttler.getThrottleGroups(IThreadContext threadContext,
String throttleGroupType)
Get all existing throttle groups for a throttle group type.
|
IConnectionThrottler |
Throttler.ThrottlingGroup.obtainConnectionThrottler(IThreadContext threadContext,
String[] binNames)
Create a bunch of bins, corresponding to the bin names specified.
|
IConnectionThrottler |
Throttler.ThrottlingGroups.obtainConnectionThrottler(IThreadContext threadContext,
String throttleGroup,
String[] binNames)
Obtain connection throttler.
|
IConnectionThrottler |
Throttler.obtainConnectionThrottler(IThreadContext threadContext,
String throttleGroupType,
String throttleGroup,
String[] binNames)
Construct connection throttler for connections with specific bin names.
|
void |
ConnectionBin.poll(IThreadContext threadContext)
Poll this bin
|
void |
FetchBin.poll(IThreadContext threadContext)
Poll this bin
|
void |
ThrottleBin.poll(IThreadContext threadContext)
Poll this bin
|
void |
Throttler.poll(IThreadContext threadContext)
Poll ALL bins periodically.
|
void |
Throttler.ThrottlingGroups.poll(IThreadContext threadContext)
Poll this set of throttle groups.
|
void |
Throttler.ThrottlingGroup.poll(IThreadContext threadContext)
Call this periodically.
|
void |
Throttler.poll(IThreadContext threadContext,
String throttleGroupType)
Poll periodically.
|
void |
Throttler.ThrottlingGroups.removeThrottleGroup(IThreadContext threadContext,
String throttleGroup)
Remove specified throttle group
|
void |
Throttler.removeThrottleGroup(IThreadContext threadContext,
String throttleGroupType,
String throttleGroup)
Remove a throttle group.
|
void |
ConnectionBin.shutDown(IThreadContext threadContext)
Shut down the bin, and release everything that is waiting on it.
|
void |
FetchBin.shutDown(IThreadContext threadContext)
Shut the bin down, and wake up all threads waiting on it.
|
void |
ThrottleBin.shutDown(IThreadContext threadContext)
Shut down this bin.
|
Constructor and Description |
---|
ConnectionBin(IThreadContext threadContext,
String throttlingGroupName,
String binName)
Constructor.
|
FetchBin(IThreadContext threadContext,
String throttlingGroupName,
String binName)
Constructor.
|
ThrottleBin(IThreadContext threadContext,
String throttlingGroupName,
String binName)
Constructor.
|
ThrottleGroups(IThreadContext threadContext)
Constructor
|
Throttler.ThrottlingGroup(IThreadContext threadContext,
String throttlingGroupType,
String throttleGroup,
IThrottleSpec throttleSpec)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
BaseCrawlerInitializationCommand.doExecute(IThreadContext tc) |
protected void |
ExportConfiguration.doExecute(IThreadContext tc) |
protected void |
ImportConfiguration.doExecute(IThreadContext tc) |
protected void |
InitializeAndRegister.doExecute(IThreadContext tc) |
protected void |
Register.doExecute(IThreadContext tc) |
protected void |
SynchronizeConnectors.doExecute(IThreadContext tc) |
protected abstract void |
TransactionalCrawlerInitializationCommand.doExecute(IThreadContext tc) |
protected void |
UnRegister.doExecute(IThreadContext tc) |
protected void |
UnRegisterAll.doExecute(IThreadContext tc) |
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
ConnectorManager.threadContext |
Constructor and Description |
---|
ConnectorManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static void |
NotificationConnectorFactory.deinstall(IThreadContext threadContext,
String className)
Uninstall connector.
|
static void |
RepositoryConnectorFactory.deinstall(IThreadContext threadContext,
String className)
Uninstall connector.
|
static String[] |
RepositoryConnectorFactory.getActivitiesList(IThreadContext threadContext,
String className)
Get the activities supported by this connector.
|
static int |
RepositoryConnectorFactory.getConnectorModel(IThreadContext threadContext,
String className)
Get the operating mode for a connector.
|
static String[] |
RepositoryConnectorFactory.getRelationshipTypes(IThreadContext threadContext,
String className)
Get the link types logged by this connector.
|
protected String[] |
RepositoryConnectorFactory.getThisActivitiesList(IThreadContext threadContext,
String className)
Get the activities supported by this connector.
|
protected int |
RepositoryConnectorFactory.getThisConnectorModel(IThreadContext threadContext,
String className)
Get the operating mode for a connector.
|
protected String[] |
RepositoryConnectorFactory.getThisRelationshipTypes(IThreadContext threadContext,
String className)
Get the link types logged by this connector.
|
static void |
NotificationConnectorFactory.install(IThreadContext threadContext,
String className)
Install connector.
|
static void |
RepositoryConnectorFactory.install(IThreadContext threadContext,
String className)
Install connector.
|
protected boolean |
NotificationConnectorFactory.isInstalled(IThreadContext tc,
String className) |
protected boolean |
RepositoryConnectorFactory.isInstalled(IThreadContext tc,
String className) |
static IBinManager |
BinManagerFactory.make(IThreadContext threadContext)
Create a bin manager handle.
|
static IConnectorManager |
ConnectorManagerFactory.make(IThreadContext tc)
Construct a connector manager.
|
static IJobManager |
JobManagerFactory.make(IThreadContext threadContext)
Create a job manager handle.
|
static INotificationConnectionManager |
NotificationConnectionManagerFactory.make(IThreadContext tc)
Make a notification connection manager handle.
|
static INotificationConnectorManager |
NotificationConnectorManagerFactory.make(IThreadContext tc)
Construct a connector manager.
|
static INotificationConnectorPool |
NotificationConnectorPoolFactory.make(IThreadContext tc)
Make a notification connector pool handle.
|
static IRepositoryConnectionManager |
RepositoryConnectionManagerFactory.make(IThreadContext tc)
Make a repository connection manager handle.
|
static IRepositoryConnectorPool |
RepositoryConnectorPoolFactory.make(IThreadContext tc)
Make a repository connector pool handle.
|
static IReprioritizationTracker |
ReprioritizationTrackerFactory.make(IThreadContext threadContext)
Create a reprioritization tracker handle.
|
static void |
NotificationConnectorFactory.outputConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
static void |
RepositoryConnectorFactory.outputConfigurationBody(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
String tabName)
Output the configuration body section.
|
static void |
NotificationConnectorFactory.outputConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
static void |
RepositoryConnectorFactory.outputConfigurationHeader(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams parameters,
ArrayList tabsArray)
Output the configuration header section.
|
static String |
NotificationConnectorFactory.processConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
static String |
RepositoryConnectorFactory.processConfigurationPost(IThreadContext threadContext,
String className,
IPostParameters variableContext,
Locale locale,
ConfigParams configParams)
Process configuration post data for a connector.
|
static void |
NotificationConnectorFactory.viewConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
static void |
RepositoryConnectorFactory.viewConfiguration(IThreadContext threadContext,
String className,
IHTTPOutput out,
Locale locale,
ConfigParams configParams)
View connector configuration.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
HopCount.threadContext
Thread context
|
protected IThreadContext |
JobManager.threadContext |
protected IThreadContext |
JobQueue.threadContext
Thread context
|
protected IThreadContext |
Jobs.threadContext |
Constructor and Description |
---|
ForcedParamManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
HopCount(IThreadContext tc,
IDBInterface database)
Constructor.
|
HopFilterManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
JobManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
JobQueue(IThreadContext tc,
IDBInterface database)
Constructor.
|
Jobs(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
NotificationManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
PipelineManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
ScheduleManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
NotificationConnectionManager.threadContext |
Constructor and Description |
---|
NotificationConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
NotificationConnectorPool.threadContext
Thread context
|
Modifier and Type | Method and Description |
---|---|
INotificationConnector[] |
NotificationConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
protected boolean |
NotificationConnectorPool.LocalPool.isConnectionNameValid(IThreadContext tc,
String connectionName) |
protected boolean |
NotificationConnectorPool.LocalPool.isInstalled(IThreadContext tc,
String className) |
Constructor and Description |
---|
NotificationConnectorPool(IThreadContext threadContext)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
NotificationConnectorManager.threadContext |
Constructor and Description |
---|
NotificationConnectorManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
RepositoryConnectionManager.threadContext |
protected IThreadContext |
RepositoryHistoryManager.threadContext
Thread context
|
Constructor and Description |
---|
RepositoryConnectionManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
RepositoryHistoryManager(IThreadContext tc,
IDBInterface database)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected IThreadContext |
RepositoryConnectorPool.threadContext
Thread context
|
Modifier and Type | Method and Description |
---|---|
IRepositoryConnector[] |
RepositoryConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
protected boolean |
RepositoryConnectorPool.LocalPool.isConnectionNameValid(IThreadContext tc,
String connectionName) |
protected boolean |
RepositoryConnectorPool.LocalPool.isInstalled(IThreadContext tc,
String className) |
Constructor and Description |
---|
RepositoryConnectorPool(IThreadContext threadContext)
Constructor
|
Constructor and Description |
---|
ReprioritizationTracker(IThreadContext threadContext)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected static int |
ManifoldCF.apiDeleteAuthorityConnection(IThreadContext tc,
Configuration output,
String connectionName)
Delete authority connection.
|
protected static int |
ManifoldCF.apiDeleteAuthorityGroup(IThreadContext tc,
Configuration output,
String groupName)
Delete authority group.
|
protected static int |
ManifoldCF.apiDeleteJob(IThreadContext tc,
Configuration output,
Long jobID)
Delete a job.
|
protected static int |
ManifoldCF.apiDeleteNotificationConnection(IThreadContext tc,
Configuration output,
String connectionName)
Delete notification connection.
|
protected static int |
ManifoldCF.apiDeleteOutputConnection(IThreadContext tc,
Configuration output,
String connectionName)
Delete output connection.
|
protected static int |
ManifoldCF.apiDeleteRepositoryConnection(IThreadContext tc,
Configuration output,
String connectionName)
Delete repository connection.
|
protected static int |
ManifoldCF.apiPostJob(IThreadContext tc,
Configuration output,
Configuration input)
Post job.
|
protected static int |
ManifoldCF.apiReadAuthorityConnection(IThreadContext tc,
Configuration output,
String connectionName)
Read authority connection
|
protected static int |
ManifoldCF.apiReadAuthorityConnections(IThreadContext tc,
Configuration output)
Get authority connections
|
protected static int |
ManifoldCF.apiReadAuthorityConnectionStatus(IThreadContext tc,
Configuration output,
String connectionName)
Read an authority connection status
|
protected static int |
ManifoldCF.apiReadAuthorityConnectors(IThreadContext tc,
Configuration output)
List authority connectors
|
protected static int |
ManifoldCF.apiReadAuthorityGroup(IThreadContext tc,
Configuration output,
String groupName)
Read authority group
|
protected static int |
ManifoldCF.apiReadAuthorityGroups(IThreadContext tc,
Configuration output)
Get authority groups
|
protected static int |
ManifoldCF.apiReadAuthorizationDomains(IThreadContext tc,
Configuration output)
List authorization domains
|
protected static int |
ManifoldCF.apiReadJob(IThreadContext tc,
Configuration output,
Long jobID)
Read a job
|
protected static int |
ManifoldCF.apiReadJobs(IThreadContext tc,
Configuration output)
Read jobs
|
protected static int |
ManifoldCF.apiReadJobStatus(IThreadContext tc,
Configuration output,
Long jobID,
Map<String,List<String>> queryParameters)
Get api job status
|
protected static int |
ManifoldCF.apiReadJobStatuses(IThreadContext tc,
Configuration output,
Map<String,List<String>> queryParameters)
Get api job statuses
|
protected static int |
ManifoldCF.apiReadJobStatusesNoCounts(IThreadContext tc,
Configuration output)
Get api job statuses
|
protected static int |
ManifoldCF.apiReadJobStatusNoCounts(IThreadContext tc,
Configuration output,
Long jobID)
Get api job status with no counts
|
protected static int |
ManifoldCF.apiReadMappingConnection(IThreadContext tc,
Configuration output,
String connectionName)
Read mapping connection
|
protected static int |
ManifoldCF.apiReadMappingConnections(IThreadContext tc,
Configuration output)
Get mapping connections
|
protected static int |
ManifoldCF.apiReadMappingConnectionStatus(IThreadContext tc,
Configuration output,
String connectionName)
Read a mapping connection status
|
protected static int |
ManifoldCF.apiReadMappingConnectors(IThreadContext tc,
Configuration output)
List mapping connectors
|
protected static int |
ManifoldCF.apiReadNotificationConnection(IThreadContext tc,
Configuration output,
String connectionName)
Read notification connection
|
protected static int |
ManifoldCF.apiReadNotificationConnectionInfo(IThreadContext tc,
Configuration output,
String connectionName,
String command)
Read a notification connection's info
|
protected static int |
ManifoldCF.apiReadNotificationConnections(IThreadContext tc,
Configuration output)
Get notification connections
|
protected static int |
ManifoldCF.apiReadNotificationConnectionStatus(IThreadContext tc,
Configuration output,
String connectionName)
Read a notification connection status
|
protected static int |
ManifoldCF.apiReadNotificationConnectors(IThreadContext tc,
Configuration output)
List notification connectors
|
protected static int |
ManifoldCF.apiReadOutputConnection(IThreadContext tc,
Configuration output,
String connectionName)
Read output connection
|
protected static int |
ManifoldCF.apiReadOutputConnectionInfo(IThreadContext tc,
Configuration output,
String connectionName,
String command)
Read an output connection's info
|
protected static int |
ManifoldCF.apiReadOutputConnections(IThreadContext tc,
Configuration output)
Get output connections
|
protected static int |
ManifoldCF.apiReadOutputConnectionStatus(IThreadContext tc,
Configuration output,
String connectionName)
Read an output connection status
|
protected static int |
ManifoldCF.apiReadOutputConnectors(IThreadContext tc,
Configuration output)
List output connectors
|
protected static int |
ManifoldCF.apiReadRepositoryConnection(IThreadContext tc,
Configuration output,
String connectionName)
Read repository connection
|
protected static int |
ManifoldCF.apiReadRepositoryConnectionActivities(IThreadContext tc,
Configuration output,
String connectionName)
Read the activity list for a given connection name.
|
protected static int |
ManifoldCF.apiReadRepositoryConnectionHistory(IThreadContext tc,
Configuration output,
String connectionName,
Map<String,List<String>> queryParameters)
History reports
|
protected static int |
ManifoldCF.apiReadRepositoryConnectionInfo(IThreadContext tc,
Configuration output,
String connectionName,
String command)
Read a repository connection's info
|
protected static int |
ManifoldCF.apiReadRepositoryConnectionJobs(IThreadContext tc,
Configuration output,
String connectionName)
Get jobs for connection
|
protected static int |
ManifoldCF.apiReadRepositoryConnectionQueue(IThreadContext tc,
Configuration output,
String connectionName,
Map<String,List<String>> queryParameters)
Queue reports
|
protected static int |
ManifoldCF.apiReadRepositoryConnections(IThreadContext tc,
Configuration output)
Get repository connections
|
protected static int |
ManifoldCF.apiReadRepositoryConnectionStatus(IThreadContext tc,
Configuration output,
String connectionName)
Read a repository connection status
|
protected static int |
ManifoldCF.apiReadRepositoryConnectors(IThreadContext tc,
Configuration output)
List repository connectors
|
protected static int |
ManifoldCF.apiReadTransformationConnection(IThreadContext tc,
Configuration output,
String connectionName)
Read transformation connection
|
protected static int |
ManifoldCF.apiReadTransformationConnectionInfo(IThreadContext tc,
Configuration output,
String connectionName,
String command)
Read a transformation connection's info
|
protected static int |
ManifoldCF.apiReadTransformationConnections(IThreadContext tc,
Configuration output)
Get transformation connections
|
protected static int |
ManifoldCF.apiReadTransformationConnectionStatus(IThreadContext tc,
Configuration output,
String connectionName)
Read a transformation connection status
|
protected static int |
ManifoldCF.apiReadTransformationConnectors(IThreadContext tc,
Configuration output)
List transformation connectors
|
protected static int |
ManifoldCF.apiWriteAbortJob(IThreadContext tc,
Configuration output,
Long jobID)
Abort a job.
|
protected static int |
ManifoldCF.apiWriteAuthorityConnection(IThreadContext tc,
Configuration output,
Configuration input,
String connectionName)
Write authority connection.
|
protected static int |
ManifoldCF.apiWriteAuthorityGroup(IThreadContext tc,
Configuration output,
Configuration input,
String groupName)
Write authority group.
|
protected static int |
ManifoldCF.apiWriteClearHistoryRepositoryConnection(IThreadContext tc,
Configuration output,
String connectionName)
Clear repository connection history.
|
protected static int |
ManifoldCF.apiWriteClearOutputConnection(IThreadContext tc,
Configuration output,
String connectionName)
Clear output connection (remove all recorded documents).
|
protected static int |
ManifoldCF.apiWriteClearVersionsOutputConnection(IThreadContext tc,
Configuration output,
String connectionName)
Reset output connection (reset version of all recorded documents).
|
protected static int |
ManifoldCF.apiWriteJob(IThreadContext tc,
Configuration output,
Configuration input,
Long jobID)
Write job.
|
protected static int |
ManifoldCF.apiWriteMappingConnection(IThreadContext tc,
Configuration output,
Configuration input,
String connectionName)
Write mapping connection.
|
protected static int |
ManifoldCF.apiWriteNotificationConnection(IThreadContext tc,
Configuration output,
Configuration input,
String connectionName)
Write notification connection.
|
protected static int |
ManifoldCF.apiWriteOutputConnection(IThreadContext tc,
Configuration output,
Configuration input,
String connectionName)
Write output connection.
|
protected static int |
ManifoldCF.apiWritePauseJob(IThreadContext tc,
Configuration output,
Long jobID)
Pause a job.
|
protected static int |
ManifoldCF.apiWriteRepositoryConnection(IThreadContext tc,
Configuration output,
Configuration input,
String connectionName)
Write repository connection.
|
protected static int |
ManifoldCF.apiWriteReseedJob(IThreadContext tc,
Configuration output,
Long jobID)
Reset incremental seeding for a job.
|
protected static int |
ManifoldCF.apiWriteRestartJob(IThreadContext tc,
Configuration output,
Long jobID,
boolean requestMinimum)
Restart a job.
|
protected static int |
ManifoldCF.apiWriteResumeJob(IThreadContext tc,
Configuration output,
Long jobID)
Resume a job.
|
protected static int |
ManifoldCF.apiWriteStartJob(IThreadContext tc,
Configuration output,
Long jobID,
boolean requestMinimum)
Start a job.
|
protected static int |
ManifoldCF.apiWriteTransformationConnection(IThreadContext tc,
Configuration output,
Configuration input,
String connectionName)
Write transformation connection.
|
void |
CrawlerAgent.cleanUp(IThreadContext threadContext)
Tear down agent environment.
|
void |
CrawlerAgent.cleanUpAgentData(IThreadContext threadContext,
String currentProcessID,
String cleanupProcessID)
Cleanup after agents process.
|
void |
CrawlerAgent.cleanUpAllAgentData(IThreadContext threadContext,
String currentProcessID)
Cleanup after ALL agents processes.
|
static void |
ManifoldCF.cleanUpEnvironment(IThreadContext tc) |
void |
CrawlerAgent.clusterInit(IThreadContext threadContext)
Called ONLY when no other active services of this kind are running.
|
static void |
ManifoldCF.createSystemDatabase(IThreadContext threadContext)
Create system database using superuser properties from properties.xml.
|
void |
CrawlerAgent.deinstall(IThreadContext threadContext)
Uninstall agent.
|
static void |
ManifoldCF.deinstallSystemTables(IThreadContext threadcontext)
Uninstall all the crawler system tables.
|
static int |
ManifoldCF.executeDeleteCommand(IThreadContext tc,
Configuration output,
String path)
Execute specified delete command.
|
static int |
ManifoldCF.executePostCommand(IThreadContext tc,
Configuration output,
String path,
Configuration input)
Execute specified post command.
|
static int |
ManifoldCF.executeReadCommand(IThreadContext tc,
Configuration output,
String path,
Map<String,List<String>> queryParameters)
Execute specified read command.
|
static int |
ManifoldCF.executeWriteCommand(IThreadContext tc,
Configuration output,
String path,
Configuration input)
Execute specified write command.
|
static void |
ManifoldCF.exportConfiguration(IThreadContext threadContext,
String exportFilename,
String passCode)
Atomically export the crawler configuration
|
static String[] |
ManifoldCF.getActivitiesList(IThreadContext threadContext,
String connectionName)
Get the activities list for a given repository connection.
|
static int |
ManifoldCF.getMaxCleanupThreads(IThreadContext threadContext)
Get the maximum number of cleanup threads.
|
static int |
ManifoldCF.getMaxDeleteThreads(IThreadContext threadContext)
Get the maximum number of delete threads.
|
static int |
ManifoldCF.getMaxExpireThreads(IThreadContext threadContext)
Get the maximum number of expire threads.
|
static int |
ManifoldCF.getMaxWorkerThreads(IThreadContext threadContext)
Get the maximum number of worker threads.
|
static void |
ManifoldCF.importConfiguration(IThreadContext threadContext,
String importFilename,
String passCode)
Atomically import a crawler configuration
|
void |
CrawlerAgent.initialize(IThreadContext threadContext)
Initialize agent environment.
|
static void |
ManifoldCF.initializeEnvironment(IThreadContext tc)
Initialize environment.
|
void |
CrawlerAgent.install(IThreadContext threadContext)
Install agent.
|
static void |
ManifoldCF.installSystemTables(IThreadContext threadcontext)
Install all the crawler system tables.
|
boolean |
CrawlerAgent.isOutputConnectionInUse(IThreadContext threadContext,
String connName)
Request permission from agent to delete an output connection.
|
boolean |
CrawlerAgent.isTransformationConnectionInUse(IThreadContext threadContext,
String connName)
Request permission from agent to delete a transformation connection.
|
static void |
ManifoldCF.localCleanup(IThreadContext tc) |
static void |
ManifoldCF.localInitialize(IThreadContext tc) |
void |
CrawlerAgent.noteOutputConnectionChange(IThreadContext threadContext,
String connectionName)
Note a change in configuration for an output connection.
|
void |
CrawlerAgent.noteOutputConnectorDeregistration(IThreadContext threadContext,
String[] connectionNames)
Note the deregistration of a set of output connections.
|
void |
CrawlerAgent.noteOutputConnectorRegistration(IThreadContext threadContext,
String[] connectionNames)
Note the registration of a set of output connections.
|
void |
CrawlerAgent.noteTransformationConnectionChange(IThreadContext threadContext,
String connectionName)
Note a change in configuration for a transformation connection.
|
void |
CrawlerAgent.noteTransformationConnectorDeregistration(IThreadContext threadContext,
String[] connectionNames)
Note the deregistration of a set of transformation connections.
|
void |
CrawlerAgent.noteTransformationConnectorRegistration(IThreadContext threadContext,
String[] connectionNames)
Note the registration of a set of transformation connections.
|
protected void |
DeleteStartupResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
protected void |
DocCleanupResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
protected void |
DocDeleteResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
protected void |
NotificationResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
protected abstract void |
ResetManager.performResetLogic(IThreadContext tc,
String processID)
Do the reset logic.
|
protected void |
SeedingResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
protected void |
StartupResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
protected void |
WorkerResetManager.performResetLogic(IThreadContext tc,
String processID)
Reset
|
static void |
ManifoldCF.registerConnectors(IThreadContext tc,
Connectors c)
Register all connectors as specified by a Connectors structure, usually read from the connectors.xml file.
|
static void |
ManifoldCF.registerThisAgent(IThreadContext tc)
Register this agent
|
static void |
ManifoldCF.reregisterAllConnectors(IThreadContext tc)
Register or re-register all connectors, based on a connectors.xml file.
|
static void |
ManifoldCF.resetAllDocumentPriorities(IThreadContext threadContext,
String processID)
Reset all (active) document priorities.
|
void |
CrawlerAgent.startAgent(IThreadContext threadContext,
String processID)
Start the agent.
|
void |
CrawlerAgent.startSystem(IThreadContext threadContext)
Start everything.
|
void |
CrawlerAgent.stopAgent(IThreadContext threadContext)
Stop the agent.
|
void |
CrawlerAgent.stopSystem(IThreadContext threadContext)
Stop the system.
|
static void |
ManifoldCF.unregisterAllConnectors(IThreadContext tc)
Unregister all connectors.
|
static void |
ManifoldCF.unregisterAllConnectors(IThreadContext tc,
Connectors c)
Unregister all connectors which don't match a specified connector list.
|
boolean |
ResetManager.waitForReset(IThreadContext tc)
Enter "wait" state for current thread.
|
static void |
ManifoldCF.writeDocumentPriorities(IThreadContext threadContext,
DocumentDescription[] descs,
Map<String,IRepositoryConnection> connectionMap,
Map<Long,IJobDescription> jobDescriptionMap)
Write a set of document priorities, based on the current queue tracker.
|
Modifier and Type | Method and Description |
---|---|
static void |
ManifoldCFJettyRunner.runAgents(IThreadContext tc)
Run the agents process.
|
Modifier and Type | Method and Description |
---|---|
IThreadContext |
ThreadContext.getThreadContext()
Get the thread context.
|
Modifier and Type | Method and Description |
---|---|
void |
APIProfile.login(IThreadContext threadContext,
String userID,
String userPassword)
Log on the user, with the already-set user id and company
description.
|
void |
AdminProfile.login(IThreadContext threadContext,
String userID,
String userPassword)
Log on the user, with the already-set user id and company
description.
|