клиента для сервиса N. Как я понял, изменились сигнатуры (ранее был RetryingFilter, сейчас RetryFilter) и появились дополнительные параметры для фильтра. Меня интересует, как теперь верно задавать политику ретрая, тк метод RetryPolicy.tries(10) - возвращает RetryPolicy[Try[Nothing]], а новая сигнатура политики для фильтра имеет вид:
val policy: RetryPolicy[(ThriftClientRequest, Try[Array[Byte]])] = ???
может кто-то сталкивался с такой проблемой? или же, как-то иначе организуют retry-паттрерн для клиента нужного вам микросервиса?
https://pastebin.com/bQGqwRhV как-то так (реальный код убран, оставнен скелет) ну и константы и тп заменено )
Обсуждают сегодня