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 and Description
static String	XML_TAG
static String	XML_TAG_AUTO_CREATE
static String	XML_TAG_AUTOSEQUENCE
static String	XML_TAG_MASTERS
static String	XML_TAG_REPOSITORY
static String	XML_TAG_SEQUENCES
static String	XML_TAG_SERVICE
static String	XML_TAG_SERVICES

Constructor Summary

Constructors

Constructor and Description
SlaveServerConfig()
SlaveServerConfig(List<SlaveServer> masters, boolean reportingToMasters, SlaveServer slaveServer)
SlaveServerConfig(org.pentaho.di.core.logging.LogChannelInterface log, Node node)
SlaveServerConfig(SlaveServer slaveServer)
SlaveServerConfig(String hostname, int port, boolean joining)

Method Summary

Methods

Modifier and Type	Method and 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<org.pentaho.di.core.jdbc.TransDataService>	getServices()
List<SlaveSequence>	getSlaveSequences()
SlaveServer	getSlaveServer()
String	getXML()
boolean	isAutomaticCreationAllowed()
boolean	isJoining()
boolean	isReportingToMasters()
void	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	setServices(List<org.pentaho.di.core.jdbc.TransDataService> services)
void	setSlaveSequences(List<SlaveSequence> slaveSequences)
void	setSlaveServer(SlaveServer slaveServer)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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_SERVICES

public static final String XML_TAG_SERVICES

See Also:

Constant Field Values

XML_TAG_SERVICE

public static final String XML_TAG_SERVICE

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()

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

getServices

public List<org.pentaho.di.core.jdbc.TransDataService> getServices()

Returns:

the services

setServices

public void setServices(List<org.pentaho.di.core.jdbc.TransDataService> services)

Parameters:

services - the services 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)