Packages

ferricstore

0.8.0
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 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.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore store keydir_runtime_supervisor.ex
Raw

lib/ferricstore/store/keydir_runtime_supervisor.ex 

defmodule Ferricstore.Store.KeydirRuntimeSupervisor do

  @moduledoc false



  use Supervisor



  @spec start_link(keyword()) :: Supervisor.on_start()

  def start_link(opts) do

    Supervisor.start_link(__MODULE__, opts, name: Keyword.get(opts, :name, __MODULE__))

  end



  @impl true

  def init(opts) do

    ctx = Keyword.fetch!(opts, :instance_ctx)



    shard_supervisor_opts = [

      name: Keyword.get(opts, :shard_supervisor_name, Ferricstore.Store.ShardSupervisor),

      data_dir: Keyword.get(opts, :data_dir, ctx.data_dir),

      shard_count: Keyword.get(opts, :shard_count, ctx.shard_count),

      instance_ctx: ctx

    ]



    children = [

      Supervisor.child_spec(

        {Ferricstore.Store.KeydirTableOwner, instance_ctx: ctx},

        id: Ferricstore.Store.KeydirTableOwner

      ),

      Supervisor.child_spec(

        {Ferricstore.Store.ShardSupervisor, shard_supervisor_opts},

        id: Ferricstore.Store.ShardSupervisor

      )

    ]



    # The table heir is deliberately supervised outside this subtree. If the

    # owner fails, it receives the ETS tables while all dependent shards stop;

    # the replacement owner reclaims them before shards restart.

    Supervisor.init(children, strategy: :rest_for_one, max_restarts: 20, max_seconds: 10)

  end

end