Module Logstash_conv.Message

type tag_format = {

field : string;

to_json : string list ‑> Json_wheel_jane_street_overlay.Std.Json_type.json_type;

}

val json_of_t : Async.Log.Message.t ‑> Json_wheel_jane_street_overlay.Std.Json_type.json_type

Translate a Log.Message.t into a JSON term suitable for Feeding into ELK. Log messages are encoded as a json object with keys:

@timestamp -> string of message time ('@' prefix as this is expected by logstash) level -> string of optional message level message -> string of message body tag_my_tag -> string value of tag with key "my_tag"

val json_of_t' : ?message:([ `Sexp of Async.Sexp.t | `String of string ] ‑> Json_wheel_jane_street_overlay.Std.Json_type.json_type) ‑> ?tags:(string * tag_format) list ‑> unit ‑> (Async.Log.Message.t ‑> Json_wheel_jane_street_overlay.Std.Json_type.json_type) Core.Staged.t

like json_of_t but allows customization of the JSON representation.