Package org.pentaho.di.www
Class SlaveServerConfig
java.lang.Object
org.pentaho.di.www.SlaveServerConfig
-
Field Summary
-
Constructor Summary
ConstructorDescriptionSlaveServerConfig
(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>
int
int
org.pentaho.metastore.api.IMetaStore
Supplier<org.pentaho.metastore.api.IMetaStore>
int
getXML()
boolean
boolean
boolean
parseJettyOptions
(Node node) Read and parse jetty optionsvoid
void
setAutomaticCreationAllowed
(boolean automaticCreationAllowed) void
setAutoSequence
(SlaveSequence autoSequence) void
setDatabases
(List<org.pentaho.di.core.database.DatabaseMeta> databases) void
setFilename
(String filename) void
setJoining
(boolean joining) void
setMasters
(List<SlaveServer> masters) void
setMaxLogLines
(int maxLogLines) void
setMaxLogTimeoutMinutes
(int maxLogTimeoutMinutes) void
setMetastoreSupplier
(Supplier<org.pentaho.metastore.api.IMetaStore> metastoreSupplier) Should generally be used only for tests.void
setObjectTimeoutMinutes
(int objectTimeoutMinutes) void
setPasswordFile
(String passwordFile) void
setReportingToMasters
(boolean reportingToMaster) void
setRepository
(Repository repository) void
setRepositoryId
(String repositoryId) void
setRepositoryPassword
(String repositoryPassword) void
setRepositoryUsername
(String repositoryUsername) void
setSlaveSequences
(List<SlaveSequence> slaveSequences) void
setSlaveServer
(SlaveServer slaveServer) protected void
setUpJettyOptions
(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
-