Package org.pentaho.di.www
Class SlaveServerConfig
- java.lang.Object
-
- org.pentaho.di.www.SlaveServerConfig
-
public class SlaveServerConfig extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static StringXML_TAGstatic StringXML_TAG_ACCEPT_QUEUE_SIZEstatic StringXML_TAG_ACCEPTORSstatic StringXML_TAG_AUTO_CREATEstatic StringXML_TAG_AUTOSEQUENCEstatic StringXML_TAG_JETTY_OPTIONSstatic StringXML_TAG_LOW_RES_MAX_IDLE_TIMEstatic StringXML_TAG_MASTERSstatic StringXML_TAG_REPOSITORYstatic StringXML_TAG_SEQUENCES
-
Constructor Summary
Constructors Constructor Description SlaveServerConfig()SlaveServerConfig(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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SlaveSequencegetAutoSequence()List<org.pentaho.di.core.database.DatabaseMeta>getDatabases()StringgetFilename()List<SlaveServer>getMasters()intgetMaxLogLines()intgetMaxLogTimeoutMinutes()org.pentaho.metastore.stores.delegate.DelegatingMetaStoregetMetaStore()intgetObjectTimeoutMinutes()StringgetPasswordFile()RepositorygetRepository()StringgetRepositoryId()StringgetRepositoryPassword()StringgetRepositoryUsername()List<SlaveSequence>getSlaveSequences()SlaveServergetSlaveServer()StringgetXML()booleanisAutomaticCreationAllowed()booleanisJoining()booleanisReportingToMasters()protected Map<String,String>parseJettyOptions(Node node)Read and parse jetty optionsvoidreadAutoSequences()voidsetAutomaticCreationAllowed(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)voidsetMetaStore(org.pentaho.metastore.stores.delegate.DelegatingMetaStore metaStore)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 Detail
-
XML_TAG
public static final String XML_TAG
- See Also:
- Constant Field Values
-
XML_TAG_MASTERS
public static final String XML_TAG_MASTERS
- See Also:
- Constant Field Values
-
XML_TAG_REPOSITORY
public static final String XML_TAG_REPOSITORY
- See Also:
- Constant Field Values
-
XML_TAG_SEQUENCES
public static final String XML_TAG_SEQUENCES
- See Also:
- Constant Field Values
-
XML_TAG_AUTOSEQUENCE
public static final String XML_TAG_AUTOSEQUENCE
- See Also:
- Constant Field Values
-
XML_TAG_AUTO_CREATE
public static final String XML_TAG_AUTO_CREATE
- See Also:
- Constant Field Values
-
XML_TAG_JETTY_OPTIONS
public static final String XML_TAG_JETTY_OPTIONS
- See Also:
- Constant Field Values
-
XML_TAG_ACCEPTORS
public static final String XML_TAG_ACCEPTORS
- See Also:
- Constant Field Values
-
XML_TAG_ACCEPT_QUEUE_SIZE
public static final String XML_TAG_ACCEPT_QUEUE_SIZE
- See Also:
- Constant Field Values
-
XML_TAG_LOW_RES_MAX_IDLE_TIME
public static final String XML_TAG_LOW_RES_MAX_IDLE_TIME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SlaveServerConfig
public SlaveServerConfig()
-
SlaveServerConfig
public SlaveServerConfig(SlaveServer slaveServer)
-
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
public SlaveServerConfig(String hostname, int port, boolean joining)
-
-
Method Detail
-
getXML
public String getXML()
-
setUpJettyOptions
protected void setUpJettyOptions(Node node)
Set up jetty options to the system properties- Parameters:
node-
-
parseJettyOptions
protected Map<String,String> parseJettyOptions(Node node)
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
public List<SlaveServer> getMasters()
- Returns:
- the list of masters to report back to if the report to masters flag is enabled.
-
setMasters
public void setMasters(List<SlaveServer> masters)
- 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
public SlaveServer getSlaveServer()
- Returns:
- the slave server.
The user name and password defined in here are used to contact this slave by the masters.
-
setSlaveServer
public void setSlaveServer(SlaveServer slaveServer)
- 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
public String getFilename()
- Returns:
- the filename
-
setFilename
public void setFilename(String filename)
- Parameters:
filename- the filename to set
-
getDatabases
public List<org.pentaho.di.core.database.DatabaseMeta> getDatabases()
- Returns:
- the databases
-
setDatabases
public void setDatabases(List<org.pentaho.di.core.database.DatabaseMeta> databases)
- Parameters:
databases- the databases to set
-
getSlaveSequences
public List<SlaveSequence> getSlaveSequences()
- Returns:
- the slaveSequences
-
setSlaveSequences
public void setSlaveSequences(List<SlaveSequence> slaveSequences)
- Parameters:
slaveSequences- the slaveSequences to set
-
getAutoSequence
public SlaveSequence getAutoSequence()
- Returns:
- the autoSequence
-
setAutoSequence
public void setAutoSequence(SlaveSequence autoSequence)
- 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
public Repository getRepository() throws org.pentaho.di.core.exception.KettleException
- Returns:
- the repository, loaded lazily
- Throws:
org.pentaho.di.core.exception.KettleException
-
setRepository
public void setRepository(Repository repository)
- Parameters:
repository- the repository to set
-
getRepositoryUsername
public String getRepositoryUsername()
- Returns:
- the repositoryUsername
-
setRepositoryUsername
public void setRepositoryUsername(String repositoryUsername)
- Parameters:
repositoryUsername- the repositoryUsername to set
-
getRepositoryPassword
public String getRepositoryPassword()
- Returns:
- the repositoryPassword
-
setRepositoryPassword
public void setRepositoryPassword(String repositoryPassword)
- Parameters:
repositoryPassword- the repositoryPassword to set
-
getMetaStore
public org.pentaho.metastore.stores.delegate.DelegatingMetaStore getMetaStore()
-
setMetaStore
public void setMetaStore(org.pentaho.metastore.stores.delegate.DelegatingMetaStore metaStore)
-
getPasswordFile
public String getPasswordFile()
-
setPasswordFile
public void setPasswordFile(String passwordFile)
-
getRepositoryId
public String getRepositoryId()
-
setRepositoryId
public void setRepositoryId(String repositoryId)
-
-