Stats implements baker.Input
()
| 230 | |
| 231 | // Stats implements baker.Input |
| 232 | func (k *KCL) Stats() baker.InputStats { |
| 233 | bag := make(baker.MetricsBag) |
| 234 | bag.AddGauge("kcl.shards", float64(atomic.LoadInt64(&k.nshards))) |
| 235 | |
| 236 | return baker.InputStats{ |
| 237 | NumProcessedLines: atomic.LoadInt64(&k.nlines), |
| 238 | Metrics: bag, |
| 239 | } |
| 240 | } |
| 241 | |
| 242 | // FreeMem implements baker.Input |
| 243 | func (k *KCL) FreeMem(data *baker.Data) { |