EventBus.Postgres

Listen and save event_bus events to Postgres.

Installation

If available in Hex, the package can be installed by adding event_bus_postgres to your list of dependencies in mix.exs:

def deps do
  [
    {:event_bus_postgres, "~> 0.1.0-beta3"}
  ]
end

On the command line:

mix ecto.create -r EventBus.Postgres.Repo
mix ecto.migrate -r EventBus.Postgres.Repo

Configuration

In your config.exs (or dev.exs, test.exs, prod.exs);

config :event_bus_postgres,
  enabled: {:system, "EB_POSTGRES_ENABLED", "true"},
  persist_in_ms: {:system, "EB_POSTGRES_PERSIST_IN_MS", "100"},
  topics: {:system, "EB_POSTGRES_TOPICS", ".*"}, # seperator is ';'
  default_ttl: {:system, "EB_POSTGRES_DEFAULT_TTL", "900000"},
  deletion_period: {:system, "EB_POSTGRES_DELETION_PERIOD", "600000"}

# DB config
config :event_bus_postgres, EventBus.Postgres.Repo,
  adapter: Ecto.Adapters.Postgres,
  url: System.get_env("DATABASE_URL"),
  pool_size: String.to_integer(System.get_env("POOL_SIZE") || "2"),
  ssl: true

Documentation

Module docs can be found at https://hexdocs.pm/event_bus_postgres.

Contributing

Issues, Bugs, Documentation, Enhancements

1. Fork the project

2. Make your improvements and write your tests(make sure you covered all the cases).

3. Make a pull request.

License

MIT