Packages

exd

0.1.24
0.2.1 0.2.0 0.1.36 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

A few sentences (a paragraph) describing the project.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
7 Dependencies
Dependants
Files
Activity
exd lib exd source adapter bus broker.ex
Raw

lib/exd/source/adapter/bus/broker.ex 

defmodule Exd.Source.Bus.Broker do

  @moduledoc """

  Broker for event bus

  """

  use GenServer



  ## Client



  @doc """

  Starts broker



  ## Options



    * `topic` - Topic to consume events from

    * `parent` - PID of parent process

  """

  def start_link(opts) do

    GenServer.start_link(__MODULE__, opts)

  end



  def process({topic, id} = event_shadow) do

    GenServer.cast(__MODULE__, event_shadow)

  end



  ## Server



  @impl true

  def init(opts) do

    topic = Keyword.fetch!(opts, :topic)

    :ok = EventBus.register_topic(__MODULE__, topic)

    {:ok, %{}}

  end



  @impl true

  def handle_cast({:record_received, id} = event_shadow, state) do

    record = EventBus.fetch_event(event_shadow)

    {:noreply, state}

  end



end