public class ReplayConfig
extends exa.bee.config.Versioned
implements com.exalead.util.Checkable, java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
ReplayConfig.EngineType |
Modifier and Type | Field and Description |
---|---|
int |
commitPeriodSecThreshold |
int |
commitSizeMbThreshold |
java.lang.String |
connectionUrl |
static int |
DEFAULT_COMMIT_PERIOD_SEC_THRESHOLD |
static int |
DEFAULT_COMMIT_SIZE_MB_THRESHOLD |
static java.lang.String |
DEFAULT_ENGINE_TYPE |
static boolean |
DEFAULT_HAS_SNAPSHOT |
static int |
DEFAULT_MAX_CONNECTION_NUMBER |
static int |
DEFAULT_OVERLAY_THRESHOLD |
java.lang.String |
engineType |
boolean |
hasSnapshot |
java.lang.String |
instance |
java.lang.String |
login |
int |
maxConnectionNumber |
int |
maxIdleTime |
int |
overlayThreshold |
java.lang.String |
password |
int |
port |
Constructor and Description |
---|
ReplayConfig() |
ReplayConfig(ReplayConfig o)
Copy constructor
|
Modifier and Type | Method and Description |
---|---|
void |
check(boolean deep,
java.lang.String errorContext)
Checks this ReplayConfig.
|
static ReplayConfig |
fromString(java.lang.String s)
String representation of this ReplayConfig.
|
int |
getCommitPeriodSecThreshold()
The maximum duration in seconds a transaction is being uncommitted.
|
int |
getCommitSizeMbThreshold()
The maximum size estimated in Megabytes a transaction can readch before being committed.
|
java.lang.String |
getConnectionUrl()
Parameters to connect to the storage engine.
|
java.lang.String |
getEngineType()
The engine to use for the storage.
|
ReplayConfig.EngineType |
getEngineTypeAsEnum()
The engine to use for the storage.
|
java.lang.String |
getInstance()
Instance name of the replay server.
|
java.lang.String |
getLogin()
Login to connect to the storage engine.
|
int |
getMaxConnectionNumber()
The maximum number of database connections which can be opened at once.
|
int |
getMaxIdleTime()
The max idle time (in second) for which an action is on a socket is waited for (typically handles the write timeout).
|
int |
getOverlayThreshold()
The size above which an entry is persisted into a dedicated file instead of being inserted into a BLOB.
If 0 or below, no file overlay is made and everything is stored within a BLOB, the limitation here is that of the DB. |
java.lang.String |
getPassword()
Password to connect to the storage engine.
|
int |
getPort()
The port which the replay server listens to.
|
static boolean |
isA(java.lang.String str,
ReplayConfig.EngineType item) |
boolean |
isHasSnapshot()
Is the snapshot table updated when a new command is saved ?
|
static boolean |
isOneOf(java.lang.String str,
ReplayConfig.EngineType... items) |
ReplayConfig |
makeCopy()
Creates and returns a deep copy of this ReplayConfig.
|
static ReplayConfig |
readFrom(java.io.InputStream is)
Read this ReplayConfig from an XML fragment.
|
void |
setCommitPeriodSecThreshold(int commitPeriodSecThreshold)
The maximum duration in seconds a transaction is being uncommitted.
|
void |
setCommitSizeMbThreshold(int commitSizeMbThreshold)
The maximum size estimated in Megabytes a transaction can readch before being committed.
|
void |
setConnectionUrl(java.lang.String connectionUrl)
Parameters to connect to the storage engine.
|
void |
setEngineType(ReplayConfig.EngineType item)
The engine to use for the storage.
|
void |
setEngineType(java.lang.String engineType)
The engine to use for the storage.
|
void |
setHasSnapshot(boolean hasSnapshot)
Is the snapshot table updated when a new command is saved ?
|
void |
setInstance(java.lang.String instance)
Instance name of the replay server.
|
void |
setLogin(java.lang.String login)
Login to connect to the storage engine.
|
void |
setMaxConnectionNumber(int maxConnectionNumber)
The maximum number of database connections which can be opened at once.
|
void |
setMaxIdleTime(int maxIdleTime)
The max idle time (in second) for which an action is on a socket is waited for (typically handles the write timeout).
|
void |
setOverlayThreshold(int overlayThreshold)
The size above which an entry is persisted into a dedicated file instead of being inserted into a BLOB.
If 0 or below, no file overlay is made and everything is stored within a BLOB, the limitation here is that of the DB. |
void |
setPassword(java.lang.String password)
Password to connect to the storage engine.
|
void |
setPort(int port)
The port which the replay server listens to.
|
java.lang.String |
toString()
String representation of this ReplayConfig.
|
ReplayConfig |
withCommitPeriodSecThreshold(int commitPeriodSecThreshold) |
ReplayConfig |
withCommitPeriodSecThreshold(java.lang.Integer commitPeriodSecThreshold) |
ReplayConfig |
withCommitSizeMbThreshold(int commitSizeMbThreshold) |
ReplayConfig |
withCommitSizeMbThreshold(java.lang.Integer commitSizeMbThreshold) |
ReplayConfig |
withConnectionUrl(java.lang.String connectionUrl) |
ReplayConfig |
withEngineType(java.lang.String engineType) |
ReplayConfig |
withHasSnapshot(boolean hasSnapshot) |
ReplayConfig |
withHasSnapshot(java.lang.Boolean hasSnapshot) |
ReplayConfig |
withInstance(java.lang.String instance) |
ReplayConfig |
withLogin(java.lang.String login) |
ReplayConfig |
withMaxConnectionNumber(int maxConnectionNumber) |
ReplayConfig |
withMaxConnectionNumber(java.lang.Integer maxConnectionNumber) |
ReplayConfig |
withMaxIdleTime(int maxIdleTime) |
ReplayConfig |
withMaxIdleTime(java.lang.Integer maxIdleTime) |
ReplayConfig |
withOverlayThreshold(int overlayThreshold) |
ReplayConfig |
withOverlayThreshold(java.lang.Integer overlayThreshold) |
ReplayConfig |
withPassword(java.lang.String password) |
ReplayConfig |
withPort(int port) |
ReplayConfig |
withPort(java.lang.Integer port) |
ReplayConfig |
withVersion(long version) |
ReplayConfig |
withVersion(java.lang.Long version) |
void |
writeTo(java.io.OutputStream os)
Write this ReplayConfig as an XML fragment
|
public int port
public int maxIdleTime
public java.lang.String instance
public java.lang.String connectionUrl
public java.lang.String login
public java.lang.String password
public java.lang.String engineType
public static final java.lang.String DEFAULT_ENGINE_TYPE
public int overlayThreshold
public static final int DEFAULT_OVERLAY_THRESHOLD
public int commitSizeMbThreshold
public static final int DEFAULT_COMMIT_SIZE_MB_THRESHOLD
public int commitPeriodSecThreshold
public static final int DEFAULT_COMMIT_PERIOD_SEC_THRESHOLD
public boolean hasSnapshot
public static final boolean DEFAULT_HAS_SNAPSHOT
public int maxConnectionNumber
public static final int DEFAULT_MAX_CONNECTION_NUMBER
public ReplayConfig()
public ReplayConfig(ReplayConfig o)
public static boolean isA(java.lang.String str, ReplayConfig.EngineType item)
public static boolean isOneOf(java.lang.String str, ReplayConfig.EngineType... items)
public void setEngineType(ReplayConfig.EngineType item)
public ReplayConfig.EngineType getEngineTypeAsEnum()
public ReplayConfig withVersion(long version)
withVersion
in class exa.bee.config.Versioned
public ReplayConfig withVersion(java.lang.Long version)
withVersion
in class exa.bee.config.Versioned
public void setPort(int port)
public int getPort()
public ReplayConfig withPort(int port)
public ReplayConfig withPort(java.lang.Integer port)
public void setMaxIdleTime(int maxIdleTime)
public int getMaxIdleTime()
public ReplayConfig withMaxIdleTime(int maxIdleTime)
public ReplayConfig withMaxIdleTime(java.lang.Integer maxIdleTime)
public void setInstance(java.lang.String instance)
public java.lang.String getInstance()
public ReplayConfig withInstance(java.lang.String instance)
public void setConnectionUrl(java.lang.String connectionUrl)
public java.lang.String getConnectionUrl()
public ReplayConfig withConnectionUrl(java.lang.String connectionUrl)
public void setLogin(java.lang.String login)
public java.lang.String getLogin()
public ReplayConfig withLogin(java.lang.String login)
public void setPassword(java.lang.String password)
public java.lang.String getPassword()
public ReplayConfig withPassword(java.lang.String password)
public void setEngineType(java.lang.String engineType)
public java.lang.String getEngineType()
public ReplayConfig withEngineType(java.lang.String engineType)
public void setOverlayThreshold(int overlayThreshold)
public int getOverlayThreshold()
public ReplayConfig withOverlayThreshold(int overlayThreshold)
public ReplayConfig withOverlayThreshold(java.lang.Integer overlayThreshold)
public void setCommitSizeMbThreshold(int commitSizeMbThreshold)
public int getCommitSizeMbThreshold()
public ReplayConfig withCommitSizeMbThreshold(int commitSizeMbThreshold)
public ReplayConfig withCommitSizeMbThreshold(java.lang.Integer commitSizeMbThreshold)
public void setCommitPeriodSecThreshold(int commitPeriodSecThreshold)
public int getCommitPeriodSecThreshold()
public ReplayConfig withCommitPeriodSecThreshold(int commitPeriodSecThreshold)
public ReplayConfig withCommitPeriodSecThreshold(java.lang.Integer commitPeriodSecThreshold)
public void setHasSnapshot(boolean hasSnapshot)
public boolean isHasSnapshot()
public ReplayConfig withHasSnapshot(boolean hasSnapshot)
public ReplayConfig withHasSnapshot(java.lang.Boolean hasSnapshot)
public void setMaxConnectionNumber(int maxConnectionNumber)
public int getMaxConnectionNumber()
public ReplayConfig withMaxConnectionNumber(int maxConnectionNumber)
public ReplayConfig withMaxConnectionNumber(java.lang.Integer maxConnectionNumber)
public ReplayConfig makeCopy()
makeCopy
in class exa.bee.config.Versioned
public static ReplayConfig readFrom(java.io.InputStream is) throws javax.xml.bind.JAXBException
javax.xml.bind.JAXBException
public void writeTo(java.io.OutputStream os) throws javax.xml.bind.JAXBException, java.io.IOException
writeTo
in class exa.bee.config.Versioned
javax.xml.bind.JAXBException
java.io.IOException
public static ReplayConfig fromString(java.lang.String s) throws javax.xml.bind.JAXBException, java.io.UnsupportedEncodingException
javax.xml.bind.JAXBException
java.io.UnsupportedEncodingException
public java.lang.String toString()
toString
in class exa.bee.config.Versioned
public void check(boolean deep, java.lang.String errorContext) throws com.exalead.util.TypedException
check
in interface com.exalead.util.Checkable
check
in class exa.bee.config.Versioned
com.exalead.util.TypedException
Copyright © 2021 Dassault Systèmes, All Rights Reserved.