org.corfudb.universe.group.cluster

Class AbstractCorfuCluster<P extends CorfuClusterParams,U extends UniverseParams>

java.lang.Object

org.corfudb.universe.group.cluster.AbstractCorfuCluster<P,U>

All Implemented Interfaces:

Cluster, CorfuCluster, Group

Direct Known Subclasses:

DockerCorfuCluster, VmCorfuCluster

public abstract class AbstractCorfuCluster<P extends CorfuClusterParams,U extends UniverseParams>
extends Object
implements CorfuCluster

Nested Class Summary

Nested classes/interfaces inherited from interface org.corfudb.universe.group.Group

Group.GroupParams

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentNavigableMap<String,CorfuServer>	nodes
protected P	params
protected U	universeParams

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractCorfuCluster(P params, U universeParams)

Method Summary

Modifier and Type	Method and Description
Node	add(Node.NodeParams nodeParams)
protected abstract CorfuServer	buildCorfuServer(CorfuServerParams nodeParams)
AbstractCorfuCluster<P,U>	deploy() Deploys a Group, including the following steps: a) Deploy the Corfu nodes b) Bootstrap all the nodes to form a cluster
void	destroy() Destroy the Group immediately by destroying all the Node-s of the group.
protected abstract com.google.common.collect.ImmutableSortedSet<String>	getClusterLayoutServers()
LocalCorfuClient	getLocalCorfuClient() Provides a corfu client running on local machine
<T extends Node> T	getNode(String nodeNameSuffix)
void	kill() Attempt to kills all the nodes in arbitrary order.
<T extends Node> com.google.common.collect.ImmutableSortedMap<String,T>	nodes() Provide the nodes that the Group is composed of.
void	stop(Duration timeout) Stop the cluster

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.universe.group.cluster.CorfuCluster

getFirstServer, getServerByIndex

Methods inherited from interface org.corfudb.universe.group.cluster.Cluster

bootstrap

Methods inherited from interface org.corfudb.universe.group.Group

getParams

Field Detail

nodes

protected final ConcurrentNavigableMap<String,CorfuServer> nodes

params

@NonNull
protected final P extends CorfuClusterParams params

universeParams

@NonNull
protected final U extends UniverseParams universeParams

Constructor Detail

AbstractCorfuCluster

protected AbstractCorfuCluster(P params,
                               U universeParams)

Method Detail

deploy

public AbstractCorfuCluster<P,U> deploy()

Deploys a Group, including the following steps: a) Deploy the Corfu nodes b) Bootstrap all the nodes to form a cluster

Specified by:

deploy in interface Group

Returns:

an instance of AbstractCorfuCluster

buildCorfuServer

protected abstract CorfuServer buildCorfuServer(CorfuServerParams nodeParams)

stop

public void stop(Duration timeout)

Stop the cluster

Specified by:

stop in interface Group

Parameters:

timeout - allowed time to gracefully stop the Group

kill

public void kill()

Attempt to kills all the nodes in arbitrary order.

Specified by:

kill in interface Group

destroy

public void destroy()

Description copied from interface: Group

Destroy the Group immediately by destroying all the Node-s of the group. Destroy - means kill and clean up the node directory which contains the application itself and could contain config files, db files and so on.

Specified by:

destroy in interface Group

add

public Node add(Node.NodeParams nodeParams)

Specified by:

add in interface Group

getNode

public <T extends Node> T getNode(String nodeNameSuffix)

Specified by:

getNode in interface Group

nodes

public <T extends Node> com.google.common.collect.ImmutableSortedMap<String,T> nodes()

Description copied from interface: Group

Provide the nodes that the Group is composed of.

Specified by:

nodes in interface Group

Returns:

an ImmutableList of Nodes.

getLocalCorfuClient

public LocalCorfuClient getLocalCorfuClient()

Description copied from interface: CorfuCluster

Provides a corfu client running on local machine

Specified by:

getLocalCorfuClient in interface CorfuCluster

Returns:

local corfu client

getClusterLayoutServers

protected abstract com.google.common.collect.ImmutableSortedSet<String> getClusterLayoutServers()