(rpcType string)
| 156 | } |
| 157 | |
| 158 | func (as *accumulatedStats) startRPC(rpcType string) { |
| 159 | as.mu.Lock() |
| 160 | defer as.mu.Unlock() |
| 161 | as.numRPCsStartedByMethod[convertRPCName(rpcType)]++ |
| 162 | } |
| 163 | |
| 164 | func (as *accumulatedStats) finishRPC(rpcType string, err error) { |
| 165 | as.mu.Lock() |
no test coverage detected