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 String
XML_TAG
static String
XML_TAG_ACCEPT_QUEUE_SIZE
static String
XML_TAG_ACCEPTORS
static String
XML_TAG_AUTO_CREATE
static String
XML_TAG_AUTOSEQUENCE
static String
XML_TAG_JETTY_OPTIONS
static String
XML_TAG_LOW_RES_MAX_IDLE_TIME
static String
XML_TAG_MASTERS
static String
XML_TAG_REPOSITORY
static String
XML_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 SlaveSequence
getAutoSequence()
List<org.pentaho.di.core.database.DatabaseMeta>
getDatabases()
String
getFilename()
List<SlaveServer>
getMasters()
int
getMaxLogLines()
int
getMaxLogTimeoutMinutes()
org.pentaho.metastore.stores.delegate.DelegatingMetaStore
getMetaStore()
int
getObjectTimeoutMinutes()
String
getPasswordFile()
Repository
getRepository()
String
getRepositoryId()
String
getRepositoryPassword()
String
getRepositoryUsername()
List<SlaveSequence>
getSlaveSequences()
SlaveServer
getSlaveServer()
String
getXML()
boolean
isAutomaticCreationAllowed()
boolean
isJoining()
boolean
isReportingToMasters()
protected Map<String,String>
parseJettyOptions(Node node)
Read and parse jetty optionsvoid
readAutoSequences()
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
setMetaStore(org.pentaho.metastore.stores.delegate.DelegatingMetaStore metaStore)
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 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)
-
-