1 defmodule Pleroma.Web.Streamer.Supervisor do
4 def start_link(opts) do
5 Supervisor.start_link(__MODULE__, opts, name: __MODULE__)
10 {Pleroma.Web.Streamer.State, args},
11 {Pleroma.Web.Streamer.Ping, args},
12 :poolboy.child_spec(:streamer_worker, poolboy_config())
15 opts = [strategy: :one_for_one, name: Pleroma.Web.Streamer.Supervisor]
16 Supervisor.init(children, opts)
19 defp poolboy_config do
21 Pleroma.Config.get(:streamer,
27 {:name, {:local, :streamer_worker}},
28 {:worker_module, Pleroma.Web.Streamer.Worker},
29 {:size, opts[:workers]},
30 {:max_overflow, opts[:overflow_workers]}