From 8da57eb855500e9e19add1ebf27bd12fde9b02cb Mon Sep 17 00:00:00 2001 From: Noah Eisen Date: Thu, 1 Dec 2016 17:14:11 -0800 Subject: [PATCH] Add availible interop tests to stress client --- stress/client/main.go | 20 +++++++++++++++++++- 1 file changed, 19 insertions(+), 1 deletion(-) diff --git a/stress/client/main.go b/stress/client/main.go index 99e164b5..f86e397f 100644 --- a/stress/client/main.go +++ b/stress/client/main.go @@ -91,7 +91,13 @@ func parseTestCases(testCaseString string) []testCaseWithWeight { "large_unary", "client_streaming", "server_streaming", - "empty_stream": + "ping_pong", + "empty_stream", + "timeout_on_sleeping_server", + "cancel_after_begin", + "cancel_after_first_response", + "status_code_and_message", + "custom_metadata": default: panic(fmt.Sprintf("unknown test type: %s", testCase[0])) } @@ -231,8 +237,20 @@ func performRPCs(gauge *gauge, conn *grpc.ClientConn, selector *weightedRandomTe interop.DoClientStreaming(client) case "server_streaming": interop.DoServerStreaming(client) + case "ping_pong": + interop.DoPingPong(client) case "empty_stream": interop.DoEmptyStream(client) + case "timeout_on_sleeping_server": + interop.DoTimeoutOnSleepingServer(client) + case "cancel_after_begin": + interop.DoCancelAfterBegin(client) + case "cancel_after_first_response": + interop.DoCancelAfterFirstResponse(client) + case "status_code_and_message": + interop.DoStatusCodeAndMessage(client) + case "custom_metadata": + interop.DoCustomMetadata(client) } done <- true }()