James Wilson 7ac88a7e84 Expose total messages sent to aggregator, too (#416) ...

* Expose total messages sent to aggregator so we can make better graphs with total dropped msgs

* cargo fmt

* use write to hopefully avoid some allocating

* add 'core' namespace to telemetry metrics for better future clarity

* cargo fmt

2021-09-30 12:21:37 +01:00

..

benches

Address feedback from Niklas

2021-08-11 16:59:11 +01:00

src

Expose total messages sent to aggregator, too (#416)

2021-09-30 12:21:37 +01:00

tests

Tidy up stale connections. (#406)

2021-09-21 15:49:42 +01:00

Cargo.toml

Avoid using flume::Receiver::into_stream() to avoid memory leaks until the issue is resolved upstream (#394)

2021-09-03 08:40:43 +01:00