Versions in this module Expand all Collapse all v0 v0.24.0 Jun 24, 2026 Changes in this version + const PageSize + var ErrNotFound = errors.New("dashboard: failed job not found") + func Handler(insp Inspector) http.Handler + type Dashboard struct + func New(stats *Stats, failed FailedJobs) *Dashboard + func (d *Dashboard) Handler() http.Handler + type FailedJob struct + Err string + FailedAt time.Time + ID string + Job queue.Job + Queue string + type FailedJobs interface + Forget func(ctx context.Context, id string) error + List func(ctx context.Context) ([]FailedJob, error) + Retry func(ctx context.Context, id string) error + type Inspector interface + Failed func(page int) ([]JobView, error) + FlushFailed func() error + Forget func(id string) error + Pending func(queue string, page int) ([]JobView, error) + Retry func(id string) error + Stats func() (StatsView, error) + func NewInspector(stats *Stats, failed *MemoryFailedJobs) Inspector + type JobView struct + Attempts int + Err string + FailedAt time.Time + ID string + Name string + Queue string + type MemoryFailedJobs struct + func NewMemoryFailedJobs(requeue RequeueFunc) *MemoryFailedJobs + func (m *MemoryFailedJobs) Forget(_ context.Context, id string) error + func (m *MemoryFailedJobs) Len() int + func (m *MemoryFailedJobs) List(_ context.Context) ([]FailedJob, error) + func (m *MemoryFailedJobs) Record(j queue.Job, queueName string, err error) + func (m *MemoryFailedJobs) Retry(ctx context.Context, id string) error + func (m *MemoryFailedJobs) WithStats(s *Stats) *MemoryFailedJobs + type QueueStat struct + Failed uint64 + Pending int64 + Processed uint64 + Pushed uint64 + Queue string + Retried uint64 + Throughput float64 + type RequeueFunc func(ctx context.Context, j queue.Job) error + type Sampler struct + func NewSampler(insp Inspector, interval, window time.Duration) *Sampler + func (s *Sampler) Rate(queue string) float64 + func (s *Sampler) Sample() + func (s *Sampler) Start() *Sampler + func (s *Sampler) Stop() + func (s *Sampler) Window(queue string) []ThroughputSample + type Stats struct + func NewStats() *Stats + func (s *Stats) OnFailed(queue string) + func (s *Stats) OnProcessed(queue string) + func (s *Stats) OnPushed(queue string) + func (s *Stats) OnRetried(queue string) + func (s *Stats) Snapshot() []QueueStat + func (s *Stats) Totals() QueueStat + type StatsView struct + Queues []QueueStat + Totals QueueStat + type ThroughputSample struct + At time.Time + Queue string + Rate float64
Go to main page