LogDB.Client.Worker (logdb_client v0.3.0)

Copy Markdown View Source

Summary

Functions

Returns a specification to start this module under a supervisor.

Отдать событие консьюмеру клиента name. wire — в каком виде транспорт отдал payload: :bytes (как лежит в шине) или :json (значение JSON-ответа). Консьюмера нет (клиент только публикует или Worker перезапускается) — событие не подтверждено, шина доставит его снова.

Вернётся, когда консьюмер разберёт всё, что ему отдали до этого вызова: вызов встаёт в очередь Worker'а за событиями. Противодавление для тех, кто забирает события сам (HTTP long-poll): следующая пачка — после этой. :ok или :gone, если Worker'а нет или он не дождался.

Callback implementation for GenServer.init/1.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

deliver(name, type, payload, meta, wire)

Отдать событие консьюмеру клиента name. wire — в каком виде транспорт отдал payload: :bytes (как лежит в шине) или :json (значение JSON-ответа). Консьюмера нет (клиент только публикует или Worker перезапускается) — событие не подтверждено, шина доставит его снова.

drained(name, timeout)

Вернётся, когда консьюмер разберёт всё, что ему отдали до этого вызова: вызов встаёт в очередь Worker'а за событиями. Противодавление для тех, кто забирает события сам (HTTP long-poll): следующая пачка — после этой. :ok или :gone, если Worker'а нет или он не дождался.

init(config)

Callback implementation for GenServer.init/1.

start_link(config)