Package org.infinispan.server.test.core

Class ContainerInfinispanServerDriver

java.lang.Object

org.infinispan.server.test.core.AbstractInfinispanServerDriver

org.infinispan.server.test.core.ContainerInfinispanServerDriver

All Implemented Interfaces:

InfinispanServerDriver

public class ContainerInfinispanServerDriver
extends AbstractInfinispanServerDriver

Since:

10.0

Author:

Tristan Tarrant <tristan@infinispan.org>

Field Summary

Fields

Modifier and Type	Field	Description
static final Integer[]	EXPOSED_PORTS
static final String	IMAGE_USER
static final String	INFINISPAN_SERVER_HOME
static final String	JDK_BASE_IMAGE_NAME
static final int	JMX_PORT
static final String	SNAPSHOT_IMAGE

Fields inherited from class org.infinispan.server.test.core.AbstractInfinispanServerDriver

BASE_DN, configuration, DEFAULT_CLUSTERED_INFINISPAN_CONFIG_FILE_NAME, DEFAULT_SERVER_CONFIG, DEFAULT_SERVER_DATA, DEFAULT_SERVER_LIB, DEFAULT_SERVER_LOG, INFINISPAN_CLUSTER_NAME, INFINISPAN_CLUSTER_STACK, INFINISPAN_SERVER_CONFIG_PATH, INFINISPAN_SERVER_ROOT_PATH, JOIN_TIMEOUT, KEY_ALGORITHM, KEY_PASSWORD, KEY_SIGNATURE_ALGORITHM, TEST_HOST_ADDRESS, testHostAddress

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ContainerInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
static void	cleanup()
MBeanServerConnection	getJmxConnection(int server)	Returns a MBeanServerConnection to the specified server
InetAddress	getServerAddress(int server)	Returns an InetAddress that points to a specific server.
InetSocketAddress	getServerSocket(int server, int port)	Returns an InetSocketAddress for connecting to a specific port on a specific server.
int	getTimeout()	Returns the amount of time in seconds that we should wait for a server start/stop operation.
boolean	isRunning(int server)	Determines whether a specific server is running as part of a server configuration
void	kill(int server)	Forcefully stops a server.
void	pause(int server)	Pauses the server.
void	restart(int server)	Restarts a previously stopped server.
void	restartCluster()	Restarts all of the nodes
void	resume(int server)	Resumes a paused server.
protected void	start(String fqcn, File rootDir, File configurationFile)
protected void	stop()
void	stop(int server)	Gracefully stops a running server
String	syncFilesFromServer(int server, String path)	Synchronizes files from the server to the local filesystem
String	syncFilesToServer(int server, String path)

Methods inherited from class org.infinispan.server.test.core.AbstractInfinispanServerDriver

applyKeyStore, applyKeyStore, applyKeyStore, applyKeyStore, applyTrustStore, applyTrustStore, applyTrustStore, applyTrustStore, copyArtifactsToUserLibDir, createKeyStores, createRemoteCacheManager, createSelfSignedCertificate, createServerHierarchy, createServerHierarchy, createSignedCertificate, createUserFile, debugJvmOption, dn, getCertificateFile, getConfDir, getConfiguration, getName, getRootDir, getStatus, prepare, serverRoot, start, stop

Methods inherited from class java.lang.Object

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

Field Details

INFINISPAN_SERVER_HOME

public static final String INFINISPAN_SERVER_HOME

See Also:

• Constant Field Values

JMX_PORT

public static final int JMX_PORT

See Also:

• Constant Field Values

JDK_BASE_IMAGE_NAME

public static final String JDK_BASE_IMAGE_NAME

See Also:

• Constant Field Values

IMAGE_USER

public static final String IMAGE_USER

See Also:

• Constant Field Values

EXPOSED_PORTS

public static final Integer[] EXPOSED_PORTS

SNAPSHOT_IMAGE

public static final String SNAPSHOT_IMAGE

See Also:

• Constant Field Values

Constructor Details

ContainerInfinispanServerDriver

protected ContainerInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Details

cleanup

public static void cleanup()

start

protected void start(String fqcn,
 File rootDir,
 File configurationFile)

Specified by:

start in class AbstractInfinispanServerDriver

stop

protected void stop()

Specified by:

stop in class AbstractInfinispanServerDriver

isRunning

public boolean isRunning(int server)

Description copied from interface: InfinispanServerDriver

Determines whether a specific server is running as part of a server configuration

Parameters:

server - the

Returns:

true if the server is running, false otherwise

getServerSocket

public InetSocketAddress getServerSocket(int server,
 int port)

Description copied from interface: InfinispanServerDriver

Returns an InetSocketAddress for connecting to a specific port on a specific server. The implementation will need to provide a specific mapping (e.g. port offset).

Parameters:

server - the index of the server

port - the service port

Returns:

an unresolved InetSocketAddress pointing to the actual running service

getServerAddress

public InetAddress getServerAddress(int server)

Description copied from interface: InfinispanServerDriver

Returns an InetAddress that points to a specific server.

Parameters:

server - the index of the server

Returns:

an InetAddress pointing to the server's address

pause

public void pause(int server)

Description copied from class: AbstractInfinispanServerDriver

Pauses the server. Equivalent to kill -SIGSTOP

Specified by:

pause in interface InfinispanServerDriver

Overrides:

pause in class AbstractInfinispanServerDriver

Parameters:

server - the index of the server

resume

public void resume(int server)

Description copied from interface: InfinispanServerDriver

Resumes a paused server. Equivalent to kill -SIGCONT

Parameters:

server - the index of the server

stop

public void stop(int server)

Description copied from interface: InfinispanServerDriver

Gracefully stops a running server

Parameters:

server - the index of the server

kill

public void kill(int server)

Description copied from interface: InfinispanServerDriver

Forcefully stops a server. Equivalent to kill -SIGKILL

Parameters:

server - the index of the server

restart

public void restart(int server)

Description copied from interface: InfinispanServerDriver

Restarts a previously stopped server.

Parameters:

server - the index of the server

restartCluster

public void restartCluster()

Description copied from interface: InfinispanServerDriver

Restarts all of the nodes

getJmxConnection

public MBeanServerConnection getJmxConnection(int server)

Description copied from interface: InfinispanServerDriver

Returns a MBeanServerConnection to the specified server

Parameters:

server - the index of the server

getTimeout

public int getTimeout()

Description copied from interface: InfinispanServerDriver

Returns the amount of time in seconds that we should wait for a server start/stop operation. This may vary depending on the type of driver (embedded, container)

Returns:

the number of seconds after which a server start/stop is considered to timeout

syncFilesFromServer

public String syncFilesFromServer(int server,
 String path)

Description copied from interface: InfinispanServerDriver

Synchronizes files from the server to the local filesystem

Parameters:

server - the server

path - if relative, the path relative to the server root, otherwise an absolute path

Returns:

the path where the data has been synced to

syncFilesToServer

public String syncFilesToServer(int server,
 String path)