org.corfudb.universe.node.client

Class LocalCorfuClient

java.lang.Object

org.corfudb.universe.node.client.LocalCorfuClient

All Implemented Interfaces:

CorfuClient, Node

public class LocalCorfuClient
extends Object
implements CorfuClient

Provides Corfu client (utility class) used in the local machine (in current process) which is basically a wrapper of CorfuRuntime.

Nested Class Summary

Nested classes/interfaces inherited from interface org.corfudb.universe.node.Node

Node.NodeParams<T>, Node.NodeType

Constructor Summary

Constructors

Constructor and Description
LocalCorfuClient(ClientParams params, com.google.common.collect.ImmutableSortedSet<String> serverEndpoints)

Method Summary

Modifier and Type	Method and Description
void	connect() See CorfuRuntime.connect()
<K,V> CorfuTable<K,V>	createDefaultCorfuTable(String streamName) Create a default CorfuTable object for data-path verification in scenario tests
LocalCorfuClient	deploy() Connect corfu runtime to the server
void	destroy() Shutdown corfu runtime
Layout	getLayout() See LayoutView.getLayout()
ManagementView	getManagementView() See CorfuRuntime#getManagementView()
ObjectsView	getObjectsView() See CorfuRuntime#getObjectsView()
CorfuRuntime	getRuntime() See CorfuRuntime()
Stress	getStress()
void	invalidateLayout() See CorfuRuntime.invalidateLayout()
void	kill() Shutdown corfu runtime
void	shutdown()
void	stop(Duration timeout) Shutdown corfu runtime

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.node.client.CorfuClient

getParams, systemDownHandler

Constructor Detail

LocalCorfuClient

public LocalCorfuClient(ClientParams params,
                        com.google.common.collect.ImmutableSortedSet<String> serverEndpoints)

Method Detail

deploy

public LocalCorfuClient deploy()

Connect corfu runtime to the server

Specified by:

deploy in interface Node

Returns:

stop

public void stop(Duration timeout)

Shutdown corfu runtime

Specified by:

stop in interface Node

Parameters:

timeout - a limit within which the method attempts to gracefully stop the client (not used for a client).

kill

public void kill()

Shutdown corfu runtime

Specified by:

kill in interface Node

destroy

public void destroy()

Shutdown corfu runtime

Specified by:

destroy in interface Node

getStress

public Stress getStress()

Specified by:

getStress in interface Node

createDefaultCorfuTable

public <K,V> CorfuTable<K,V> createDefaultCorfuTable(String streamName)

Description copied from interface: CorfuClient

Create a default CorfuTable object for data-path verification in scenario tests

Specified by:

createDefaultCorfuTable in interface CorfuClient

Parameters:

streamName - stream name of the table

Returns:

CorfuTable object created by runtime

connect

public void connect()

Description copied from interface: CorfuClient

See CorfuRuntime.connect()

Specified by:

connect in interface CorfuClient

getRuntime

public CorfuRuntime getRuntime()

Description copied from interface: CorfuClient

See CorfuRuntime()

Specified by:

getRuntime in interface CorfuClient

getLayout

public Layout getLayout()

Description copied from interface: CorfuClient

See LayoutView.getLayout()

Specified by:

getLayout in interface CorfuClient

getObjectsView

public ObjectsView getObjectsView()

Description copied from interface: CorfuClient

See CorfuRuntime#getObjectsView()

Specified by:

getObjectsView in interface CorfuClient

getManagementView

public ManagementView getManagementView()

Description copied from interface: CorfuClient

See CorfuRuntime#getManagementView()

Specified by:

getManagementView in interface CorfuClient

invalidateLayout

public void invalidateLayout()

Description copied from interface: CorfuClient

See CorfuRuntime.invalidateLayout()

Specified by:

invalidateLayout in interface CorfuClient

shutdown

public void shutdown()

Specified by:

shutdown in interface CorfuClient