Я изучаю асинхронную систему RPC в Твиттере, и мне важно использовать фильтр и сервис для логической задачи. Я прочитал статью https://twitter.github.io/finagle/guide/ServicesAndFilters.html и попробуйте написать простой код, чтобы он стал правдой,...

У меня есть конечная точка HTTP API, которую мне нужно постоянно проверять на наличие новых значений. К счастью, он поддерживает длительный опрос. Итак, идея состоит в том, что мне нужно реализовать «бесконечный цикл», в котором я делаю запрос, жду...

Я новичок в Finatra и scala. Мне нужно сохранить IP-адрес с другими данными в почтовом запросе. Я использую специальный класс case: case class MyRequest(name : String, email: String) Как я могу также получить remoteAddress в этом запросе? Заранее...

В finch мы можем определить маршрутизатор, параметры запроса, тело запроса следующим образом. case class Test(name: String, age: Int) val router: Endpoint[Test] = post("hello") { Ok(Test("name", 30)) } val requestBody: Endpoint[Test] =...

Я взаимодействую с веб-службой .Net. Согласно описанию службы, сервер ожидает тип base64Binary. Вот как я пытаюсь создать пакет SOAP: <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"...

Я хочу написать реализацию службы бережливости на Scala (используя Scrooge), но без использования Finagle, так как я не мог написать клиент ruby/python для серверов Finagle. Проблема в том, что со Скруджем служба, похоже, не реализует класс...

Netty, который используется в Finagle, использует конвейер «обработчиков» для последовательной обработки входящих и исходящих связанных данных. Примеры Netty и включенные библиотеки демонстрируют различные обработчики, используемые для таких вещей,...

Как я могу создать кластер сервера memcached и получить к нему доступ с помощью finagle. ct Похоже, что ServerSet с ZooKeeper можно использовать для построения кластера. Но у меня есть несколько вопросов. 1 Какой алгоритм раздачи ключа на...

Вот код для привязки параметра запроса к маршрутизатору. val testReader: Endpoint[Test] = Endpoint.derive[Test].fromParams val test: Endpoint[String] = post("test" ? testReader) { t : Test => { Created("OK") }} Я использую метод...

Я борюсь с повторными попытками клиента Finagle. По какой-то причине клиент не повторяет неудачные запросы в тесте, хотя я использую собственный классификатор, который должен помечать любой код ответа, отличный от 200, как RetryableFailure. Я...

Я работаю над системой микросервисов, реализованной на Scala с использованием Finagle и Thrift в качестве платформы. Так как есть несколько сервисов, которые какое-то время никто не трогал, мне нужно выяснить, используются ли они вообще (точнее,...

Я пытаюсь использовать библиотеку scala finch для создания API. У меня есть следующий простой код: package example import io.finch._ import com.twitter.finagle.Http object HelloWorld extends App { val api: Endpoint[String] = get("hello") {...

У меня возникла проблема при реализации IntegrationTest с Finatra на Scala. Я просто следую их официальным документам для ранней реализации, но я получил ошибку [error]...