Packages

exq_ui

0.17.0
0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.3 0.12.2 0.12.1 0.12.0 0.11.1 0.11.0 0.10.0 0.9.0 0.8.6 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.5 0.6.4 0.6.3 0.6.0 0.5.0 0.1.0

Exq UI is the UI component for Exq, a job processing library. Exq UI provides the UI dashboard to display stats on job processing.

HexDocs

Current section

Files

Jump to
Readme
30 Versions
9 Dependencies
0 Dependants
Files
Activity
exq_ui lib exq_ui_web live busy_live index.ex
Raw

lib/exq_ui_web/live/busy_live/index.ex 

defmodule ExqUIWeb.BusyLive.Index do

  @moduledoc false

  use ExqUIWeb, :live_view

  alias ExqUI.Queue



  @impl true



  def mount(_params, %{"config" => config}, socket) do

    {:ok,

     assign(socket, %{

       config: config,

       nodes: Queue.list_nodes(config),

       jobs: Queue.list_current_jobs(config)

     })}

  end



  @impl true

  def handle_event(

        "signal",

        %{

          "signal" => %{"name" => "TSTP", "node_id" => node_id},

          "_target" => ["signal", "quiet"]

        },

        socket

      ) do

    config = socket.assigns.config

    :ok = Queue.send_signal(config, node_id, "TSTP")



    nodes =

      Enum.map(socket.assigns.nodes, fn node ->

        if node.identity == node_id do

          %{node | quiet: true}

        else

          node

        end

      end)



    socket = assign(socket, :nodes, nodes)



    {:noreply, socket}

  end



  @impl true

  def handle_event("signal", _, socket) do

    {:noreply, socket}

  end

end