grpc
/
grpc-go
mirror of https://github.com/grpc/grpc-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1008 from ncteisen/stress_test_fix 

Add Available Interop Tests to Stress Client
This commit is contained in:
Noah Eisen 2016-12-02 10:43:27 -08:00 committed by GitHub
parent 417442a753 4203221fb9
commit 708a7f9f32
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
stress/client/main.go
View File

@ -91,7 +91,13 @@ func parseTestCases(testCaseString string) []testCaseWithWeight {
"large_unary", "large_unary",
"client_streaming", "client_streaming",
"server_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: default:
panic(fmt.Sprintf("unknown test type: %s", testCase[0])) 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) interop.DoClientStreaming(client)
case "server_streaming": case "server_streaming":
interop.DoServerStreaming(client) interop.DoServerStreaming(client)
case "ping_pong":
interop.DoPingPong(client)
case "empty_stream": case "empty_stream":
interop.DoEmptyStream(client) 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 done <- true
}() }()