Class SlaveServerConfig

java.lang.Object
org.pentaho.di.www.SlaveServerConfig

public class SlaveServerConfig extends Object
  • Field Details

  • Constructor Details

    • 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 Details

    • 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.api.IMetaStore getMetaStore()
    • getMetastoreSupplier

      public Supplier<org.pentaho.metastore.api.IMetaStore> getMetastoreSupplier()
    • setMetastoreSupplier

      public void setMetastoreSupplier(Supplier<org.pentaho.metastore.api.IMetaStore> metastoreSupplier)
      Should generally be used only for tests.
      Parameters:
      metastoreSupplier -
    • getPasswordFile

      public String getPasswordFile()
    • setPasswordFile

      public void setPasswordFile(String passwordFile)
    • getRepositoryId

      public String getRepositoryId()
    • setRepositoryId

      public void setRepositoryId(String repositoryId)