()
| 242 | } |
| 243 | |
| 244 | func statsOption() output.ResponseOption { |
| 245 | if !statsFlag { |
| 246 | return func(*output.Response) {} |
| 247 | } |
| 248 | var requests int |
| 249 | var latency time.Duration |
| 250 | if sdkStats != nil { |
| 251 | requests = sdkStats.RequestCount() |
| 252 | latency = sdkStats.TotalLatency() |
| 253 | } |
| 254 | return output.WithMeta("stats", map[string]any{ |
| 255 | "requests": requests, |
| 256 | "latency_ms": latency.Milliseconds(), |
| 257 | }) |
| 258 | } |
| 259 | |
| 260 | // writeOK wraps writer.OK and always injects statsOption() so every command |
| 261 | // response includes request stats when --stats is set. |
no test coverage detected