twitter-finagle

2热度

2回答

我试图覆盖健康终点。我需要让它返回其他的东西，然后'OK'。如文档中所述，我应该使用Lifecycle.Warmup特性。无论 HttpMuxer.addHandler(Route("/health", new ReplyHandler("not OK\n"))) 也压倒一切的方法尚不帮助。下面的这段代码，也没有帮助。 HttpMuxer.addHandler( Route(

1热度

1回答

无法找到正确的SBT依赖

今天是我与芬奇的第一天。我无法找到正确的一套SBT依赖关系为finch和finagle。我已经尝试了所有的依赖关系，如图2图像

0热度

1回答

如何将请求参数指定为Json类型

我正在创建一个期望Json的Finch端点。 URL - LogBundles /龙JSON消息/过程我使用json4s库JSON解析如何指定身体类型JSON或如何传递LogBundles和过程之间的一个JSON值？我不能做body.as [case class]，因为我不会知道Json的确切结构。我只会在解析时寻找特定的键。代码 val bundleProcessEndpoint: E

0热度

1回答

Finagle光圈算法如何选择“非重叠”子集？

我一直在阅读关于Finagle并试图理解代码来弄清楚Aperture的子集选择是如何工作的。我看到ApertureLeastLoaded有一个“useDeterministicOrdering”和一个“EndpointFactory”，我猜应该是决定哪些客户端在子集中采用的关键点。在阅读Google SRE's book的“deterministic subsetting”部分时，我理解从客户

1热度

1回答

在Finagle中记录远程主机

我想在使用Finagle客户端时将被叫远程主机记录到STDOUT。但据我所知，这是不可能通过com.twitter.finagle.http.filter.LoggingFilter;其#format（例如见下文）方法无法访问实际的主机： request.remoteHost()返回0.0.0.0 request.remoteAddress()返回其基本上含有上述IP request.host()

0热度

1回答

Finch Hello World错误：Http不是com.twitter.finagle的成员

我正在尝试使用scala finch库来构建API。我有以下简单的代码： package example import io.finch._ import com.twitter.finagle.Http object HelloWorld extends App { val api: Endpoint[String] = get("hello") { Ok("Hello,

0热度

1回答

覆盖RootMonitor

我在Future.respond中运行了一些代码，由于一个错误，它会抛出一个NPE。问题是我的单元测试完全错过了它，并且都非常高兴地通过，因为NPE被RootMonitor吞噬了。所以，我的问题是，如果有任何方式来覆盖单元测试的RootMonitor行为导致测试失败而不是吞咽异常？我知道，我可以在响应中捕获异常，但这有点不好 - 如果我认为可能会有异常，我会首先解决它。这正是我希望我的测试能够

1热度

1回答

Finagle解决方案找不到方案

我创建了自己的finagle解析器，我想在我的scalaTest中测试它。但由于我的测试不提供META-INF /服务/ com.twitter.finagle.Resolver文件，当我运行客户端 Http.client.newService("myResolver!foo.com:/endpoint", "service") 我收到错误 com.twitter.finagle.Resolv

4热度

2回答

如何处理Finatra中的请求？

我有一个有put端点的服务。我希望能够访问url参数以及body。我该如何做到这一点。这是我的终点： put("/:customerNum") { foo: Foo => val custNum = ??? } 如何访问customerNum？

0热度

1回答

你能在SBT定义依赖别名

Recently的欺骗库取决于libthrift定制叉子"com.twitter" % "libthrift"开始。常规的是"org.apache.thrift" % "libthrift"。两者在同一个包中包含相同的类。虽然可以手动清理classpath中，它可能是，并不是每一个开发商会意识到在未来的 - 尤其是通过短暂的依赖关系。我们已经制定了内部SBT插件，我们所有的项目都在用，可用于共