Looping the metrics back through the same channel could result in a deadlock, by using a new channel and locking the processor we can ensure that all stages can make continual progress. |
||
|---|---|---|
| .. | ||
| accumulator.go | ||
| accumulator_test.go | ||
| agent.go | ||
| agent_test.go | ||