diagnostics

gistfile1.scala

trait Diagnostics[Data, Request] extends WebNode[Data, Request] {

  override def sendSpiders(spiderHome: ActorRef, data: Data, msg: (Request, Spider), collected: Set[ActorRef]) {
    spiderHome ! DiagnosticData[Data](data, now, selfNode)
    super.sendSpiders(spiderHome, data, msg, collected)
  }

  override def before = diagnoseBefore

  override def after = diagnoseAfter

  def diagnoseBefore: Receive

  def diagnoseAfter: Receive

  def now = System.nanoTime()
}

/**
 * A Diagnostic Data message, including a timestamp when the diagnosis was taken, and at which node in the web.
 */
case class DiagnosticData[Data](data:Data, timestamp:Long, nodeRef:WebNodeRef)