Система мониторинга для кластера Akka

Очень сложно отслеживать состояния всех участников кластера Akka. Я искал в Интернете хорошую систему для мониторинга кластерной системы Akka. Однако результаты, скорее всего, были системами для мониторинга статистики JVM. Мне любопытно, есть ли система, которую я могу использовать для отслеживания статистики ниже:

  1. Каковы активные участники, их состояния и все другие атрибуты ... например, время подключения, роль, путь, хост и т. Д.

  2. Статус всех активных сегментов сегментов и их сегментов.

  3. Сообщения, буферизованные в Akka (ожидающие сообщения)

  4. Почтовый ящик мертвых писем

  5. Статус координаторов


akka akka-cluster
person Yifei    schedule 11.08.2015    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Вы можете просто попросить некоторого наблюдающего актера отправлять сообщения актерам, состояние которых вы хотите видеть, чтобы они отправили сообщение этому наблюдающему актеру с моментальным снимком их состояния.

Вы также можете использовать агентов, но я не думаю, что они распространяются.

Если вы искали какую-то общую структуру или что-то для этого, я бы предложил попытаться связать часть этого поведения с чертой, я действительно не знаю, что это нужно, потому что это зависит от того, как вы видите, как это поведение работает. , если все сообщения, отправленные обратно наблюдателю, могут относиться к одному и тому же классу case или нет, и т. д.

person Derrops    schedule 18.08.2015

arrow_upward
0
arrow_downward

Kamon.io может собирать матрицы по вашему желанию.
для instance:

val myHistogram = Kamon.metrics.histogram("my-histogram")
myHistogram.record(42)
myHistogram.record(43)
myHistogram.record(44)

val myCounter = Kamon.metrics.counter("my-counter")
myCounter.increment()
myCounter.increment(17)

val myMMCounter = Kamon.metrics.minMaxCounter("my-mm-counter", refreshInterval = 500 milliseconds)
myMMCounter.increment()
myMMCounter.decrement()

val myTaggedHistogram = Kamon.metrics.histogram("my-tagged-histogram", tags = Map("algorithm" -> "X"))
myTaggedHistogram.record(700L)
myTaggedHistogram.record(800L)

Кроме того, Kamon.io поддерживает несколько бэкэндов в качестве хранилища данных этих метрик.

person turutosiya    schedule 19.08.2015