Packages

event_bus_postgres

0.3.0
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 - Please prefer always latest minor
HexDocs

Current section

Files

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

lib/event_bus_postgres/workers/ttl.ex 

defmodule EventBus.Postgres.Worker.TTL do

  @moduledoc false



  use GenServer



  alias EventBus.Postgres.{Config, Store}



  ## Callbacks



  @doc false

  def start_link do

    GenServer.start_link(__MODULE__, [], name: __MODULE__)

  end



  @doc false

  def init(_opts) do

    delete_later()

    {:ok, nil}

  end



  @doc false

  def handle_info(:delete_expired, state) do

    Store.delete_expired()

    delete_later()

    {:noreply, state}

  end



  defp delete_later do

    Process.send_after(self(), :delete_expired, Config.deletion_period())

  end

end