nginx.d

import std.csv;
import std.stdio;
import std.datetime;
import std.conv;


/*
reads logfiles from nginx that are generated with:
  log_format metrics '$msec\t$connection\t$status\t$request_time\t$remote_addr\t$remote_port\t$body_bytes_sent\t$request_uri\t$tcpinfo_rtt\t$tcpinfo_rttvar\t$tcpinfo_snd_cwnd\t$tcpinfo_rcv_space';
*/



//could this be done better?
struct SysUnixTime
{
    this(string s)
    {
        t = SysTime(621_355_968_000_000_000L + convert!("msecs",
                "hnsecs")(cast(long)(s.to!double * 1000)));
    }

    SysTime t;
    alias t this;
}

struct NginxLogLine
{
    SysUnixTime time;
    ulong connection;
    ushort status;
    float request_time;
    string remote_addr;
    ushort remote_port;
    uint body_bytes_sent;
    string request_uri;
    uint tcpinfo_rtt;
    uint tcpinfo_rttvar;
    uint tcpinfo_snd_cwnd;
    uint tcpinfo_rcv_space;
}

void main()
{

    import std.algorithm;
    auto records = stdin.byLine.joiner("\n").csvReader!NginxLogLine('\t');

    foreach (l; records)
    {
        writeln(record.status);
    }

}