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 String	IMAGE_USER
static String	INFINISPAN_SERVER_HOME
static String	JDK_BASE_IMAGE_NAME
static int	JMX_PORT

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

BASE_DN, configuration, DEFAULT_CLUSTERED_INFINISPAN_CONFIG_FILE_NAME, KEY_ALGORITHM, KEY_PASSWORD, KEY_SIGNATURE_ALGORITHM, KEYSTORE_TYPE, TEST_HOST_ADDRESS, testHostAddress

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ContainerInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
InfinispanGenericContainer	getContainer(int i)
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 name, File rootDir, File configurationFile)
protected void	stop()
void	stop(int server)	Gracefully stops a running server

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

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

Methods inherited from class java.lang.Object

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

Field Detail

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

Constructor Detail

ContainerInfinispanServerDriver

protected ContainerInfinispanServerDriver(InfinispanServerTestConfiguration configuration)

Method Detail

start

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

Specified by:

start in class AbstractInfinispanServerDriver

getContainer

public InfinispanGenericContainer getContainer(int i)

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