Method IncrBytesProcessed

input/kcl.go:373–375

(shard string, count int64)

}

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

func (m *kclDatadogMetrics) MillisBehindLatest(shard string, ms float64) {
	m.metricsClient.GaugeWithTags("ms_behind_latest_milliseconds", ms, []string{"shard:" + shard})