Релиз ExGolos v0.6: обработка ивентов блокчейна с помощью GenStage

На связи @ontofractal. В этом релизе интегрирован GenStage, новый стандарт спецификации для обработки и обмена ивентами между процессами Elixir/Erlang. Внедрение GenStage упрощает Elixir разработчикам взаимодействие с модулем ExGolos: достаточно запустить GenStage Consumer с опцией subscribe_to: Golos.Stage.Blocks.Producer или subscribe_to: Golos.Stage.Txs.ProducerConsumer. Оба producer-а работают в режиме BroadcastDispatcher -- каждый поступающий ивент будет отправлен всем consumers.

По сути, операции записывающиеся в блокчейн в каждом блоке, являются ивентами, поэтому GenStage особенно хорошо подходит для решения подобного класса задач. Я почти уверен,что GenStage останется основным интерфейсом ExGolos для потоковой обработки ивентов.

Changelog

• breaking: удалена предыдущая версия стримера операций
• удалена опция stream_to в конфиге
• добавлен модуль Golos.Stage.Blocks.Producer производящий блоки Golos в режиме BroadcastDispatcher
• добавлен модуль Golos.Stage.Ops.ProducerConsumer, потребляющий блоки и производящий операции в режиме BroadcastDispatcher
• добавлен супервайзер для новых GenStage модулей
• добавлен пример базового GenStage Consumer для операций
• обновлено readme

Пример GenStage consumer для обработки стрима операций

defmodule Golos.Stage.Ops.ExampleConsumer do
  use GenStage
  require Logger

  def start_link(args, options \\ []) do
    GenStage.start_link(__MODULE__, args, options)
  end

  def init(state) do
    {:consumer, state, subscribe_to: state.subscribe_to}
  end

  def handle_events(events, _from, state) do
    for op <- events do
      Logger.info """
      New operation:
      #{inspect op}
      """
    end
    {:noreply, [], state}
  end

end

Roadmap

ExGolos находится в активной разработке.

• исследовать использование GenStage
• Улучшить документацию
• Добавить оставшиеся стракты
• Добавить возможность броадкаста транзакций

Больше об Elixir

Elixir -- функциональный язык программирования созданный на основе Erlang/OTP. Его основные преимущества: удобные примитивы параллелизации и одновременности(concurrency) вычислений, устойчивость к сбоям и относительно простое создание распределенных кластеров.

• Elixir Crash Course
• Elixir School