public class ReplicaConfig
extends java.lang.Object
KetchReplica
.Modifier and Type | Class and Description |
---|---|
(package private) static class |
ReplicaConfig.UnitMap |
Modifier and Type | Field and Description |
---|---|
private KetchReplica.CommitMethod |
commitMethod |
private KetchReplica.CommitSpeed |
commitSpeed |
private long |
maxRetry |
private long |
minRetry |
private KetchReplica.Participation |
participation |
Constructor and Description |
---|
ReplicaConfig() |
Modifier and Type | Method and Description |
---|---|
ReplicaConfig |
fromConfig(Config cfg,
java.lang.String name)
Update the configuration from a config block.
|
KetchReplica.CommitMethod |
getCommitMethod()
Get how Ketch should apply committed changes.
|
KetchReplica.CommitSpeed |
getCommitSpeed()
Get how quickly should Ketch commit.
|
long |
getMaxRetry(java.util.concurrent.TimeUnit unit)
Returns the maximum wait delay before retrying a failure.
|
private static long |
getMillis(Config cfg,
java.lang.String name,
java.lang.String key,
long defaultValue) |
long |
getMinRetry(java.util.concurrent.TimeUnit unit)
Returns the minimum wait delay before retrying a failure.
|
KetchReplica.Participation |
getParticipation()
Get participation of the replica in the system.
|
static ReplicaConfig |
newFromConfig(Config cfg,
java.lang.String name)
Read a configuration from a config block.
|
private KetchReplica.Participation participation
private KetchReplica.CommitMethod commitMethod
private KetchReplica.CommitSpeed commitSpeed
private long minRetry
private long maxRetry
public static ReplicaConfig newFromConfig(Config cfg, java.lang.String name)
cfg
- configuration to read.name
- of the replica being configured.name
.public KetchReplica.Participation getParticipation()
public KetchReplica.CommitMethod getCommitMethod()
public KetchReplica.CommitSpeed getCommitSpeed()
public long getMinRetry(java.util.concurrent.TimeUnit unit)
unit
- to get retry delay in.public long getMaxRetry(java.util.concurrent.TimeUnit unit)
unit
- to get retry delay in.public ReplicaConfig fromConfig(Config cfg, java.lang.String name)
cfg
- configuration to read.name
- of the replica being configured.this
private static long getMillis(Config cfg, java.lang.String name, java.lang.String key, long defaultValue)