dmexe / finagle-consul   0.1.0

Service discovery and leader election for Finagle cluster with Consul. This project originaly developed by kachayev/finagle-consul, Unlike kachayev’s version, where services are used, here we use sessions and k/v for discovery.

Consul is a distributed, highly available and extremely scalable tool for service discovery and configuration.

This project is using Consul sessions and K/V storage for announces. Unlike Consul services, sessions allow to set up key TTL's, and when application is killed by OOM killer or closed unexpectedly, the session and keys, associated with it, are automatically removed after TTL is expired.

Service definitions are stored in /v1/kv/finagle/services/:name/:sessionId, you can specify a name as URL, but all "/" will be replaced with "."

Warning! This is still BETA.

Add the following to your sbt build.sbt file:

resolvers += Resolver.jcenterRepo

libraryDependencies ++= Seq(
  "com.github.dmexe" %% "finagle-consul" % "0.1.0"
)

To announce your service use the following scheme:

consul!host1:port1,host2:port2,...!serviceName

For example,

val server = Http.serveAndAnnounce("consul!127.0.0.1:8500!/RandomNumber")
val client = Http.newService("consul!127.0.0.1:8500!/RandomNumber")

The Consul service may use for lead election for finagle applications, usage example:

// first, create session and lock service, which keeps session, and periodically try to lock key
val leader = ConsulLeaderElection.get("lockName", "localhost:8500")

// call method getStatus, result may be one of
// Pending - no status information
// Leader - current session abtained lock
// Follower - lock obtained by another session

if (leader.getStatus == Leader) {
  ...
}

...