Package org.apache.hadoop.ozone.container.replication

Class ReplicationServer.ReplicationConfig

java.lang.Object

org.apache.hadoop.ozone.container.replication.ReplicationServer.ReplicationConfig

Enclosing class:

ReplicationServer

public static final class ReplicationServer.ReplicationConfig
extends Object

Replication-related configuration.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PREFIX
static final String	QUEUE_LIMIT
static final int	REPLICATION_MAX_STREAMS_DEFAULT
static final String	REPLICATION_STREAMS_LIMIT_KEY
static final String	STREAMS_LIMIT_KEY

Constructor Summary

Constructors

Constructor	Description
ReplicationConfig()

Method Summary

Modifier and Type	Method	Description
double	getOutOfServiceFactor()
int	getPort()
int	getReplicationMaxStreams()
int	getReplicationQueueLimit()
int	scaleOutOfServiceLimit(int original)
ReplicationServer.ReplicationConfig	setPort(int portParam)
void	setReplicationMaxStreams(int replicationMaxStreams)
void	setReplicationQueueLimit(int limit)
void	validate()

Methods inherited from class java.lang.Object

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

Field Details

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

STREAMS_LIMIT_KEY

public static final String STREAMS_LIMIT_KEY

See Also:

• Constant Field Values

QUEUE_LIMIT

public static final String QUEUE_LIMIT

See Also:

• Constant Field Values

REPLICATION_STREAMS_LIMIT_KEY

public static final String REPLICATION_STREAMS_LIMIT_KEY

See Also:

• Constant Field Values

REPLICATION_MAX_STREAMS_DEFAULT

public static final int REPLICATION_MAX_STREAMS_DEFAULT

See Also:

• Constant Field Values

Constructor Details

ReplicationConfig

public ReplicationConfig()

Method Details

getOutOfServiceFactor

public double getOutOfServiceFactor()

scaleOutOfServiceLimit

public int scaleOutOfServiceLimit(int original)

getPort

public int getPort()

setPort

public ReplicationServer.ReplicationConfig setPort(int portParam)

getReplicationMaxStreams

public int getReplicationMaxStreams()

setReplicationMaxStreams

public void setReplicationMaxStreams(int replicationMaxStreams)

getReplicationQueueLimit

public int getReplicationQueueLimit()

setReplicationQueueLimit

public void setReplicationQueueLimit(int limit)

validate

public void validate()