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 components realtime_stats_component.ex
Raw

lib/exq_ui_web/live/components/realtime_stats_component.ex 

defmodule ExqUIWeb.RealtimeStatsComponent do

  @moduledoc false

  use ExqUIWeb, :live_component

  alias ExqUI.Queue



  @tick_interval 5_000



  @impl true

  def mount(socket) do

    if connected?(socket) do

      send_update_after(__MODULE__, [id: "realtime-stats"], 0)

    end



    {:ok, socket}

  end



  @impl true

  def update(assigns, socket) do

    config = socket.assigns[:config] || assigns[:config]



    stats = Queue.realtime_stats(config, assigns[:stats])



    send_update_after(

      __MODULE__,

      [id: "realtime-stats", stats: stats, config: config],

      @tick_interval

    )



    socket = push_event(socket, "append-point", Map.take(stats, [:processed, :failed]))

    {:ok, assign(socket, stats: stats, tick_interval: @tick_interval, config: config)}

  end

end