Packages

verk_web

1.4.2
1.6.0 1.5.1 1.5.0 1.4.2 1.4.1 1.4.0 1.3.0 1.2.0 1.1.1 1.1.0 1.0.2 1.0.1 1.0.0 0.14.0 0.13.7 0.13.6 0.13.5 0.13.4 0.13.3 retired 0.13.2 0.13.1 0.13.0 0.11.0 0.10.0 0.9.5 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0

A Verk dashboard

HexDocs

Current section

Files

Jump to
Readme
30 Versions
8 Dependencies
Dependants
Files
Activity
verk_web lib verk_web tracking_queues_handler.ex
Raw

lib/verk_web/tracking_queues_handler.ex 

defmodule VerkWeb.TrackingQueuesHandler do

  use GenStage



  def start_link(pid) do

    GenStage.start_link(__MODULE__, pid)

  end



  def init(pid) do

    {:consumer, pid, subscribe_to: [Verk.EventProducer]}

  end



  def handle_events(events, _from, pid) do

    Enum.each(events, fn event -> handle_event(event, pid) end)

    {:noreply, [], pid}

  end



  defp handle_event(%Verk.Events.QueueRunning{} = event, pid) do

    send pid, {:queue_status, %{queue: event.queue, status: "running"}}

  end

  defp handle_event(%Verk.Events.QueuePausing{} = event, pid) do

    send pid, {:queue_status, %{queue: event.queue, status: "pausing"}}

  end

  defp handle_event(%Verk.Events.QueuePaused{} = event, pid) do

    send pid, {:queue_status, %{queue: event.queue, status: "paused"}}

  end

  defp handle_event(_, _), do: :ok

end