(shard string, ms float64)
| 379 | } |
| 380 | |
| 381 | func (m *kclDatadogMetrics) RecordGetRecordsTime(shard string, ms float64) { |
| 382 | t := time.Duration(ms) * time.Millisecond |
| 383 | m.metricsClient.DurationWithTags("get_records_time_milliseconds", t, []string{"shard:" + shard}) |
| 384 | } |
| 385 | |
| 386 | func (m *kclDatadogMetrics) RecordProcessRecordsTime(shard string, ms float64) { |
| 387 | t := time.Duration(ms) * time.Millisecond |
nothing calls this directly
no test coverage detected