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. |
||
|---|---|---|
| .. | ||
| filter.go | ||
| filter_test.go | ||
| makemetric.go | ||
| running_aggregator.go | ||
| running_aggregator_test.go | ||
| running_input.go | ||
| running_input_test.go | ||
| running_output.go | ||
| running_output_test.go | ||
| running_processor.go | ||
| running_processor_test.go | ||