Packages

event_bus_postgres

0.2.9
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 - 0.2.x versions has a minor bug on event find method, please refer to latest version.
HexDocs

Current section

Files

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

lib/event_bus_postgres.ex 

defmodule EventBus.Postgres do

  @moduledoc """

  Postgres plugin for EventBus

  """



  alias EventBus.Postgres.Queue



  @doc """

  Deliver EventBus events to Postgres queue

  """

  def process({_topic, _id} = event_shadow) do

    Queue.push(event_shadow)

  end

end