Method IncrRecordsProcessed

input/kcl.go:369–371

(shard string, count int)

}

func (m *kclDatadogMetrics) IncrRecordsProcessed(shard string, count int) {
	m.metricsClient.DeltaCountWithTags("processed_records", int64(count), []string{"shard:" + shard})
}

func (m *kclDatadogMetrics) IncrBytesProcessed(shard string, count int64) {
	m.metricsClient.DeltaCountWithTags("processed_bytes", count, []string{"shard:" + shard})