org.corfudb.universe.node.client

Interface CorfuClient

All Superinterfaces:

Node

All Known Implementing Classes:

LocalCorfuClient

public interface CorfuClient
extends Node

Represent a Corfu client implementation of Node.

Nested Class Summary

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

Node.NodeParams<T>, Node.NodeType

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
Layout	getLayout() See LayoutView.getLayout()
ManagementView	getManagementView() See CorfuRuntime#getManagementView()
ObjectsView	getObjectsView() See CorfuRuntime#getObjectsView()
ClientParams	getParams()
CorfuRuntime	getRuntime() See CorfuRuntime()
void	invalidateLayout() See CorfuRuntime.invalidateLayout()
void	shutdown()
default void	systemDownHandler() A handler which is invoked at any point when the Corfu client attempts to make an RPC request to the Corfu cluster but is unable to complete.

Methods inherited from interface org.corfudb.universe.node.Node

deploy, destroy, getStress, kill, stop

Method Detail

getParams

ClientParams getParams()

Specified by:

getParams in interface Node

createDefaultCorfuTable

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

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

Parameters:

streamName - stream name of the table

Returns:

CorfuTable object created by runtime

connect

void connect()

See CorfuRuntime.connect()

getRuntime

CorfuRuntime getRuntime()

See CorfuRuntime()

getLayout

Layout getLayout()

See LayoutView.getLayout()

getManagementView

ManagementView getManagementView()

See CorfuRuntime#getManagementView()

getObjectsView

ObjectsView getObjectsView()

See CorfuRuntime#getObjectsView()

invalidateLayout

void invalidateLayout()

See CorfuRuntime.invalidateLayout()

systemDownHandler

default void systemDownHandler()

A handler which is invoked at any point when the Corfu client attempts to make an RPC request to the Corfu cluster but is unable to complete. This method can be helpful in tests where the it is needed to assert that the cluster is unavailable

shutdown

void shutdown()