GenEvent поведение
Менеджер событий с поведением обработчиков событий.
Если вы заинтересованы в реализации менеджера событий, пожалуйста, ознакомьтесь с разделом "Альтернативы" ниже. Если вам необходимо реализовать обработчик событий для интеграции с существующей системой, такой как Elixir's Logger, пожалуйста, используйте :gen_event вместо этого.
Альтернативы
Существует несколько подходящих альтернатив GenEvent. Каждая из них может быть наиболее выгодной в зависимости от варианта использования.
Supervisor и GenServers
Альтернативой GenEvent является очень минимальное решение, состоящее из использования супервайзора и нескольких GenServers, запущенных под ним. Супервайзор действует как "менеджер событий", а дочерние GenServers — как "обработчики событий". Этот подход имеет некоторые недостатки (например, он не обеспечивает обратную связь при перегрузке), но все же может заменить GenEvent для использования с низкой нагрузкой. Эта запись в блоге от José Valim содержит более подробную информацию об этом подходе.
GenStage
Если случай использования, в котором вы использовали GenEvent, требует более сложной логики, GenStage предоставляет отличную альтернативу. GenStage — это внешняя библиотека Elixir, поддерживаемая командой Elixir; она предоставляет инструмент для реализации систем, которые обмениваются событиями в режиме запроса с встроенной поддержкой обратной связи при перегрузке. См. документацию GenStage для получения дополнительной информации.
:gen_event
Если ваш случай использования требует точно того, что предоставлял GenEvent, или вам необходимо интегрироваться с существующей системой на основе :gen_event, вы по-прежнему можете использовать :gen_event модуль Erlang.
Краткое описание
Типы
Обработчики
Типы
handler()Source
@type handler() :: atom() | {atom(), term()} manager()Source
@type manager() :: pid() | name() | {atom(), node()} name()Source
@type name() :: atom() | {:global, term()} | {:via, module(), term()} on_start()Source
@type on_start() :: {:ok, pid()} | {:error, {:already_started, pid()}} options()Source
@type options() :: [{:name, name()}] Обработчики
code_change(old_vsn, state, extra)Source
@callback code_change(old_vsn, state :: term(), extra :: term()) ::
{:ok, new_state :: term()}
when old_vsn: term() | {:down, term()} handle_call(request, state)Source
@callback handle_call(request :: term(), state :: term()) ::
{:ok, reply, new_state}
| {:ok, reply, new_state, :hibernate}
| {:remove_handler, reply}
when reply: term(), new_state: term() handle_event(event, state)Source
@callback handle_event(event :: term(), state :: term()) ::
{:ok, new_state} | {:ok, new_state, :hibernate} | :remove_handler
when new_state: term() handle_info(msg, state)Source
@callback handle_info(msg :: term(), state :: term()) ::
{:ok, new_state} | {:ok, new_state, :hibernate} | :remove_handler
when new_state: term() init(args)Source
@callback init(args :: term()) ::
{:ok, state} | {:ok, state, :hibernate} | {:error, reason :: any()}
when state: any() terminate(reason, state)Source
@callback terminate(reason, state :: term()) :: term()
when reason:
:stop | {:stop, term()} | :remove_handler | {:error, term()} | term()
© 2012 Plataformatec
Licensed under the Apache License, Version 2.0.
https://hexdocs.pm/elixir/1.13.4/GenEvent.html
