[fahimfaisaal]

Summary

Read-only queue and job views on varmq queue routes (goptics/varmq#173, merged): GET /queues, GET /queues/{id}/jobs?state&offset&limit. Job types from github.com/goptics/varmq/contract v0.1.0 (zero-dep module, nothing else from varmq). Merged with main (#7 a11y fixes).

 go.mod                          # + github.com/goptics/varmq/contract v0.1.0
 internal/
 ├── api/
+│   └── queues.go          # ListQueues, ListJobs; Queue ID escaped as one path segment; 404/405 = no queue data
 ├── fleet/
+│   ├── queues.go          # FetchQueues from every instance, GroupQueues by Queue ID (one copy, never summed)
 │   └── fleettest/fakevarmq.go   # serves spec-shaped queue fixtures
 └── web/
+    ├── queues.go          # /queues list, /queues/{id} job page
+    └── templates/queue.html, queues.html
     templates/layout.html  # Queues nav link
     static/app.css         # queue/job styles; queues table stacks on phones

Request flow on page load:

GET /queues
  guard: current snapshot, this env's lease, same source (as actions)
  FetchQueues            # one /queues call per instance
  GroupQueues            # by Queue ID; read copy beats error copy; On = instances reporting it
GET /queues/{id}?state=failed&offset=0
  FetchJobs              # first instance; next instance on 404/error
  render one row per job: ID, short time, final error or one-line payload, attempts
  open row (<details>): to-scale timeline with step icons, errors per attempt, payload (indented, cut at 64 KiB)

• Types: contract.JobRecord, JobError, JobCounts (int64), JobTotals, JobState. Local only api.QueueSummary: /queues wire entry (ID, error, optional counts/totals); contract has no type for it.
• Job page: state tabs with counts, sticky on scroll (one compact row on phones); jobs as dense rows in one panel; header shows range and state count (1–50 of 10000); short times (clock today, day this year, else date) with full time in title and <time datetime>; timeline steps as inline SVG icons (enqueued, started, finished or failed), hollow when not reached.
• Errors: one line per failed attempt (errors[], oldest first, max 10): attempt no., <time>, text. Job summary shows final error.
• a11y as fix(web): audit P2 a11y fixes: headings, down units, partial dots, tips, phone table #7: page h1 (sr-only "Queues"; Queue ID on job page), queues table stacks at <= 640px with data-label, state tabs aria-current, <time datetime>, payload <pre tabindex="0">.
• Instances without queue routes (older varmq, storage without QueueInspector) named in a note. Worker views unchanged.
• Collector stores no queue data: no queue history. Job page no auto-refresh (would close an open job).
• No CLI view: vartop has no worker list command to mirror.

Not covered

• No single-job route in spec: job has no permalink; pending job with no ID has no key.
• Paging: spec answer has no total. "Next" hidden when state count (read with the page) says page is last; count can be a moment stale.

Evidence

• internal/api/queues_test.go: Queue ID escaping ({, }, /), 404/405 fallback, payload bytes kept as sent, errors decode.
• internal/fleet/queues_test.go: grouping does not sum, unsupported instances, error copies, jobs fallback to next instance.
• internal/web/queues_test.go: both pages against fake varmq, incl. Queue ID with /, errors list oldest first.
• go vet ./..., go test -race ./... pass.
• Browser: dashboard, /queues, /queues/{id} at 375px dark and 800px light, fake fleet.
• Real fleet: varmq 8cf7a4a (#173) + redisq feat/job-records-inspector, 2 instances on one Redis queue orders/eu (Queue ID with /). List, failed tab, errors, paging checked; found + fixed: same-host instances (same instance name) both labelled instance-1 in "Reported by".
• GitNexus detect-changes vs main: shared symbols touched are routes (+2 routes), parseTemplates (+2 sets), Page (+2 nil-able fields); callers covered by tests.

Merge Danger

Door: two-way

Additive: new routes, templates, nav link, one zero-dep module. Revert removes it cleanly.

Blast Radius: web

• Open /queues tab sends one /queues request per instance per poll interval.
• Pages show "no queue data" until instances run varmq with #173 and a storage with QueueInspector.

Screenshots (before / after)

Fake fleet, 3 instances: instance-1 and instance-3 share two queues; instance-2 older varmq (no queue routes). Images on branch pr-assets/queue-views.

Dashboard nav, 375px, dark: new "Queues" link.

Before	After

Dashboard nav, 800px, light

Before	After

New pages, no before (main answers 404).

/queues: one row per Queue ID, counts not summed, "Reported by" instances; note names instance-2 (no queue routes). Phone: rows stack, cells labelled.

375px, dark	800px, light

/queues/{id}, failed tab, job expanded: sticky state tabs with counts; list header with range; row with final error; open job: timeline with step icons, 3 errors entries oldest first, indented payload.

375px, dark	800px, light

/queues/{id}, pending tab: jobs with no ID yet; one-line payload preview per row.

375px, dark	800px, light