Packages

super_worker

0.3.6
0.5.0 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

SuperWorker is a powerful Elixir library for working with supervisors and background jobs. It provides a much simpler approach than traditional supervisors. This library is currently under development and is unstable, so it is not recommended for production use.

HexDocs

Current section

Files

Jump to
Readme
22 Versions
0 Dependencies
Dependants
Files
Activity
super_worker lib supervisor partition.ex
Raw

lib/supervisor/partition.ex 

defmodule SuperWorker.Supervisor.Partition do

  alias SuperWorker.Supervisor

  alias Supervisor.{Db, Looper}



  alias __MODULE__



  require Logger



  def start_partition(state) do

    Db.put_sup_pid(state.table, state.id, self())



    send(state.master, {:partition_started, state.id})



    # Turn partition process to system process.

    Process.flag(:trap_exit, true)



    Looper.main_loop(state)

  end



  def init_additional_partitions(supervisor = %Supervisor{}) do

    Logger.debug(

      "SuperWorker, Supervisor, [#{inspect(supervisor.id)}] init additional partitions, options: #{inspect(supervisor)}"

    )



    Enum.map(1..supervisor.num_partitions, fn i ->

      Logger.debug(

        "SuperWorker, Supervisor, [#{inspect(supervisor.id)}] add partition: #{inspect(i)}"

      )



      supervisor =

        supervisor

        |> Map.put(:master, supervisor.id)

        |> Map.put(:id, i)



      {:ok, partition, pid} = init_partition(supervisor)

      {partition, pid}

    end)

    |> Enum.into(%{})

  end



  ## Private functions



  defp init_partition(partition = %Supervisor{}) do

    # Start the main loop

    pid = spawn_link(Partition, :start_partition, [partition])



    Logger.debug(

      "SuperWorker, Supervisor, #{inspect(partition.id)} initialized, pid: #{inspect(pid)}"

    )



    {:ok, partition.id, pid}

  end

end