com.rpl.rama.test

Interface InProcessCluster

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, ClusterManagerBase

public interface InProcessCluster
extends ClusterManagerBase

Simulates a Rama cluster in a single process. Useful for unit testing modules or experimenting with Rama API. An InProcessCluster is used to manage modules and retrive depot, PState, and query topology clients.

See Also:

Testing documentation

Method Summary

Modifier and Type	Method and Description
static InProcessCluster	create() Creates an InProcessCluster
static InProcessCluster	create(java.util.List<java.lang.Class> serializations) Creates an InProcessCluster with the specified RamaCustomSerialization implementations registered for all launched modules
void	destroyModule(java.lang.String moduleName) Destroy a module
void	launchModule(RamaModule m, LaunchConfig config) Launch a module.
void	pauseMicrobatchTopology(java.lang.String moduleName, java.lang.String topologyName) Pauses the specified microbatch topology so it stops processing.
void	resumeMicrobatchTopology(java.lang.String moduleName, java.lang.String topologyName) Resumes a paused microbatch topology so it starts processing again.
void	updateModule(RamaModule m) Update a module to a new version.
void	updateModule(RamaModule m, UpdateOptions options) Update a module to a new version.
void	waitForMicrobatchProcessedCount(java.lang.String moduleName, java.lang.String topologyName, int count) Block until specified microbatch topology has finished processing at least the specified number of depot records.

Methods inherited from interface com.rpl.rama.cluster.ClusterManagerBase

clusterDepot, clusterPState, clusterQuery

Methods inherited from interface java.io.Closeable

close

Method Detail

launchModule

void launchModule(RamaModule m,
                  LaunchConfig config)

Launch a module. Blocks until module is running.

Parameters:

m - Module to launch

config - Parallelism config

updateModule

void updateModule(RamaModule m)

Update a module to a new version. Blocks until the update is complete.

Parameters:

m - Module to update. RamaModule.getModuleName() can be used in test contexts to define two different versions of the same module.

updateModule

void updateModule(RamaModule m,
                  UpdateOptions options)

Update a module to a new version. Blocks until the update is complete.

Parameters:

m - Module to update. RamaModule.getModuleName() can be used in test contexts to define two different versions of the same module.

options - Options for module update

destroyModule

void destroyModule(java.lang.String moduleName)

Destroy a module

Parameters:

moduleName - Name of module to destroy

waitForMicrobatchProcessedCount

void waitForMicrobatchProcessedCount(java.lang.String moduleName,
                                     java.lang.String topologyName,
                                     int count)

Block until specified microbatch topology has finished processing at least the specified number of depot records. If condition fails to be achieved within a timeout, an exception is thrown.

Parameters:

moduleName - Name of module

topologyName - Name of microbatch topology

count - Number of records

pauseMicrobatchTopology

void pauseMicrobatchTopology(java.lang.String moduleName,
                             java.lang.String topologyName)

Pauses the specified microbatch topology so it stops processing. Blocks until the currently running microbatch finishes. No-op if topology is already paused.

Parameters:

moduleName - Name of module

topologyName - Name of topology

resumeMicrobatchTopology

void resumeMicrobatchTopology(java.lang.String moduleName,
                              java.lang.String topologyName)

Resumes a paused microbatch topology so it starts processing again. No-op if topology is already active.

Parameters:

moduleName - Name of module

topologyName - Name of topology

create

static InProcessCluster create()

Creates an InProcessCluster

create

static InProcessCluster create(java.util.List<java.lang.Class> serializations)

Creates an InProcessCluster with the specified RamaCustomSerialization implementations registered for all launched modules