public class IntegrationTestRpcClient
extends java.lang.Object
Constructor and Description |
---|
IntegrationTestRpcClient() |
Modifier and Type | Method and Description |
---|---|
protected AbstractRpcClient |
createRpcClient(Configuration conf,
boolean isSyncClient) |
void |
testRpcWithChaosMonkey(boolean isSyncClient) |
void |
testRpcWithChaosMonkeyWithAsyncClient() |
void |
testRpcWithChaosMonkeyWithSyncClient() |
void |
testRpcWithWriteThread() |
protected AbstractRpcClient createRpcClient(Configuration conf, boolean isSyncClient)
public void testRpcWithWriteThread() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testRpcWithChaosMonkeyWithSyncClient() throws java.lang.Throwable
java.lang.Throwable
public void testRpcWithChaosMonkeyWithAsyncClient() throws java.lang.Throwable
java.lang.Throwable
public void testRpcWithChaosMonkey(boolean isSyncClient) throws java.lang.Throwable
java.lang.Throwable