но в среднем обычно есть Vector или Map Daemon

Там инфа о том, какое состояние бэкграундовых процессов

Можно положить Daemon \ zio.Fiber

И рядом Ref, куда живой процесс периодически будет складывать инфу

с таймстампом

И всё это собирать в хттп методе

Да, обычно не нужно явно мониторить. Но если реально надо, например, логгировать ситуации типа "уже 20 минут читаем", то в мире zio это можно сделать через комбинацию schedule и race. В кэтс, наверняка, тоже

Эт как например?

Ну я на коленке вот так придумал:

def withMonitoring[R, E, A](task: ZIO[R, E, A], tag: String, monitorInterval: Duration = 20.minutes): ZIO[R with Clock, E, A] = {
    zio.clock.nanoTime.flatMap(start => {
      val monitorOnce: ZIO[Clock, Nothing, Any] = zio.clock.nanoTime.flatMap(now =>
        UIO {
          val dur = Duration.fromNanos(now - start)
          logger.info(s"$tag is running for ${dur.render} so far")
        }
      )

      val runMonitoring = monitorOnce.delay(monitorInterval).forever
      task.raceFirst(runMonitoring)
    })
  }

если у тебя стримы бесконечные, то мб просто нужен супервайзинг стримов?

рестартануть весь сервис, если умер 1 стрим? F

А их там оч мало и это основной функционал сервиса.

Добрый день, есть ли тут те, кто пользуются дистейджем?

Не пойму, почему у меня приложение при интерапте нормально не завершается - пишет phase=late Going to shut down..., закрывает ресурсы, но после этого продолжает висеть.

Думал, может, я где-то у себя накосячил, но в примере
https://github.com/7mind/distage-example
работает также - после kill -s SIGINT pid приложение, судя по логам, начинает финализировать ресурсы но не завершается, пока явно еще и SIGKILL не отправишь.

с этим можно что-то сделать?

У ребят есть чатик в телеге https://t.me/izumi_ru

Хмм, повторил проблему в примере, пофиксим

https://scastie.scala-lang.org/FbwEuiaOQvKzB719844jaQ

Есть идеи, почему не работает вывод типов для второго примера?

У кого-нибудь ещё было такое? После обновления скала плагина поломалось всё, даже файлы в пакете прогрузить не может