Мониторинг метрики размера почтового ящика действующих лиц с помощью kamon-akka 0.6.x

Я без проблем использовал версию 0.5.2 библиотеки kamon-akka, чтобы следить за своими актерами akka. Затем я обновил его до 0.6.3 и заметил, что некоторые статистические данные не были отправлены.

Когда я посмотрел на исходный код kamon, я увидел, что метрика размера почтового ящика не была отправлена ​​для маршрутизирующих акторов, работающих под маршрутизатором. Вместо этого метрики маршрутизатора, такие как routingTime, отправляются действующим субъектам. Тем не менее, я использую их в качестве рабочих, и мне нужно отслеживать размеры их почтовых ящиков.

Вот часть источника kamon, которая создает монитор Routee с RouterMetrics вместо ActorMetrics, который содержит метрику размера почтового ящика:

package akka.kamon.instrumentation
object ActorMonitor {
  ...

  def createRouteeMonitor(cellInfo: CellInfo): ActorMonitor = {
    def routerMetrics = Kamon.metrics.entity(RouterMetrics, cellInfo.entity)

    if (cellInfo.isTracked)
      new TrackedRoutee(cellInfo.entity, routerMetrics)
    else ActorMonitors.ContextPropagationOnly
  }

  ...
}

Я не уверен, что это ошибка, но как я могу решить эту проблему? Существуют ли какие-либо конфигурации или обходные решения, чтобы это исправить?

Заранее спасибо.

0 ответов

Другие вопросы по тегам