Package dev.henneberger.vertx.sqlserver.replication

Class SqlServerReplicationOptions

java.lang.Object

dev.henneberger.vertx.sqlserver.replication.SqlServerReplicationOptions

public class SqlServerReplicationOptions
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_HOST
static final int	DEFAULT_PORT

Constructor Summary

Constructors

Constructor	Description
SqlServerReplicationOptions()
SqlServerReplicationOptions(SqlServerReplicationOptions other)
SqlServerReplicationOptions(io.vertx.core.json.JsonObject json)

Method Summary

Modifier and Type	Method	Description
String	getCaptureInstance()
String	getDatabase()
String	getHost()
dev.henneberger.vertx.replication.core.LsnStore	getLsnStore()
int	getMaxBatchSize()
int	getMaxConcurrentDispatch()
String	getPassword()
String	getPasswordEnv()
long	getPollIntervalMs()
Integer	getPort()
long	getPreflightMaxWaitMs()
String	getPreflightMode()
long	getPreflightRetryIntervalMs()
dev.henneberger.vertx.replication.core.RetryPolicy	getRetryPolicy()
Boolean	getSsl()
String	getUser()
String	getValueNormalizationMode()
dev.henneberger.vertx.replication.core.ValueNormalizer	getValueNormalizer()
boolean	isAutoStart()
boolean	isPreflightEnabled()
SqlServerReplicationOptions	merge(io.vertx.core.json.JsonObject other)
SqlServerReplicationOptions	setAutoStart(boolean autoStart)
SqlServerReplicationOptions	setCaptureInstance(String captureInstance)
SqlServerReplicationOptions	setDatabase(String database)
SqlServerReplicationOptions	setHost(String host)
SqlServerReplicationOptions	setLsnStore(dev.henneberger.vertx.replication.core.LsnStore lsnStore)
SqlServerReplicationOptions	setMaxBatchSize(int maxBatchSize)
SqlServerReplicationOptions	setMaxConcurrentDispatch(int maxConcurrentDispatch)
SqlServerReplicationOptions	setPassword(String password)
SqlServerReplicationOptions	setPasswordEnv(String passwordEnv)
SqlServerReplicationOptions	setPollIntervalMs(long pollIntervalMs)
SqlServerReplicationOptions	setPort(Integer port)
SqlServerReplicationOptions	setPreflightEnabled(boolean preflightEnabled)
SqlServerReplicationOptions	setPreflightMaxWaitMs(long preflightMaxWaitMs)
SqlServerReplicationOptions	setPreflightMode(String preflightMode)
SqlServerReplicationOptions	setPreflightRetryIntervalMs(long preflightRetryIntervalMs)
SqlServerReplicationOptions	setRetryPolicy(dev.henneberger.vertx.replication.core.RetryPolicy retryPolicy)
SqlServerReplicationOptions	setSsl(Boolean ssl)
SqlServerReplicationOptions	setUser(String user)
SqlServerReplicationOptions	setValueNormalizationMode(String valueNormalizationMode)
SqlServerReplicationOptions	setValueNormalizer(dev.henneberger.vertx.replication.core.ValueNormalizer valueNormalizer)
io.vertx.core.json.JsonObject	toJson()
dev.henneberger.vertx.replication.core.ValueNormalizationMode	valueNormalizationMode()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_HOST

public static final String DEFAULT_HOST

See Also:

• Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

• Constant Field Values

Constructor Details

SqlServerReplicationOptions

public SqlServerReplicationOptions()

SqlServerReplicationOptions

public SqlServerReplicationOptions(io.vertx.core.json.JsonObject json)

SqlServerReplicationOptions

public SqlServerReplicationOptions(SqlServerReplicationOptions other)

Method Details

getHost

public String getHost()

setHost

public SqlServerReplicationOptions setHost(String host)

getPort

public Integer getPort()

setPort

public SqlServerReplicationOptions setPort(Integer port)

getDatabase

public String getDatabase()

setDatabase

public SqlServerReplicationOptions setDatabase(String database)

getUser

public String getUser()

setUser

public SqlServerReplicationOptions setUser(String user)

getPassword

public String getPassword()

setPassword

public SqlServerReplicationOptions setPassword(String password)

getPasswordEnv

public String getPasswordEnv()

setPasswordEnv

public SqlServerReplicationOptions setPasswordEnv(String passwordEnv)

getSsl

public Boolean getSsl()

setSsl

public SqlServerReplicationOptions setSsl(Boolean ssl)

getCaptureInstance

public String getCaptureInstance()

setCaptureInstance

public SqlServerReplicationOptions setCaptureInstance(String captureInstance)

getPollIntervalMs

public long getPollIntervalMs()

setPollIntervalMs

public SqlServerReplicationOptions setPollIntervalMs(long pollIntervalMs)

getMaxBatchSize

public int getMaxBatchSize()

setMaxBatchSize

public SqlServerReplicationOptions setMaxBatchSize(int maxBatchSize)

getRetryPolicy

public dev.henneberger.vertx.replication.core.RetryPolicy getRetryPolicy()

setRetryPolicy

public SqlServerReplicationOptions setRetryPolicy(dev.henneberger.vertx.replication.core.RetryPolicy retryPolicy)

isPreflightEnabled

public boolean isPreflightEnabled()

setPreflightEnabled

public SqlServerReplicationOptions setPreflightEnabled(boolean preflightEnabled)

getPreflightMode

public String getPreflightMode()

setPreflightMode

public SqlServerReplicationOptions setPreflightMode(String preflightMode)

getPreflightMaxWaitMs

public long getPreflightMaxWaitMs()

setPreflightMaxWaitMs

public SqlServerReplicationOptions setPreflightMaxWaitMs(long preflightMaxWaitMs)

getPreflightRetryIntervalMs

public long getPreflightRetryIntervalMs()

setPreflightRetryIntervalMs

public SqlServerReplicationOptions setPreflightRetryIntervalMs(long preflightRetryIntervalMs)

isAutoStart

public boolean isAutoStart()

setAutoStart

public SqlServerReplicationOptions setAutoStart(boolean autoStart)

getMaxConcurrentDispatch

public int getMaxConcurrentDispatch()

setMaxConcurrentDispatch

public SqlServerReplicationOptions setMaxConcurrentDispatch(int maxConcurrentDispatch)

getValueNormalizationMode

public String getValueNormalizationMode()

setValueNormalizationMode

public SqlServerReplicationOptions setValueNormalizationMode(String valueNormalizationMode)

valueNormalizationMode

public dev.henneberger.vertx.replication.core.ValueNormalizationMode valueNormalizationMode()

getValueNormalizer

public dev.henneberger.vertx.replication.core.ValueNormalizer getValueNormalizer()

setValueNormalizer

public SqlServerReplicationOptions setValueNormalizer(dev.henneberger.vertx.replication.core.ValueNormalizer valueNormalizer)

getLsnStore

public dev.henneberger.vertx.replication.core.LsnStore getLsnStore()

setLsnStore

public SqlServerReplicationOptions setLsnStore(dev.henneberger.vertx.replication.core.LsnStore lsnStore)

toJson

public io.vertx.core.json.JsonObject toJson()

merge

public SqlServerReplicationOptions merge(io.vertx.core.json.JsonObject other)