Package org.pentaho.di.www
Class SlaveServerConfig
java.lang.Object
org.pentaho.di.www.SlaveServerConfig
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionSlaveServerConfig(String hostname, int port, boolean joining) SlaveServerConfig(List<SlaveServer> masters, boolean reportingToMasters, SlaveServer slaveServer) SlaveServerConfig(SlaveServer slaveServer) SlaveServerConfig(org.pentaho.di.core.logging.LogChannelInterface log, Node node) -
Method Summary
Modifier and TypeMethodDescriptionList<org.pentaho.di.core.database.DatabaseMeta>intintorg.pentaho.metastore.api.IMetaStoreSupplier<org.pentaho.metastore.api.IMetaStore>intgetXML()booleanbooleanbooleanparseJettyOptions(Node node) Read and parse jetty optionsvoidvoidsetAutomaticCreationAllowed(boolean automaticCreationAllowed) voidsetAutoSequence(SlaveSequence autoSequence) voidsetDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases) voidsetFilename(String filename) voidsetJoining(boolean joining) voidsetMasters(List<SlaveServer> masters) voidsetMaxLogLines(int maxLogLines) voidsetMaxLogTimeoutMinutes(int maxLogTimeoutMinutes) voidsetMetastoreSupplier(Supplier<org.pentaho.metastore.api.IMetaStore> metastoreSupplier) Should generally be used only for tests.voidsetObjectTimeoutMinutes(int objectTimeoutMinutes) voidsetPasswordFile(String passwordFile) voidsetReportingToMasters(boolean reportingToMaster) voidsetRepository(Repository repository) voidsetRepositoryId(String repositoryId) voidsetRepositoryPassword(String repositoryPassword) voidsetRepositoryUsername(String repositoryUsername) voidsetSlaveSequences(List<SlaveSequence> slaveSequences) voidsetSlaveServer(SlaveServer slaveServer) protected voidsetUpJettyOptions(Node node) Set up jetty options to the system properties
-
Field Details
-
XML_TAG
- See Also:
-
XML_TAG_MASTERS
- See Also:
-
XML_TAG_REPOSITORY
- See Also:
-
XML_TAG_SEQUENCES
- See Also:
-
XML_TAG_AUTOSEQUENCE
- See Also:
-
XML_TAG_AUTO_CREATE
- See Also:
-
XML_TAG_JETTY_OPTIONS
- See Also:
-
XML_TAG_ACCEPTORS
- See Also:
-
XML_TAG_ACCEPT_QUEUE_SIZE
- See Also:
-
XML_TAG_LOW_RES_MAX_IDLE_TIME
- See Also:
-
-
Constructor Details
-
SlaveServerConfig
public SlaveServerConfig() -
SlaveServerConfig
-
SlaveServerConfig
public SlaveServerConfig(List<SlaveServer> masters, boolean reportingToMasters, SlaveServer slaveServer) -
SlaveServerConfig
public SlaveServerConfig(org.pentaho.di.core.logging.LogChannelInterface log, Node node) throws org.pentaho.di.core.exception.KettleXMLException - Throws:
org.pentaho.di.core.exception.KettleXMLException
-
SlaveServerConfig
-
-
Method Details
-
getXML
-
setUpJettyOptions
Set up jetty options to the system properties- Parameters:
node-
-
parseJettyOptions
Read and parse jetty options- Parameters:
node- that contains jetty options nodes- Returns:
- map of not empty jetty options
-
readAutoSequences
public void readAutoSequences() throws org.pentaho.di.core.exception.KettleException- Throws:
org.pentaho.di.core.exception.KettleException
-
getMasters
- Returns:
- the list of masters to report back to if the report to masters flag is enabled.
-
setMasters
- Parameters:
masters- the list of masters to set. It is the list of masters to report back to if the report to masters flag is enabled.
-
getSlaveServer
- Returns:
- the slave server.
The user name and password defined in here are used to contact this slave by the masters.
-
setSlaveServer
- Parameters:
slaveServer- the slave server details to set.
The user name and password defined in here are used to contact this slave by the masters.
-
isReportingToMasters
public boolean isReportingToMasters()- Returns:
- true if this slave reports to the masters
-
setReportingToMasters
public void setReportingToMasters(boolean reportingToMaster) - Parameters:
reportingToMaster- set to true if this slave should report to the masters
-
isJoining
public boolean isJoining()- Returns:
- true if the webserver needs to join with the webserver threads (wait/block until finished)
-
setJoining
public void setJoining(boolean joining) - Parameters:
joining- Set to true if the webserver needs to join with the webserver threads (wait/block until finished)
-
getMaxLogLines
public int getMaxLogLines()- Returns:
- the maxLogLines
-
setMaxLogLines
public void setMaxLogLines(int maxLogLines) - Parameters:
maxLogLines- the maxLogLines to set
-
getMaxLogTimeoutMinutes
public int getMaxLogTimeoutMinutes()- Returns:
- the maxLogTimeoutMinutes
-
setMaxLogTimeoutMinutes
public void setMaxLogTimeoutMinutes(int maxLogTimeoutMinutes) - Parameters:
maxLogTimeoutMinutes- the maxLogTimeoutMinutes to set
-
getObjectTimeoutMinutes
public int getObjectTimeoutMinutes()- Returns:
- the objectTimeoutMinutes
-
setObjectTimeoutMinutes
public void setObjectTimeoutMinutes(int objectTimeoutMinutes) - Parameters:
objectTimeoutMinutes- the objectTimeoutMinutes to set
-
getFilename
- Returns:
- the filename
-
setFilename
- Parameters:
filename- the filename to set
-
getDatabases
- Returns:
- the databases
-
setDatabases
- Parameters:
databases- the databases to set
-
getSlaveSequences
- Returns:
- the slaveSequences
-
setSlaveSequences
- Parameters:
slaveSequences- the slaveSequences to set
-
getAutoSequence
- Returns:
- the autoSequence
-
setAutoSequence
- Parameters:
autoSequence- the autoSequence to set
-
isAutomaticCreationAllowed
public boolean isAutomaticCreationAllowed()- Returns:
- the automaticCreationAllowed
-
setAutomaticCreationAllowed
public void setAutomaticCreationAllowed(boolean automaticCreationAllowed) - Parameters:
automaticCreationAllowed- the automaticCreationAllowed to set
-
getRepository
- Returns:
- the repository, loaded lazily
- Throws:
org.pentaho.di.core.exception.KettleException
-
setRepository
- Parameters:
repository- the repository to set
-
getRepositoryUsername
- Returns:
- the repositoryUsername
-
setRepositoryUsername
- Parameters:
repositoryUsername- the repositoryUsername to set
-
getRepositoryPassword
- Returns:
- the repositoryPassword
-
setRepositoryPassword
- Parameters:
repositoryPassword- the repositoryPassword to set
-
getMetaStore
public org.pentaho.metastore.api.IMetaStore getMetaStore() -
getMetastoreSupplier
-
setMetastoreSupplier
Should generally be used only for tests.- Parameters:
metastoreSupplier-
-
getPasswordFile
-
setPasswordFile
-
getRepositoryId
-
setRepositoryId
-