in atlas-webapi/src/main/scala/com/netflix/atlas/webapi/TagsApi.scala [61:81]
private def handleReq(path: Option[String]): Route = {
get {
extractRequestContext { ctx =>
val req = toRequest(ctx, path)
val limit = req.limit
_ =>
ask(dbRef, req.toDbRequest)(60.seconds).map {
case TagListResponse(vs) if req.useText => asText(tagString(vs), offsetTag(limit, vs))
case KeyListResponse(vs) if req.useText =>
asText(vs.mkString("\n"), offsetString(limit, vs))
case ValueListResponse(vs) if req.useText =>
asText(vs.mkString("\n"), offsetString(limit, vs))
case TagListResponse(vs) if req.useJson => asJson(vs, offsetTag(limit, vs))
case KeyListResponse(vs) if req.useJson => asJson(vs, offsetString(limit, vs))
case ValueListResponse(vs) if req.useJson => asJson(vs, offsetString(limit, vs))
case Failure(t) => throw t
case v => throw new MatchError(v)
}
}
}
}