Packages

eddb

0.16.0
0.16.0 0.15.0 0.14.0 0.12.0 0.11.0 0.10.0 0.9.2 0.9.1 0.9.0 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.1 0.1.0

Distirbuted database for unstructured data

HexDocs

Current section

Files

Jump to
Readme
18 Versions
5 Dependencies
0 Dependants
Files
Activity
eddb lib schedulers SyncScheduler.ex
Raw

lib/schedulers/SyncScheduler.ex 

defmodule Schedulers.SyncScheduler do

  use GenServer

  require Logger

  alias Eddb.Facade



  # 1 hour

  @interval 60 * 60 * 1000



  def start_link(_opts) do

    GenServer.start_link(__MODULE__, %{}, name: __MODULE__)

  end



  @impl true

  def init(state) do

    schedule_sync()

    {:ok, state}

  end



  @impl true

  def handle_info(:sync, state) do

    Logger.info("Starting periodic sync...")

    Facade.sync()

    Logger.info("Periodic sync completed.")

    schedule_sync()

    {:noreply, state}

  end



  defp schedule_sync do

    Process.send_after(self(), :sync, @interval)

  end

end