Merge pull request #55 from heroku/m_equal_logplex_stats

Add m= in front of logplex_stats logging so it's easier to group in splunk

src/logplex_stats.erl

@@ -152,20 +152,20 @@ start_timer() ->
     erlang:start_timer(Time, ?MODULE, flush).
 
 log_stat(UnixTS, #drain_stat{drain_id=DrainId, channel_id=ChannelId, key=Key}, Val) ->
-    io:format("logplex_stats ts=~p channel_id=~p drain_id=~p ~p=~p~n",
+    io:format("m=logplex_stats ts=~p channel_id=~p drain_id=~p ~p=~p~n",
         [UnixTS, ChannelId, DrainId, Key, Val]);
 
 log_stat(UnixTS, #channel_stat{channel_id=ChannelId, key=Key}, Val) ->
-    io:format("logplex_stats ts=~p channel_id=~p ~p=~p~n",
+    io:format("m=logplex_stats ts=~p channel_id=~p ~p=~p~n",
         [UnixTS, ChannelId, Key, Val]);
 
 log_stat(UnixTS, #logplex_stat{module=Mod, key=K}, Val) ->
-    io:format("logplex_stats ts=~p system module=~p ~200p=~p~n",
+    io:format("m=logplex_stats ts=~p system module=~p ~200p=~p~n",
         [UnixTS, Mod, K, Val]);
 
 log_stat(UnixTS, {Class, Key}, Val) ->
-    io:format("logplex_stats ts=~p freeform class=~p key=~p count=~p~n",
+    io:format("m=logplex_stats ts=~p freeform class=~p key=~p count=~p~n",
         [UnixTS, Class, Key, Val]);
 
 log_stat(UnixTS, Key, Val) when is_atom(Key); is_list(Key) ->
-    io:format("logplex_stats ts=~p ~p=~p~n", [UnixTS, Key, Val]).
+    io:format("m=logplex_stats ts=~p ~p=~p~n", [UnixTS, Key, Val]).