org.apache.curator.test

Class InstanceSpec

java.lang.Object

org.apache.curator.test.InstanceSpec

public class InstanceSpec
extends Object

Abstracts one of the servers in the ensemble

Constructor Summary

Constructors

Constructor and Description
InstanceSpec(File dataDirectory, int port, int electionPort, int quorumPort, boolean deleteDataDirectoryOnClose, int serverId)
InstanceSpec(File dataDirectory, int port, int electionPort, int quorumPort, boolean deleteDataDirectoryOnClose, int serverId, int tickTime, int maxClientCnxns)
InstanceSpec(File dataDirectory, int port, int electionPort, int quorumPort, boolean deleteDataDirectoryOnClose, int serverId, int tickTime, int maxClientCnxns, Map<String,Object> customProperties)
InstanceSpec(File dataDirectory, int port, int electionPort, int quorumPort, boolean deleteDataDirectoryOnClose, int serverId, int tickTime, int maxClientCnxns, Map<String,Object> customProperties, String hostname)

Method Summary

Modifier and Type	Method and Description
boolean	deleteDataDirectoryOnClose()
boolean	equals(Object o)
String	getConnectString() Deprecated. use TestingServer.getConnectString() or TestingCluster.getConnectString() instead
Map<String,Object>	getCustomProperties()
File	getDataDirectory()
int	getElectionPort()
String	getHostname()
int	getMaxClientCnxns()
int	getPort()
int	getQuorumPort()
static int	getRandomPort()
int	getServerId()
int	getTickTime()
int	hashCode()
static InstanceSpec	newInstanceSpec()
static void	reset()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

InstanceSpec

public InstanceSpec(File dataDirectory,
                    int port,
                    int electionPort,
                    int quorumPort,
                    boolean deleteDataDirectoryOnClose,
                    int serverId)

Parameters:

dataDirectory - where to store data/logs/etc.

port - the port to listen on - each server in the ensemble must use a unique port

electionPort - the electionPort to listen on - each server in the ensemble must use a unique electionPort

quorumPort - the quorumPort to listen on - each server in the ensemble must use a unique quorumPort

deleteDataDirectoryOnClose - if true, the data directory will be deleted when TestingCluster.close() is called

serverId - the server ID for the instance

InstanceSpec

public InstanceSpec(File dataDirectory,
                    int port,
                    int electionPort,
                    int quorumPort,
                    boolean deleteDataDirectoryOnClose,
                    int serverId,
                    int tickTime,
                    int maxClientCnxns)

Parameters:

dataDirectory - where to store data/logs/etc.

port - the port to listen on - each server in the ensemble must use a unique port

electionPort - the electionPort to listen on - each server in the ensemble must use a unique electionPort

quorumPort - the quorumPort to listen on - each server in the ensemble must use a unique quorumPort

deleteDataDirectoryOnClose - if true, the data directory will be deleted when TestingCluster.close() is called

serverId - the server ID for the instance

tickTime - tickTime. Set -1 to used fault server configuration

maxClientCnxns - max number of client connections from the same IP. Set -1 to use default server configuration

InstanceSpec

public InstanceSpec(File dataDirectory,
                    int port,
                    int electionPort,
                    int quorumPort,
                    boolean deleteDataDirectoryOnClose,
                    int serverId,
                    int tickTime,
                    int maxClientCnxns,
                    Map<String,Object> customProperties)

Parameters:

dataDirectory - where to store data/logs/etc.

port - the port to listen on - each server in the ensemble must use a unique port

electionPort - the electionPort to listen on - each server in the ensemble must use a unique electionPort

quorumPort - the quorumPort to listen on - each server in the ensemble must use a unique quorumPort

deleteDataDirectoryOnClose - if true, the data directory will be deleted when TestingCluster.close() is called

serverId - the server ID for the instance

tickTime - tickTime. Set -1 to used fault server configuration

maxClientCnxns - max number of client connections from the same IP. Set -1 to use default server configuration

customProperties - other properties to be passed to the server

InstanceSpec

public InstanceSpec(File dataDirectory,
                    int port,
                    int electionPort,
                    int quorumPort,
                    boolean deleteDataDirectoryOnClose,
                    int serverId,
                    int tickTime,
                    int maxClientCnxns,
                    Map<String,Object> customProperties,
                    String hostname)

Parameters:

dataDirectory - where to store data/logs/etc.

port - the port to listen on - each server in the ensemble must use a unique port

electionPort - the electionPort to listen on - each server in the ensemble must use a unique electionPort

quorumPort - the quorumPort to listen on - each server in the ensemble must use a unique quorumPort

deleteDataDirectoryOnClose - if true, the data directory will be deleted when TestingCluster.close() is called

serverId - the server ID for the instance

tickTime - tickTime. Set -1 to used fault server configuration

maxClientCnxns - max number of client connections from the same IP. Set -1 to use default server configuration

customProperties - other properties to be passed to the server

hostname - Hostname or IP if the cluster is intending to be bounded into external interfaces

Method Detail

reset

public static void reset()

newInstanceSpec

public static InstanceSpec newInstanceSpec()

getRandomPort

public static int getRandomPort()

getServerId

public int getServerId()

getDataDirectory

public File getDataDirectory()

getPort

public int getPort()

getElectionPort

public int getElectionPort()

getQuorumPort

public int getQuorumPort()

getConnectString

@Deprecated
public String getConnectString()

Deprecated. use TestingServer.getConnectString() or TestingCluster.getConnectString() instead

getTickTime

public int getTickTime()

getMaxClientCnxns

public int getMaxClientCnxns()

deleteDataDirectoryOnClose

public boolean deleteDataDirectoryOnClose()

getCustomProperties

public Map<String,Object> getCustomProperties()

getHostname

public String getHostname()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object