(start startFunc, stop stopFunc, bf stats.Features, s *stats.Stats)
| 242 | type rpcCleanupFunc func() |
| 243 | |
| 244 | func unaryBenchmark(start startFunc, stop stopFunc, bf stats.Features, s *stats.Stats) { |
| 245 | caller, cleanup := makeFuncUnary(bf) |
| 246 | defer cleanup() |
| 247 | runBenchmark(caller, start, stop, bf, s, workloadsUnary) |
| 248 | } |
| 249 | |
| 250 | func streamBenchmark(start startFunc, stop stopFunc, bf stats.Features, s *stats.Stats) { |
| 251 | caller, cleanup := makeFuncStream(bf) |
no test coverage detected