Method RecordProcessRecordsTime

input/kcl.go:386–389

(shard string, ms float64)

}

func (m *kclDatadogMetrics) RecordProcessRecordsTime(shard string, ms float64) {
	t := time.Duration(ms) * time.Millisecond
	m.metricsClient.DurationWithTags("process_records_time_milliseconds", t, []string{"shard:" + shard})
}