KVAppService.scala

package rings

import akka.actor.{ActorSystem, ActorRef, Props}

sealed trait AppServiceAPI
case class Prime() extends AppServiceAPI
case class Command() extends AppServiceAPI
case class View(lockClients: Seq[ActorRef]) extends AppServiceAPI

/**
 * This object instantiates the service tiers and a load-generating master, and
 * links all the actors together by passing around ActorRef references.
 *
 * The service to instantiate is bolted into the KVAppService code.  Modify this
 * object if you want to instantiate a different service.
 */

object KVAppService {

  def apply(system: ActorSystem, numNodes: Int, ackEach: Int, t: Int): ActorRef = {

    /** Lock tier: create lock clients and lock server*/
    val lockServer = system.actorOf(LockServer.props(system, t), "LockServer")

    /** Service tier: create app servers */
    val servers = for (i <- 0 to numNodes-1)
      yield system.actorOf(GroupServer.props(lockServer, t, i, ackEach), "GroupServer" + i)

    lockServer ! View(servers)

    /** If you want to initialize a different service instead, that previous line might look like this:
      * yield system.actorOf(GroupServer.props(i, numNodes, stores, ackEach), "GroupServer" + i)
      * For that you need to implement the GroupServer object and the companion actor class.
      * Following the "rings" example.
      */


//    /** Tells each server the list of servers and their ActorRefs wrapped in a message. */
//    for (server <- servers)
//      server ! View(lock_server)

    /** Load-generating master */
    val master = system.actorOf(LoadMaster.props(numNodes, servers, ackEach), "LoadMaster")
    master
  }
}