feature: add river inspector that returns various info about the system

オープン

#781 2025年2月20日に作成コメント 4 件リアクション 5 件担当者 0 名 GitHub で見る

まだ誰も着手していません。

評価

難易度: 5/5
見積もり時間: 1週間以上
初心者へのやさしさ: 25/100

issue の種類: 機能追加
明瞭さ: 説明が足りない
活発さ: 停滞
技術スタック: go, postgresql
領域: api, backend, databases

調査の方向性

Start by reviewing River's subscriptions documentation and the asynq Inspector API for the proposed inspection shape. Compare those options with riverui's internal/dbsqlc SQL queries and the listed approaches for collecting job metrics. Done would require an agreed API for counts by state and kind, but the issue does not define the final scope.

索引モデルが issue の本文から書いたものです。

説明

enhancement

Motivation

I want to periodically upload metrics about jobs count, state, and kind.

The API that allows that would be great, but at the same time I have a workaround and I think this is a low prio issue.

API

I think about something similar as asynq inspector, but only with few methods like:

JobsCountByState
JobsCountByKind
etc...

This API might be utilized by riverui, because right now riverui uses its own sql queries

API dosen't need to guarantee backward compatibility as it will probably change in upcoming versions.

Possible solutions

River middleware that sends telemetry data about each job.

This would work, but many projects enable sampling to reduce the cost of storing large amount of data.

subscriptions

This approach requires a leader election to make sure only one instance sends data.
Btw - I think exposing a leader election as an API would be a great value added by river.

Collector

This is the most common setup and collector could aggregate metrics. But if you want to keep things simple then instances send the telemetry data straight to the external service.

Perioding job + sql

Right now I use periodic job and custom sql queries to fetch the data and send it once a while.

主要言語: Go
スター: 5.7k
フォーク: 179
平均マージ: 15時間 43分
マージ済み PR（30日）: 13

コントリビューションガイド

このリポジトリのコントリビューションガイドは索引されていません

はじめの一歩

issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
リポジトリをフォークし、ブランチを切って変更します。
issue 番号を参照したプルリクエストを送ります。

riverqueue/river のほかの issue

Remote JobCancel() can be silently lost while the notifier is reconnecting (no durable-poll fallback) オープン

難易度 5/5 1週間以上初心者へのやさしさ 45/100

riverqueue/river#1358 · コメント 1 件 · 2026年8月22日に作成
JobRescuer can overwrite a job that completed after the stuck-job fetch オープン

難易度 3/5 1〜2日初心者へのやさしさ 78/100

riverqueue/river#1302 · コメント 2 件 · 2026年7月10日に作成
River job stuck at running オープン

難易度 4/5 3〜5日初心者へのやさしさ 35/100

riverqueue/river#1258 · コメント 7 件 · 2026年5月26日に作成
river stuck connected to read-only postgres instance オープン

難易度 4/5 3〜5日初心者へのやさしさ 45/100

riverqueue/river#1225 · コメント 14 件 · 2026年4月22日に作成
Workflow dep resolution leaves `scheduled_at` stale, breaking queue delay monitoring オープン

難易度 4/5 3〜5日初心者へのやさしさ 52/100

riverqueue/river#1185 · コメント 2 件 · 2026年3月25日に作成

riverqueue/river の issue をすべて見る

似ている issue

verify-gofmt cannot fail: it runs gofmt -w before the check オープン

kind/bug

難易度 2/5 1〜3時間初心者へのやさしさ 88/100

kubernetes-sigs/prow#953 · コメント 1 件 · 2026年9月21日に作成
caddy fmt deletes an opening brace at the end of the input オープン

難易度 2/5 1〜3時間初心者へのやさしさ 88/100

caddyserver/caddy#8046 · 2026年9月21日に作成
gate (GO): setLeverage intermittently fails with INVALID_SIGNATURE — signed Rawencode(query) and sent Urlencode(query) can differ in key order オープン

難易度 2/5 1〜3時間初心者へのやさしさ 86/100

ccxt/ccxt#30561 · 2026年9月21日に作成
Improve unit tests in sectionParser_test.go オープン

L1 recommended for recruits

難易度 2/5 1〜3時間初心者へのやさしさ 88/100

UTDNebula/api-tools#202 · 2026年9月21日に作成
[optimization:agents-md-curator] AGENTS.md: compress duplicated Debugging & Logging section and merge redundant autopilot rules オープン

optimization optimization:agents-md-curator

難易度 2/5 1〜3時間初心者へのやさしさ 86/100

githubnext/gh-aw-cao#13143 · 2026年9月20日に作成

Go の issue をもっと見る