in src/main/scala/com/twitter/iago/server/AutoStats.scala [81:94]
private[this] def toScribe(
scribe: Scribe.FutureIface,
category: String = "cuckoo_json",
pool: FuturePool = FuturePool.immediatePool
): Service[Sample, Unit] = Service.mk { sample =>
pool {
LogEntry(category, sample.toJson) :: Nil
}.flatMap {
scribe.log(_) map { _ =>
} onFailure {
lg.error(_, "scribe")
}
}
}