Pipe logs to Riemann

riemannlogs.fs

module RiemannStore =

    open System
    open System.Configuration
    open Riemann

    let client = new Client(riemannServer, riemannPort)

    let state entry =
        match entry.Level with
        | Debug -> "ok"
        | Warn -> "warning"
        | Error -> "error"

    let description entry =
        seq {
            yield sprintf "Message: %s" entry.Data.Message
            yield sprintf "Host: %s" entry.Source.Host
            yield sprintf "Timestamp: %s" <| entry.Timestamp.ToString()
            match entry.Data.Exception with
            | Some e ->
                yield ""
                yield e.Message
                yield e.StackTrace
            | None -> ()
        } |> String.concat "\n"

    let logEntry entry =
        using (client.Tag(entry.Source.Host))
            (fun _ -> client.SendEvent("log " + entry.Source.Category, state entry, description entry, float32 1.0))
        
    let createRiemannStore =
        { Store.Set = logEntry
          Store.Flush = ignore }