Packages

event_bus_postgres

0.2.4
0.4.2 0.4.1 retired 0.4.0 retired 0.3.1 retired 0.3.0 retired 0.2.9 retired 0.2.8 retired 0.2.7 retired 0.2.6 retired 0.2.5 retired 0.2.4 retired 0.2.3 retired 0.2.2 retired 0.2.1 retired 0.2.0 retired 0.1.0 retired 0.1.0-beta3 retired 0.1.0-beta2 retired 0.1.0-beta1 retired

Postgres event store for event_bus

Retired package: Deprecated
HexDocs

Current section

Files

Jump to
Readme
19 Versions
4 Dependencies
Dependants
Files
Activity
event_bus_postgres lib event_bus_postgres bucket.ex
Raw

lib/event_bus_postgres/bucket.ex 

defmodule EventBus.Postgres.Bucket do

  @moduledoc """

  Event persistence worker

  """



  use GenStage

  alias EventBus.Postgres.{Config, Store, EventMapper}



  def init(:ok) do

    {

      :consumer,

      :ok,

      subscribe_to: [

        {

          EventMapper,

          min_demand: Config.min_demand(), max_demand: Config.max_demand()

        }

      ]

    }

  end



  def start_link do

    GenStage.start_link(__MODULE__, :ok)

  end



  @doc false

  def handle_events(events, _from, state) do

    Store.batch_insert(events)

    {:noreply, [], state}

  end

end