Scala client library for sending events to Riemann, featuring strong typing, asynchronous API (using Akka under the hood) and a DSL to avoid cluttering the application codebase with metrics-related code.
In build.sbt (scala 2.11.7):
# riemann-java-client comes from clojars.org
resolvers += "clojars.org" at "http://clojars.org/repo"
libraryDependencies += "net.benmur" %% "riemann-scala-client" % "0.4.0"
Or in pom.xml if you are using maven:
<dependency>
<groupId>net.benmur</groupId>
<artifactId>riemann-scala-client_2.11</artifactId>
<version>0.4.0</version>
</dependency>
<dependency>
<groupId>net.benmur</groupId>
<artifactId>riemann-scala-client_2.10</artifactId>
<version>0.4.0</version>
</dependency>
The imports list is somewhat longer than it used to be, because Scala 2.11 became more picky about choosing implicits (having both Reliable
and Unreliable
variants of SendOff
in scope makes it unable to choose either one).
Issue #10 is open about simplifying imports again.
import net.benmur.riemann.client.RiemannClient.{riemannConnectAs, Unreliable}
import net.benmur.riemann.client.UnreliableIO._
import net.benmur.riemann.client.EventSenderDSL._
import net.benmur.riemann.client.EventDSL._
import akka.actor.ActorSystem
import akka.util.Timeout
import scala.concurrent.duration.DurationInt
import java.net.InetSocketAddress
object RiemannSendTest extends App {
implicit val system = ActorSystem()
implicit val timeout = Timeout(5.seconds)
val metrics = riemannConnectAs[Unreliable] to new InetSocketAddress("localhost", 5555)
service("service name") | state("warning") |>> metrics
}
Change Unreliable
to Reliable
and UnreliableIO
to ReliableIO
as needed, which will make the |><
sending operation (returning a Future) available.
val tcpDestination = riemannConnectAs[Reliable] to new InetSocketAddress("localhost", 5555)
val udpDestination = riemannConnectAs[Unreliable] to new InetSocketAddress("localhost", 5555)
Please note that operations returning a Future won't compile if the connection is created with an Unreliable
type parameter, this is intentional. (Well, it will compile if you have an implicit in scope implementing SendAndExpectFeedback[_, _, Unreliable]
).
Building an event is done by combining event parts. Each part is optional, as per the Protocol Buffers definition. Here is how to build a completely populated event:
val event = oneEvent() | host("hostname") | service("service xyz") | state("warning") | time(1234L) |
description("metric is way too high") | tags("performance", "slow", "provider-xyz") |
metric(0.8f) | ttl(120L)
// which is the same as (but with less intermediate objects instanciated):
val event2 = EventPart(host=Some("hostname"), service=Some("service xyz"), state=Some("warning"),
description=Some("metric is way too high"), time=Some(1234L),
tags=Seq("performance", "slow", "provider-xyz"), metric=Some(0.8f), ttl=Some(120L))
// given these declarations:
val destination = riemannConnectAs[Reliable] to new InetSocketAddress("localhost", 5555)
val destinationWithDefaults = destination withValues(host("host") | service("service response time"))
// this:
state("warning") | metric(0.5) |>> destinationWithDefaults
// is the same as:
host("host") | service("service response time") | state("warning") | metric(0.5) |>> destination
// implementing a counter or heartbeat is easy:
val signupCounter = destination withValues(service("Successful user registration"))
oneEvent() |>> signupCounter
val metricsDestination = riemannConnectAs[Unreliable] to new
InetSocketAddress("localhost", 5555) withValues(host("host") | service("service response time"))
state("warning") | metric(0.5) |>> metricsDestination
val metricsDestination = riemannConnectAs[Reliable] to new
InetSocketAddress("localhost", 5555) withValues(host("host") | service("service response time"))
state("warning") | metric(0.5) |>> metricsDestination
val metricsDestination = riemannConnectAs[Reliable] to new
InetSocketAddress("localhost", 5555) withValues(host("host") | service("service response time"))
state("warning") | metric(0.5) |>< metricsDestination onComplete {
case Left(exception) => // ...
case Right(false) => println("not sent ok!!")
case Right(true) => println("sent ok")
}
val metricsDestination = riemannConnectAs[Reliable] to new InetSocketAddress("localhost", 5555)
Query("tagged \"slow\"") |>< metricsDestination onComplete {
case Left(exception) => // ...
case Right(events) => events foreach println
}
Please note that operations returning a Future won't compile if the connection is created with an Unreliable
type parameter, this is intentional. (Well, it will compile if you have an implicit in scope implementing SendAndExpectFeedback[_, _, Unreliable]
).
Pull requests are very welcome.
This version is intended to work with Scala 2.11 and Akka 2.3.
Care has been taken to be as reliable as possible, because sending metrics should not impact your application's stability. In particular:
Please see next milestone's open issues list for items pending implementation.