Makes a UnaryCall gRPC request using the given BenchmarkServiceClient and request and response sizes.
(client testgrpc.BenchmarkServiceClient, reqSize, respSize int)
| 537 | // Makes a UnaryCall gRPC request using the given BenchmarkServiceClient and |
| 538 | // request and response sizes. |
| 539 | func unaryCaller(client testgrpc.BenchmarkServiceClient, reqSize, respSize int) { |
| 540 | if err := benchmark.DoUnaryCall(client, reqSize, respSize); err != nil { |
| 541 | logger.Fatalf("DoUnaryCall failed: %v", err) |
| 542 | } |
| 543 | } |
| 544 | |
| 545 | func streamCaller(stream testgrpc.BenchmarkService_StreamingCallClient, req any) { |
| 546 | if err := benchmark.DoStreamingRoundTripPreloaded(stream, req); err != nil { |
no test coverage detected