"Sonatype OSS" at "http://oss.sonatype.org/content/repositories/snapshots"
"Twitter repo" at "http://maven.twttr.com"

libraryDependencies += "io.ckite" % "ckite" % "0.1.2-SNAPSHOT"

//KVStore is a simple distributed Map accepting Puts and Gets
class KVStore extends StateMachine {

  val map = new ConcurrentHashMap[String, String]()

  //called when a consensus has been reached for a WriteCommand or when a ReadCommand was received
  override def apply(command: Command): Any = command match {
      case Put(key: String, value: String) => { 
        map.put(key, value)
        value
      }
      case Get(key: String) => map.get(key)
  }

  //called during Log replay on startup and upon installSnapshot requests
  override def deserialize(snapshotBytes: Array[Byte]) = {
	//some deserialization mechanism
  }
 
  //called when Log compaction is required
  override def serialize(): Array[Byte] = {
	//some serialization mechanism
  }

}

//WriteCommands are replicated under Raft rules
case class Put(key: String, value: String) extends WriteCommand

//ReadCommands are not replicated but forwarded to the Leader
case class Get(key: String) extends ReadCommand

val ckite = CKiteBuilder().withLocalBinding("localhost:9091")
                          .withMembersBindings(Seq("localhost:9092","localhost:9093"))
                          .withMinElectionTimeout(1000).withMaxElectionTimeout(1500) //optional
                          .withHeartbeatsInterval(250) //optional
                          .withDataDir("/home/ckite/data") //dataDir for persistent state (log, terms, snapshots, etc...)
                          .withStateMachine(new KVStore()) //KVStore is an implementation of the StateMachine trait
                          .build
ckite.start()

//this Put command is forwarded to the Leader and applied under Raft rules
ckite.write(Put("key1","value1")) 

//consistent read commands are forwarded to the Leader
val value = ckite.read[String](Get("key1")) 

//as write commands, cluster membership changes are forwarded to the Leader
ckite.addMember("someHost:9094")

//as write commands, cluster membership changes are forwarded to the Leader
ckite.removeMember("someHost:9094")

//alternatively you can read from its local state machine allowing possible stale values
val value = ckite.readLocal[String](Get("key1")) 

//if necessary waits for elections to end
ckite.isLeader() 

ckite.stop()