def localAdjust()

in src/main/scala/com/twitter/iago/launcher/LocalMode.scala [117:135]

• 17 lines of code
• 1 McCabe index (conditional complexity)

  def localAdjust(feederFlags: Seq[Flag[_]], serverFlags: Seq[Flag[_]]): Unit = {
    missingFlagCheck(List(requestRateF, servicePortF))

    val localServerIface = Thrift.client.newServiceIface[ParrotServerService.ServiceIface](
      dest = servicePortF(),
      label = "local_feeder"
    )

    val setRate = new TimeoutFilter(10.seconds, DefaultTimer.twitter) andThen localServerIface.setRate
    Await.result(
      setRate(ParrotServerService.SetRate.Args(requestRateF()))
        .onSuccess { _ =>
          log.info(s"Adjusted rate [to ${requestRateF()}].")
        }
        .onFailure { e =>
          log.error(s"Failed to adjust rate [to ${requestRateF()}]:\n$e")
        }
    )
  }