RedisTracingFilter

gistfile1.txt

private class RedisTracingFilter extends SimpleFilter[Command, Reply] {
  override def apply(command: Command, service: Service[Command, Reply]) = Trace.unwind {
    Trace.recordRpcname("redis", command.command)
    Trace.record(Annotation.ClientSend())
    service(command) map { response =>
      Trace.record(Annotation.ClientRecv())
      response
    }
  }
}