Раскодирует payload по типу, который объявил издатель (_content_type в
meta), — один консьюмер читает и JSON, и термы, и текст, что бы ни
публиковали и через какой транспорт.
- JSON (
application/json,…+json) — значение; - Erlang-терм —
binary_to_term(:safe); терм с незнакомым атомом — ошибка (LogDB.Client.DecodeErrorвhandle_error/2); text/*— строка;- прочее — байты как есть;
- тип не объявлен (старые события) — терм, если похоже на терм, иначе байты.
Публикует через erlangd термами (как Parser.Erlangd).
Summary
Functions
Callback implementation for LogDB.Client.Parser.decode/1.
Callback implementation for LogDB.Client.Parser.decode_event/3.
Callback implementation for LogDB.Client.Parser.encode/1.
Callback implementation for LogDB.Client.Parser.encode_bytes/1.
Functions
Callback implementation for LogDB.Client.Parser.decode/1.
Callback implementation for LogDB.Client.Parser.decode_event/3.
Callback implementation for LogDB.Client.Parser.encode/1.
Callback implementation for LogDB.Client.Parser.encode_bytes/1.