qrush 0.6.0

Lightweight Job Queue and Task Scheduler for Rust (Actix + Redis + Cron)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

{% extends "layout.html.tera" %}
{% block content %}
<h1 class="text-2xl font-semibold mb-4">{{ title | default(value="Delayed Jobs") }}</h1>

<div class="card overflow-hidden">
  <table class="table">
    <thead class="bg-slate-50/60 dark:bg-slate-900/30">
      <tr>
        <th class="th">ID</th>
        <th class="th">Type</th>
        <th class="th">Status</th>
        <th class="th">Run at</th>
        <th class="th">Error</th>
        <th class="th">Actions</th>
      </tr>
    </thead>
    <tbody>
      {% for job in jobs %}
      {% set s = job.status | default(value="queued") %}
      <tr class="hover:bg-slate-50/60 dark:hover:bg-slate-900/30">
        <td class="td font-mono text-xs">{{ job.id }}</td>
        <td class="td">{{ job.job_type }}</td>
        <td class="td"><span class="{% if s == "failed" %}chip-red{% else %}chip-amber{% endif %}">{{ s }}</span></td>
        <td class="td">{{ job.run_at | default(value="—") }}</td>
        <td class="td max-w-[20rem] truncate" title="{{ job.error | default(value='') }}">{{ job.error | default(value='') }}</td>
        <td class="td">
          <button class="btn" onclick="jobAction('queue','{{ job.id }}')">Queue now</button>
          <button class="btn-danger" onclick="jobAction('delete','{{ job.id }}')">Delete</button>
        </td>
      </tr>
      {% else %}<tr><td class="td" colspan="6">No delayed jobs.</td></tr>{% endfor %}
    </tbody>
  </table>
</div>

{% if page is defined %}
  {% set prev = page.current - 1 %}{% set next = page.current + 1 %}
  <div class="mt-4 flex items-center justify-between text-sm">
    <div class="text-slate-500 dark:text-slate-400">Showing {{ page.start }}–{{ page.end }} of {{ page.total }}</div>
    <div class="flex gap-2">
      <a class="btn {% if not page.has_prev %}opacity-50 pointer-events-none{% endif %}" href="?page={{ prev }}">Prev</a>
      <a class="btn {% if not page.has_next %}opacity-50 pointer-events-none{% endif %}" href="?page={{ next }}">Next</a>
    </div>
  </div>
{% endif %}

<script>
async function jobAction(action, job_id){
  try{
    const r = await fetch('/qrush/metrics/jobs/action',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({action, job_id})});
    if(r.ok){ location.reload(); } else { alert('Action failed'); }
  }catch(e){ alert('Action error'); }
}
</script>
{% endblock content %}