1 files changed, 132 insertions, 0 deletions
diff --git a/content/blog/2012-1-25-finagle-with-scala-bootstrapper.markdown b/content/blog/2012-1-25-finagle-with-scala-bootstrapper.markdown
new file mode 100644
index 0000000..7a5910d
--- /dev/null
+++ b/content/blog/2012-1-25-finagle-with-scala-bootstrapper.markdown
@@ -0,0 +1,132 @@
+---
+title: "Finagle with scala-bootstrapper"
+date: 2012-01-25T09:45:00Z
+comments: false
+url: /finagle-with-scala-bootstrapper
+tags: ["scala"]
+---
+
+
+
+I've been fascinated by the concepts in [finagle](http://twitter.github.com/finagle/) for some time, but being a scala noob, I never knew how to bootstrap a finagle project. Turns out twitter has a gem, [scala-bootstrapper](https://github.com/twitter/scala-bootstrapper), that generates a simple thirft based key/value store for you. There's even a[tutorial](http://twitter.github.com/scala_school/searchbird.html)  on how to extend the example project into a distributed search service.
+
+This is a guide on setting it all up locally, it assumes you have Git, Homebrew, and OS X.
+
+### Install scala 2.8.1
+
+```sh
+$ brew versions scala
+$ cd/usr/local/(or wherever you have homebrew installed)
+$ git checkout -b scala281 0e16b9d(make sure the SHA matches versions output)
+$ brew install scala
+$ git checkout master$git branch -D scala281
+```
+
+### Install sbt 0.7.4 (assumes you have a ~/bin in your $PATH)
+
+```sh
+$ curl -O http://simple-build-tool.googlecode.com/files/sbt-launch-0.7.4.jar > ~/bin/sbt-launch.jar
+$ echo 'java -Xmx1G -jar `dirname $0`/sbt-launch.jar "$@"'> ~/bin/sbt
+```
+
+### Install scala-bootstrapper
+
+```sh
+$ gem install scala-bootstrapper
+```
+
+### Generate finagle project**
+
+```sh
+$ mkdir newbird
+$ cd newbird
+$ scala-bootstrapper newbird
+$ sbt update
+$ sbt test
+```
+
+### Add a Client class
+
+create newbird/src/main/scala/com/twitter/newbird/Client.scala with
+
+```scala
+package com.twitter.newbird
+
+import com.twitter.finagle.builder.ClientBuilder
+import com.twitter.finagle.thrift.ThriftClientFramedCodec
+import com.twitter.newbird.thrift._
+import org.apache.thrift.protocol.TBinaryProtocol
+
+import java.net.InetSocketAddress
+
+class Client {  
+
+  val service = ClientBuilder().hosts(Seq(newInetSocketAddress("localhost",9999)))
+    .codec(ThriftClientFramedCodec())    
+    .hostConnectionLimit(1)    
+    .build()  
+  val client = new NewbirdServiceClientAdapter(
+    new thrift.NewbirdService.ServiceToClient(service,newTBinaryProtocol.Factory))  
+
+  def get(key:String) = client.get(key)()  
+  def put(key:String, value:String) = client.put(key,value)()
+
+}
+
+```
+
+### Running the server
+
+```sh
+$ cd newbird
+$ sbt> run -f config/development.scala
+
+```
+
+### Playing with the client
+
+
+```sh
+$ cd newbird
+$ sbt console
+scala> import com.twitter.newbird.Client
+scala> val client = new Client()
+scala> client.put("foo","bar")
+scala> client.get("foo")
+```
+
+### Bonus
+
+finagle exports a stats url you can curl:
+
+```sh
+$ curl http://localhost:9900/stats.txt
+counters:  Newbird/connects: 1  
+Newbird/requests: 4  
+Newbird/success: 4
+gauges:  
+  Newbird/connections: 0  
+  Newbird/pending: 0  
+  jvm_heap_committed: 588251136  
+  jvm_heap_max: 2146828288  
+  jvm_heap_used: 64354560  
+  jvm_nonheap_committed: 83267584  
+  jvm_nonheap_max: 318767104  
+  jvm_nonheap_used: 68655360  
+  jvm_num_cpus: 4  
+  jvm_start_time: 1327511164928  
+  jvm_thread_count: 14  
+  jvm_thread_daemon_count: 9  
+  jvm_thread_peak_count: 14  
+  jvm_uptime: 2626505
+labels:
+  metrics:  
+    Newbird/connection_duration: (average=2590412, count=1, maximum=2590412, minimum=2590412, p25=2590412, p50=2590412, p75=2590412, p90=2590412, p99=2590412, p999=2590412, p9999=2590412)  
+    Newbird/connection_received_bytes: (average=192, count=1, maximum=192, minimum=192, p25=192, p50=192, p75=192, p90=192, p99=192, p999=192, p9999=192)  
+    Newbird/connection_requests: (average=4, count=1, maximum=4, minimum=4, p25=4, p50=4, p75=4, p90=4, p99=4, p999=4, p9999=4)  
+    Newbird/connection_sent_bytes: (average=120, count=1, maximum=120, minimum=120, p25=120, p50=120, p75=120, p90=120, p99=120, p999=120, p9999=120)  
+    Newbird/request_latency_ms: (average=14, count=4, maximum=39, minimum=2, p25=2, p50=8, p75=10, p90=39, p99=39, p999=39, p9999=39)
+```
+ 
+
+