Packages

service_watcher_sup

0.1.7
0.2.6 0.2.5 0.2.1 0.2.0 0.1.9 0.1.8 0.1.7 0.1.4 0.1.3 0.1.2 0.1.1

This is a GenServer-ish implementation of a Service watcher. A process that is designed to poll service state every given number of miliseconds and perform due actions in case it is not in designated state. The process is also capable of sending notifications to the configured recipient in Slack.

HexDocs

Current section

Files

Jump to
Readme
11 Versions
4 Dependencies
Dependants
Files
Activity
service_watcher_sup lib supervisor job_supervisor.ex
Raw

lib/supervisor/job_supervisor.ex 

defmodule JobSupervisor do

  use DynamicSupervisor



  import Service.Watcher, only: [service_name_alias: 1]



  def start_link do

    DynamicSupervisor.start_link(__MODULE__, [:one_for_one], name: __MODULE__)

  end



  def start_child(service_name, module, function, args, interval, period \\ :infinity, spawn_on_call \\ false) do

    spec = Supervisor.Spec.worker(

      TimerJob,

      [

        module, function, args, interval, period, spawn_on_call,

        [name: service_name_alias(service_name)]

      ], [restart: :transient])

    child = DynamicSupervisor.start_child(__MODULE__, spec)

    case child do

      {:ok, pid} ->

        pid |> TimerJob.run()

        IO.puts "Started #{service_name} [#{inspect pid}] job right off"

    end

    child

  end



  def init([strategy]) do

    DynamicSupervisor.init(strategy: strategy)

  end



end