Как получить метрику для шины коллектора в контексте aleph

Question

Учитывая шину, созданную с помощью Aleph/Manifold, как вы можете измерить интересные метрики, такие как пропускная способность, задержка, количество ошибок и тайм-ауты?

(manifold.bus/event-bus (fn []
                            (s/stream 100 )))

Answer 1

Алеф не имеет встроенного мониторинга.

Вы можете создать его самостоятельно, либо в своей функции-обработчике (возможно, используя атом), либо сразу используя Netty. E сть :bootstrap-transform аргумент, который позволяет вам создать Netty ChannelHandler,

Это должно позволить вам использовать существующие решения для мониторинга производительности Netty (эта страница может быть полезна).